tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hgo...@apache.org
Subject cvs commit: jakarta-tomcat/proposals/web-connector/native/common jk_msg_buff.c jk_msg_buff.h
Date Thu, 03 May 2001 14:29:23 GMT
hgomez      01/05/03 07:29:23

  Added:       proposals/web-connector/native/common jk_msg_buff.c
                        jk_msg_buff.h
  Log:
  buffer stuff
  
  Revision  Changes    Path
  1.1                  jakarta-tomcat/proposals/web-connector/native/common/jk_msg_buff.c
  
  Index: jk_msg_buff.c
  ===================================================================
  /*
   * Copyright (c) 1997-1999 The Java Apache Project.  All rights reserved.
   *
   * Redistribution and use in source and binary forms, with or without
   * modification, are permitted provided that the following conditions
   * are met:
   *
   * 1. Redistributions of source code must retain the above copyright
   *    notice, this list of conditions and the following disclaimer.
   *
   * 2. Redistributions in binary form must reproduce the above copyright
   *    notice, this list of conditions and the following disclaimer in
   *    the documentation and/or other materials provided with the
   *    distribution.
   *
   * 3. All advertising materials mentioning features or use of this
   *    software must display the following acknowledgment:
   *    "This product includes software developed by the Java Apache 
   *    Project for use in the Apache JServ servlet engine project
   *    <http://java.apache.org/>."
   *
   * 4. The names "Apache JServ", "Apache JServ Servlet Engine" and 
   *    "Java Apache Project" must not be used to endorse or promote products 
   *    derived from this software without prior written permission.
   *
   * 5. Products derived from this software may not be called "Apache JServ"
   *    nor may "Apache" nor "Apache JServ" appear in their names without 
   *    prior written permission of the Java Apache Project.
   *
   * 6. Redistributions of any form whatsoever must retain the following
   *    acknowledgment:
   *    "This product includes software developed by the Java Apache 
   *    Project for use in the Apache JServ servlet engine project
   *    <http://java.apache.org/>."
   *    
   * THIS SOFTWARE IS PROVIDED BY THE JAVA APACHE PROJECT "AS IS" AND ANY
   * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
   * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE JAVA APACHE PROJECT OR
   * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
   * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
   * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
   * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
   * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
   * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
   * OF THE POSSIBILITY OF SUCH DAMAGE.
   *
   * This software consists of voluntary contributions made by many
   * individuals on behalf of the Java Apache Group. For more information
   * on the Java Apache Project and the Apache JServ Servlet Engine project,
   * please see <http://java.apache.org/>.
   *
   */
  
  /***************************************************************************
   * Description: Data marshaling. XDR like                                  *
   * Author:      Costin <costin@costin.dnt.ro>                              *
   * Author:      Gal Shachor <shachor@il.ibm.com>                           *
   * Author:      Henri Gomez <hgomez@slib.fr>                               *
   * Version:     $Revision: 1.1 $                                           *
   ***************************************************************************/
  
  #include "jk_pool.h"
  #include "jk_connect.h"
  #include "jk_util.h"
  #include "jk_sockbuf.h"
  #include "jk_msg_buff.h"
  #include "jk_logger.h"
  
  struct jk_msg_buf {
      jk_pool_t *pool;
  
      unsigned char *buf;
      int pos; 
      int len;
      int maxlen;
  };
  
  
  /*
   * Simple marshaling code.
   */
  
  /* XXX what's above this line can go to .h XXX */
  void jk_b_dump(jk_msg_buf_t *msg, 
                 char *err) 
  {
      int i=0;
  	printf("%s %d/%d/%d %x %x %x %x - %x %x %x %x - %x %x %x %x - %x %x %x %x\n", err, msg->pos,
msg->len, msg->maxlen,  
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++]);
  
  	i = msg->pos - 4;
      if(i < 0) {
          i=0;
      }
  	
      printf("        %x %x %x %x - %x %x %x %x --- %x %x %x %x - %x %x %x %x\n", 
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++],
  	       msg->buf[i++],msg->buf[i++],msg->buf[i++],msg->buf[i++]);
  
  }
  
  void jk_b_reset(jk_msg_buf_t *msg) 
  {
      msg->len = 4;
      msg->pos = 4;
  }
  
  void jk_b_set_int(jk_msg_buf_t *msg, 
                    int pos, 
                    unsigned short val) 
  {
      msg->buf[pos]       = (unsigned char)((val >> 8) & 0xff);
      msg->buf[pos + 1]   = (unsigned char)(val & 0xff);
  }
  
  
  int jk_b_append_int(jk_msg_buf_t *msg, 
                      unsigned short val) 
  {
      if(msg->len + 2 > msg->maxlen) {
  	    return -1;
      }
  
      jk_b_set_int(msg, msg->len, val);
  
      msg->len += 2;
  
      return 0;
  }
  
  
  void jk_b_set_byte(jk_msg_buf_t *msg, 
                     int pos, 
                     unsigned char val) 
  {
      msg->buf[pos]= val;
  }
  
  int jk_b_append_byte(jk_msg_buf_t *msg, 
                       unsigned char val)
  {
      if(msg->len + 1 > msg->maxlen) {
  	    return -1;
      }
  
      jk_b_set_byte(msg, msg->len, val);
  
      msg->len += 1;
  
      return 0;
  }
  
  
  void jk_b_end(jk_msg_buf_t *msg) 
  {
      /* 
       * Ugly way to set the size in the right position 
       */
      jk_b_set_int(msg, 2, (unsigned short )(msg->len - 4)); /* see protocol */
      jk_b_set_int(msg, 0, 0x1234);
  }
  
  
  jk_msg_buf_t *jk_b_new(jk_pool_t *p) 
  {
      jk_msg_buf_t *msg = 
              (jk_msg_buf_t *)jk_pool_alloc(p, sizeof(jk_msg_buf_t));
  
      if(!msg) {
          return NULL;
      }
  
      msg->pool = p;
      
      return msg;
  }
  
  int jk_b_set_buffer(jk_msg_buf_t *msg, 
                      char *data, 
                      int buffSize) 
  {
      if(!msg) {
          return -1;
      }
  
      msg->len = 0;
      msg->buf = (unsigned char *)data;
      msg->maxlen = buffSize;
      
      return 0;
  }
  
  
  int jk_b_set_buffer_size(jk_msg_buf_t *msg, 
                           int buffSize) 
  {
      unsigned char *data = (unsigned char *)jk_pool_alloc(msg->pool, buffSize);
      
      if(!data) {
  	    return -1;
      }
  
      jk_b_set_buffer(msg, (char *)data, buffSize);
      return 0;
  }
  
  unsigned char *jk_b_get_buff(jk_msg_buf_t *msg) 
  {
      return msg->buf;
  }
  
  unsigned int jk_b_get_pos(jk_msg_buf_t *msg) 
  {
      return msg->pos;
  }
  
  void jk_b_set_pos(jk_msg_buf_t *msg,
                            int pos) 
  {
      msg->pos = pos;
  }
  
  unsigned int jk_b_get_len(jk_msg_buf_t *msg) 
  {
      return msg->len;
  }
  
  void jk_b_set_len(jk_msg_buf_t *msg, 
                    int len) 
  {
      msg->len=len;
  }
  
  int jk_b_get_size(jk_msg_buf_t *msg) 
  {
      return msg->maxlen;
  }
  
  int jk_b_append_string(jk_msg_buf_t *msg, 
                         const char *param) 
  {
      int len;
  
      if(!param) {
  	    jk_b_append_int( msg, 0xFFFF );
  	    return 0; 
      }
  
      len = strlen(param);
      if(msg->len + len + 2  > msg->maxlen) {
  	    return -1;
      }
  
      /* ignore error - we checked once */
      jk_b_append_int(msg, (unsigned short )len);
  
      /* We checked for space !!  */
      strncpy((char *)msg->buf + msg->len , param, len+1); /* including \0 */
      msg->len += len + 1;
  
      return 0;
  }
  
  unsigned short jk_b_get_int(jk_msg_buf_t *msg) 
  {
      int i;
      if(msg->pos + 1 > msg->len) {
  	    printf( "Read after end \n");
  	    return -1;
      }
      i  = ((msg->buf[msg->pos++]&0xff)<<8);
      i += (msg->buf[(msg->pos++)] & 0xFF);
      return i;
  }
  
  unsigned short jk_b_pget_int(jk_msg_buf_t *msg, 
                               int pos) 
  {
      int i= ((msg->buf[pos++]&0xff)<<8);
      i+= (msg->buf[pos] & 0xFF);
      return i;
  }
  
  unsigned char jk_b_get_byte(jk_msg_buf_t *msg) 
  {
      unsigned char rc;
      if(msg->pos > msg->len) {
  	    printf("Read after end \n");
  	    return -1;
      }
      rc = msg->buf[msg->pos++];
      
      return rc;
  }
  
  unsigned char jk_b_pget_byte(jk_msg_buf_t *msg, 
                               int pos) 
  {
      return msg->buf[pos];
  }
  
  
  unsigned char *jk_b_get_string(jk_msg_buf_t *msg) 
  {
      int size = jk_b_get_int(msg);
      int start = msg->pos;
  
      if((size < 0 ) || (size + start > msg->maxlen)) { 
  	    jk_b_dump(msg, "After get int"); 
  	    printf("ERROR\n" );
  	    return (unsigned char *)"ERROR"; /* XXX */
      }
  
      msg->pos += size;
      msg->pos++;  /* terminating NULL */
      
      return (unsigned char *)(msg->buf + start); 
  }
  
  /** Shame-less copy from somewhere.
      assert (src != dst)
   */
  static void swap_16(unsigned char *src, unsigned char *dst) 
  {
      *dst++ = *(src + 1 );
      *dst= *src;
  }
  
  /** Helpie dump function 
   */
  void jk_dump_buff(jk_logger_t *l,
                        const char *file,
                        int line,
                        int level,
                        char * what,
                        jk_msg_buf_t * msg)
  {
  #ifdef USE_ALSO_BODY
          jk_log(l, file, line, level, "%s #%d %.*s\n",
                    what,
                    jk_b_get_len(msg),
                    jk_b_get_len(msg),
                    jk_b_get_buff(msg));
  #else
  jk_log(l, file, line, level, "%s #%d\n", what, jk_b_get_len(msg));
  #endif
  }
  
  
  
  
  1.1                  jakarta-tomcat/proposals/web-connector/native/common/jk_msg_buff.h
  
  Index: jk_msg_buff.h
  ===================================================================
  /*
   * Copyright (c) 1997-1999 The Java Apache Project.  All rights reserved.
   *
   * Redistribution and use in source and binary forms, with or without
   * modification, are permitted provided that the following conditions
   * are met:
   *
   * 1. Redistributions of source code must retain the above copyright
   *    notice, this list of conditions and the following disclaimer.
   *
   * 2. Redistributions in binary form must reproduce the above copyright
   *    notice, this list of conditions and the following disclaimer in
   *    the documentation and/or other materials provided with the
   *    distribution.
   *
   * 3. All advertising materials mentioning features or use of this
   *    software must display the following acknowledgment:
   *    "This product includes software developed by the Java Apache 
   *    Project for use in the Apache JServ servlet engine project
   *    <http://java.apache.org/>."
   *
   * 4. The names "Apache JServ", "Apache JServ Servlet Engine" and 
   *    "Java Apache Project" must not be used to endorse or promote products 
   *    derived from this software without prior written permission.
   *
   * 5. Products derived from this software may not be called "Apache JServ"
   *    nor may "Apache" nor "Apache JServ" appear in their names without 
   *    prior written permission of the Java Apache Project.
   *
   * 6. Redistributions of any form whatsoever must retain the following
   *    acknowledgment:
   *    "This product includes software developed by the Java Apache 
   *    Project for use in the Apache JServ servlet engine project
   *    <http://java.apache.org/>."
   *    
   * THIS SOFTWARE IS PROVIDED BY THE JAVA APACHE PROJECT "AS IS" AND ANY
   * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
   * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE JAVA APACHE PROJECT OR
   * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
   * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
   * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
   * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
   * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
   * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
   * OF THE POSSIBILITY OF SUCH DAMAGE.
   *
   * This software consists of voluntary contributions made by many
   * individuals on behalf of the Java Apache Group. For more information
   * on the Java Apache Project and the Apache JServ Servlet Engine project,
   * please see <http://java.apache.org/>.
   *
   */
  
  /***************************************************************************
   * Description: Data marshaling. XDR like                                  *
   * Author:      Costin <costin@costin.dnt.ro>                              *
   * Author:      Gal Shachor <shachor@il.ibm.com>                           *
   * Version:     $Revision: 1.1 $                                           *
   ***************************************************************************/
  
  #ifndef JK_MSG_BUF_H
  #define JK_MSG_BUF_H
  
  
  #ifdef __cplusplus
  extern "C" {
  #endif /* __cplusplus */
  
  #define DEF_BUFFER_SZ (8 * 1024)
  
  /* XXX replace all return values with error codes */
  #define ERR_BAD_PACKET -5
  
  /*
  RPC details:
  
    - one parameter  - use a structure for more. The method
      is encoded as part of the request
    - one or no result
    - 
  
  
  
   */
  
  struct jk_msg_buf;
  typedef struct jk_msg_buf jk_msg_buf_t;
  
  /* -------------------- Setup routines -------------------- */
  
  /** Allocate a buffer.
   */
  jk_msg_buf_t *jk_b_new(jk_pool_t *p); 
  
  /** Set up a buffer with an existing buffer
   */
  int jk_b_set_buffer(jk_msg_buf_t *msg, 
                      char *data, 
                      int buffSize );
  
  /*
   * Set up a buffer with a new buffer of buffSize
   */
  int jk_b_set_buffer_size(jk_msg_buf_t *msg, 
                           int buffSize);
  
  /*
   * Finalize the buffer before sending - set length fields, etc
   */
  void jk_b_end(jk_msg_buf_t *msg);
  
  /*
   * Recycle the buffer - z for a new invocation 
   */
  void jk_b_reset(jk_msg_buf_t *msg );
  
  /*
   * Return the buffer body 
   */ 
  unsigned char *jk_b_get_buff(jk_msg_buf_t *msg);
  
  /* 
   * Return the current reading position
   */
  unsigned int jk_b_get_pos(jk_msg_buf_t *msg);
  
  /*
   * Buffer size 
   */
  int jk_b_get_size(jk_msg_buf_t *msg);
  
  void jk_b_set_len(jk_msg_buf_t *msg, 
                    int len);
  
  void jk_b_set_pos(jk_msg_buf_t *msg, 
                    int pos);
  
  /*
   * Get the  message length for incomming buffers
   *   or the current length for outgoing
   */
  unsigned int jk_b_get_len(jk_msg_buf_t *msg);
  
  /*
   * Dump the buffer header
   *   @param err Message text
   */
  void jk_b_dump(jk_msg_buf_t *msg, 
                 char *err); 
  
  /* -------------------- Real encoding -------------------- */
  
  void jk_b_set_int(jk_msg_buf_t *msg, 
                    int pos, 
                    unsigned short val);
  
  int jk_b_append_byte(jk_msg_buf_t *msg, 
                       unsigned char val);
  
  int jk_b_append_int(jk_msg_buf_t *msg, 
                      unsigned short val);
  
  int jk_b_append_string(jk_msg_buf_t *msg, 
                         const char *param);
  
  
  /* -------------------- Decoding -------------------- */
  
  unsigned char *jk_b_get_string(jk_msg_buf_t *msg);
  
  /** Get an int from the current position 
   */
  unsigned short jk_b_get_int(jk_msg_buf_t *msg);
  
  unsigned char jk_b_get_byte(jk_msg_buf_t *msg);
  
  /** Get an int from an arbitrary position 
   */
  unsigned short jk_b_pget_int(jk_msg_buf_t *msg, 
                               int pos);
  
  unsigned char jk_b_pget_byte(jk_msg_buf_t *msg, 
                               int pos);
  
  /* --------------------- Help ------------------------ */
  void jk_dump_buff(jk_logger_t *l, 
                        const char *file,
                        int line,
                        int level,
                        char * what,
                        jk_msg_buf_t * msg);
  
  #ifdef __cplusplus
  }
  #endif /* __cplusplus */
  
  #endif /* JK_MSG_BUF_H */
  
  
  

Mime
View raw message