jk_msg_ajp.c

Tomcat 4.1与WebServer集成组件的源代码包.

/* ========================================================================= *
 *                                                                           *
 *                 The Apache Software License,  Version 1.1                 *
 *                                                                           *
 *          Copyright (c) 1999-2002 The Apache Software Foundation.          *
 *                           All rights reserved.                            *
 *                                                                           *
 * ========================================================================= *
 *                                                                           *
 * Redistribution and use in source and binary forms,  with or without modi- *
 * fication, are permitted provided that the following conditions are met:   *
 *                                                                           *
 * 1. Redistributions of source code  must retain the above copyright notice *
 *    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. The end-user documentation  included with the redistribution,  if any, *
 *    must include the following acknowlegement:                             *
 *                                                                           *
 *       "This product includes  software developed  by the Apache  Software *
 *        Foundation <http://www.apache.org/>."                              *
 *                                                                           *
 *    Alternately, this acknowlegement may appear in the software itself, if *
 *    and wherever such third-party acknowlegements normally appear.         *
 *                                                                           *
 * 4. The names  "The  Jakarta  Project",  "Jk",  and  "Apache  Software     *
 *    Foundation"  must not be used  to endorse or promote  products derived *
 *    from this  software without  prior  written  permission.  For  written *
 *    permission, please contact <[e-mail]>.                        *
 *                                                                           *
 * 5. Products derived from this software may not be called "Apache" nor may *
 *    "Apache" appear in their names without prior written permission of the *
 *    Apache Software Foundation.                                            *
 *                                                                           *
 * THIS SOFTWARE IS PROVIDED "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 APACHE  SOFTWARE  FOUNDATION 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 indivi- *
 * duals on behalf of the  Apache Software Foundation.  For more information *
 * on the Apache Software Foundation, please see <http://www.apache.org/>.   *
 *                                                                           *
 * ========================================================================= */

/**
 *  Data marshaling. Originally based on Jserv's ajp12 and other similar
 *  formats. Implements the jk_msg interface. 
 *
 *  Will be eventually replaced with XDR or CDR.
 *
 * @author:      Gal Shachor <[e-mail]>                           
 * @author:      Henri Gomez <[e-mail]>                               
 * @author:      Costin Manolache
 */

#include "jk_pool.h"
#include "jk_msg.h"
#include "jk_logger.h"
#include "jk_endpoint.h"
#include "jk_channel.h"
#include "jk_requtil.h"

/* Signature for the messages sent from Apache to tomcat
 */
#define AJP13_WS_HEADER           0x1234
/* Size of the header ( signature + len )
 */
#define AJP_HEADER_LEN            (4)
#define AJP_HEADER_SZ_LEN         (2)

char *jk_HEX="0123456789ABCDEFX";

/*
 * Debugging - display the buffer.
 */
static void jk2_msg_ajp_dump(jk_env_t *env, struct jk_msg *_this,
                             char *err)
{
    unsigned int i=0;
    char line[80];
    char *current;
    unsigned int j;
    unsigned int len=_this->len;

    if( len > 1024 ) len=1024;
    
    env->l->jkLog( env, env->l, JK_LOG_INFO,
                   "%s pos=%d len=%d max=%d \n",
                   err, _this->pos, _this->len, _this->maxlen );

    for( i=0; i< len; i+=16) {
        current=line;
/*         I can't believe I did this ! That's the %.4x :-) 
           *current++= jk_HEX[ ( i & 0xf000 ) >> 12  ]; */
/*         *current++= jk_HEX[ ( i & 0x0f00 ) >> 8  ]; */
/*         *current++= jk_HEX[ ( i & 0xf0 ) >> 4 ]; */
/*         *current++= jk_HEX[ ( i & 0x0f )  ]; */
        
        for( j=0; j<16; j++ ) {
            unsigned char x=(_this->buf[i+j]);

            *current++ = jk_HEX[x >> 4 ];
            *current++ = jk_HEX[x & 0x0f ];
            *current++ =' ';
        }
        *current++=' ';
        *current++='-';
        *current++=' ';
        for( j=0; j<16; j++ ) {
            unsigned char x=_this->buf[i+j];

            if( x > 0x20 && x < 0x7F ) {
                *current++=x;
            } else {
                *current++='.';
            }
        }
        *current++='\n';
        *current++='\0';
        env->l->jkLog(env, env->l, JK_LOG_INFO,
                      "%.4x    %s", i, line);
    }
}

 
static void jk2_msg_ajp_reset(jk_env_t *env, jk_msg_t *_this) 
{
    _this->len = AJP_HEADER_LEN;
    _this->pos = AJP_HEADER_LEN;
}

static void jk2_msg_ajp_end(jk_env_t *env, jk_msg_t *msg) 
{
    unsigned short len=msg->len - AJP_HEADER_LEN;
    

    if(msg->serverSide ) {
        msg->buf[0]=0x41;
        msg->buf[1]=0x42;
    } else {
        msg->buf[0]=0x12;
        msg->buf[1]=0x34;
    }

    msg->buf[2]=(unsigned char)((len >> 8) & 0xFF);
    msg->buf[3]=(unsigned char)(len & 0xFF);
}



static int jk2_msg_ajp_appendLong(jk_env_t *env, jk_msg_t *msg,
                                  const unsigned long val)
{
    int len=msg->len;
    
    if(len + AJP_HEADER_LEN > msg->maxlen) {
        return JK_ERR;
    }
    
    msg->buf[len]       = (unsigned char)((val >> 24) & 0xFF);
    msg->buf[len + 1]   = (unsigned char)((val >> 16) & 0xFF);
    msg->buf[len + 2]   = (unsigned char)((val >> 8) & 0xFF);
    msg->buf[len + 3]   = (unsigned char)(val & 0xFF);

    msg->len += 4;

    return JK_OK;
}


static int jk2_msg_ajp_appendInt(jk_env_t *env, jk_msg_t *msg, 
                                 const unsigned short val) 
{
    int len=msg->len;
    if(len + 2 > msg->maxlen) {
        return JK_ERR;
    }

    msg->buf[len]       = (unsigned char)((val >> 8) & 0xFF);
    msg->buf[len + 1]   = (unsigned char)(val & 0xFF);

    msg->len += 2;

    return JK_OK;
}

static int jk2_msg_ajp_appendByte(jk_env_t *env, jk_msg_t *msg, 
                                  unsigned char val)
{
    int len=msg->len;
    if(len + 1 > msg->maxlen) {
	    return JK_ERR;
    }

    msg->buf[len]= val;
    msg->len += 1;

    return JK_OK;
}

static int jk2_msg_ajp_appendMap(jk_env_t *env, jk_msg_t *msg, 
                                 jk_map_t *map) 
{
    int rc;
    int i;
    int size=map->size(env, map);

    rc=msg->appendInt( env, msg, (short)size );
    
    for( i=0; i< size; i++ ) {
        char *name=map->nameAt( env, map, i );
        char *val=map->valueAt( env, map, i );
        if( rc== JK_OK ) 
            rc=msg->appendString( env, msg, name );
        if( rc== JK_OK ) 
            msg->appendString( env, msg, val );
    }
    
    return rc;
}

static int jk2_msg_ajp_getMap(jk_env_t *env, jk_msg_t *msg, 
                              jk_map_t *map) 
{
    int size=msg->getInt( env, msg );
    int i;

    if( size < 0 ) {
        env->l->jkLog( env, env->l, JK_LOG_ERROR,
                       "msg_ajp.getMap(): negative size %d\n",
                       size);
        return JK_ERR;
    }
    for( i=0; i<size; i++ ) {
        char *name= msg->getString( env, msg );
        char *val=msg->getString( env, msg );

        map->add( env, map, name, val );
    }
    return JK_OK;
}


static int jk2_msg_ajp_appendAString(jk_env_t *env, jk_msg_t *msg, 
                                     const char *param, int convert) 
{
    int len;

    if(param==NULL) {
        msg->appendInt( env, msg, 0xFFFF );
        return JK_OK; 
    }

    len = strlen(param);
    if(msg->len + len + 2  > msg->maxlen) {
	    return JK_ERR;
    }

    /* ignore error - we checked once */
    msg->appendInt(env, msg, (unsigned short )len);

    /* We checked for space !!  */
    strncpy((char *)msg->buf + msg->len , param, len+1);    /* including \0 */
#if defined(AS400) || defined(_OSD_POSIX)
    if (convert)
    	jk_xlate_to_ascii((char *)msg->buf + msg->len, len+1);  /* convert from EBCDIC if needed */
#endif
    msg->len += len + 1;

    return JK_OK;
}



static int jk2_msg_ajp_appendString(jk_env_t *env, jk_msg_t *msg, 
                                    const char *param) 
{
    return jk2_msg_ajp_appendAString(env, msg, param, 1);
}


static int jk2_msg_ajp_appendAsciiString(jk_env_t *env, jk_msg_t *msg, 
                                         const char *param) 
{
    return jk2_msg_ajp_appendAString(env, msg, param, 0);
}


static int jk2_msg_ajp_appendBytes(jk_env_t *env, jk_msg_t  *msg,
                                   const unsigned char  *param,