42 apr_status_t ajp_msg_dump(apr_pool_t *pool, ajp_msg_t *msg, char *err,  in ajp_msg_dump()  argument
49     apr_size_t  len = msg->len;  in ajp_msg_dump()
65                  err, msg->pos, msg->len, msg->max_size);  in ajp_msg_dump()
81              x = msg->buf[i + j];  in ajp_msg_dump()
91             x = msg->buf[i + j];  in ajp_msg_dump()
115 apr_status_t ajp_msg_log(request_rec *r, ajp_msg_t *msg, char *err)  in ajp_msg_log()  argument
129         rc = ajp_msg_dump(r->pool, msg, err, count, &buf);  in ajp_msg_log()
149 apr_status_t ajp_msg_check_header(ajp_msg_t *msg, apr_size_t *len)  in ajp_msg_check_header()  argument
151     apr_byte_t *head = msg->buf;  in ajp_msg_check_header()
167     if (msglen > msg->max_size) {  in ajp_msg_check_header()
171                      msglen, msg->max_size);  in ajp_msg_check_header()
175     msg->len = msglen + AJP_HEADER_LEN;  in ajp_msg_check_header()
176     msg->pos = AJP_HEADER_LEN;  in ajp_msg_check_header()
188 apr_status_t ajp_msg_reset(ajp_msg_t *msg)  in ajp_msg_reset()  argument
190     msg->len = AJP_HEADER_LEN;  in ajp_msg_reset()
191     msg->pos = AJP_HEADER_LEN;  in ajp_msg_reset()
202 apr_status_t ajp_msg_reuse(ajp_msg_t *msg)  in ajp_msg_reuse()  argument
207     buf = msg->buf;  in ajp_msg_reuse()
208     max_size = msg->max_size;  in ajp_msg_reuse()
209     memset(msg, 0, sizeof(ajp_msg_t));  in ajp_msg_reuse()
210     msg->buf = buf;  in ajp_msg_reuse()
211     msg->max_size = max_size;  in ajp_msg_reuse()
212     msg->header_len = AJP_HEADER_LEN;  in ajp_msg_reuse()
213     ajp_msg_reset(msg);  in ajp_msg_reuse()
223 apr_status_t ajp_msg_end(ajp_msg_t *msg)  in ajp_msg_end()  argument
225     apr_size_t len = msg->len - AJP_HEADER_LEN;  in ajp_msg_end()
227     if (msg->server_side) {  in ajp_msg_end()
228         msg->buf[0] = 0x41;  in ajp_msg_end()
229         msg->buf[1] = 0x42;  in ajp_msg_end()
232         msg->buf[0] = 0x12;  in ajp_msg_end()
233         msg->buf[1] = 0x34;  in ajp_msg_end()
236     msg->buf[2] = (apr_byte_t)((len >> 8) & 0xFF);  in ajp_msg_end()
237     msg->buf[3] = (apr_byte_t)(len & 0xFF);  in ajp_msg_end()
242 static APR_INLINE int ajp_log_overflow(ajp_msg_t *msg, const char *context)  in ajp_log_overflow()  argument
247                  context, msg->pos, msg->len);  in ajp_log_overflow()
258 apr_status_t ajp_msg_append_uint32(ajp_msg_t *msg, apr_uint32_t value)  in ajp_msg_append_uint32()  argument
260     apr_size_t len = msg->len;  in ajp_msg_append_uint32()
262     if ((len + 4) > msg->max_size) {  in ajp_msg_append_uint32()
263         return ajp_log_overflow(msg, "ajp_msg_append_uint32");  in ajp_msg_append_uint32()
266     msg->buf[len]     = (apr_byte_t)((value >> 24) & 0xFF);  in ajp_msg_append_uint32()
267     msg->buf[len + 1] = (apr_byte_t)((value >> 16) & 0xFF);  in ajp_msg_append_uint32()
268     msg->buf[len + 2] = (apr_byte_t)((value >> 8) & 0xFF);  in ajp_msg_append_uint32()
269     msg->buf[len + 3] = (apr_byte_t)(value & 0xFF);  in ajp_msg_append_uint32()
271     msg->len += 4;  in ajp_msg_append_uint32()
283 apr_status_t ajp_msg_append_uint16(ajp_msg_t *msg, apr_uint16_t value)  in ajp_msg_append_uint16()  argument
285     apr_size_t len = msg->len;  in ajp_msg_append_uint16()
287     if ((len + 2) > msg->max_size) {  in ajp_msg_append_uint16()
288         return ajp_log_overflow(msg, "ajp_msg_append_uint16");  in ajp_msg_append_uint16()
291     msg->buf[len]     = (apr_byte_t)((value >> 8) & 0xFF);  in ajp_msg_append_uint16()
292     msg->buf[len + 1] = (apr_byte_t)(value & 0xFF);  in ajp_msg_append_uint16()
294     msg->len += 2;  in ajp_msg_append_uint16()
306 apr_status_t ajp_msg_append_uint8(ajp_msg_t *msg, apr_byte_t value)  in ajp_msg_append_uint8()  argument
308     apr_size_t len = msg->len;  in ajp_msg_append_uint8()
310     if ((len + 1) > msg->max_size) {  in ajp_msg_append_uint8()
311         return ajp_log_overflow(msg, "ajp_msg_append_uint8");  in ajp_msg_append_uint8()
314     msg->buf[len] = value;  in ajp_msg_append_uint8()
315     msg->len += 1;  in ajp_msg_append_uint8()
329 apr_status_t ajp_msg_append_string_ex(ajp_msg_t *msg, const char *value,  in ajp_msg_append_string_ex()  argument
335         return(ajp_msg_append_uint16(msg, 0xFFFF));  in ajp_msg_append_string_ex()
339     if ((msg->len + len + 3) > msg->max_size) {  in ajp_msg_append_string_ex()
340         return ajp_log_overflow(msg, "ajp_msg_append_cvt_string");  in ajp_msg_append_string_ex()
344     ajp_msg_append_uint16(msg, (apr_uint16_t)len);  in ajp_msg_append_string_ex()
347     memcpy(msg->buf + msg->len, value, len + 1); /* including \0 */  in ajp_msg_append_string_ex()
351         ap_xlate_proto_to_ascii((char *)msg->buf + msg->len, len + 1);  in ajp_msg_append_string_ex()
354     msg->len += len + 1;  in ajp_msg_append_string_ex()
367 apr_status_t ajp_msg_append_bytes(ajp_msg_t *msg, const apr_byte_t *value,  in ajp_msg_append_bytes()  argument
374     if ((msg->len + valuelen) > msg->max_size) {  in ajp_msg_append_bytes()
375         return ajp_log_overflow(msg, "ajp_msg_append_bytes");  in ajp_msg_append_bytes()
379     memcpy(msg->buf + msg->len, value, valuelen);  in ajp_msg_append_bytes()
380     msg->len += valuelen;  in ajp_msg_append_bytes()
392 apr_status_t ajp_msg_get_uint32(ajp_msg_t *msg, apr_uint32_t *rvalue)  in ajp_msg_get_uint32()  argument
396     if ((msg->pos + 3) > msg->len) {  in ajp_msg_get_uint32()
397         return ajp_log_overflow(msg, "ajp_msg_get_uint32");  in ajp_msg_get_uint32()
400     value  = ((msg->buf[(msg->pos++)] & 0xFF) << 24);  in ajp_msg_get_uint32()
401     value |= ((msg->buf[(msg->pos++)] & 0xFF) << 16);  in ajp_msg_get_uint32()
402     value |= ((msg->buf[(msg->pos++)] & 0xFF) << 8);  in ajp_msg_get_uint32()
403     value |= ((msg->buf[(msg->pos++)] & 0xFF));  in ajp_msg_get_uint32()
417 apr_status_t ajp_msg_get_uint16(ajp_msg_t *msg, apr_uint16_t *rvalue)  in ajp_msg_get_uint16()  argument
421     if ((msg->pos + 1) > msg->len) {  in ajp_msg_get_uint16()
422         return ajp_log_overflow(msg, "ajp_msg_get_uint16");  in ajp_msg_get_uint16()
425     value  = ((msg->buf[(msg->pos++)] & 0xFF) << 8);  in ajp_msg_get_uint16()
426     value += ((msg->buf[(msg->pos++)] & 0xFF));  in ajp_msg_get_uint16()
440 apr_status_t ajp_msg_peek_uint16(ajp_msg_t *msg, apr_uint16_t *rvalue)  in ajp_msg_peek_uint16()  argument
444     if ((msg->pos + 1) > msg->len) {  in ajp_msg_peek_uint16()
445         return ajp_log_overflow(msg, "ajp_msg_peek_uint16");  in ajp_msg_peek_uint16()
448     value = ((msg->buf[(msg->pos)] & 0xFF) << 8);  in ajp_msg_peek_uint16()
449     value += ((msg->buf[(msg->pos + 1)] & 0xFF));  in ajp_msg_peek_uint16()
463 apr_status_t ajp_msg_peek_uint8(ajp_msg_t *msg, apr_byte_t *rvalue)  in ajp_msg_peek_uint8()  argument
465     if (msg->pos > msg->len) {  in ajp_msg_peek_uint8()
466         return ajp_log_overflow(msg, "ajp_msg_peek_uint8");  in ajp_msg_peek_uint8()
469     *rvalue = msg->buf[msg->pos];  in ajp_msg_peek_uint8()
480 apr_status_t ajp_msg_get_uint8(ajp_msg_t *msg, apr_byte_t *rvalue)  in ajp_msg_get_uint8()  argument
483     if (msg->pos > msg->len) {  in ajp_msg_get_uint8()
484         return ajp_log_overflow(msg, "ajp_msg_get_uint8");  in ajp_msg_get_uint8()
487     *rvalue = msg->buf[msg->pos++];  in ajp_msg_get_uint8()
499 apr_status_t ajp_msg_get_string(ajp_msg_t *msg, const char **rvalue)  in ajp_msg_get_string()  argument
505     status = ajp_msg_get_uint16(msg, &size);  in ajp_msg_get_string()
506     start = msg->pos;  in ajp_msg_get_string()
508     if ((status != APR_SUCCESS) || (size + start > msg->max_size)) {  in ajp_msg_get_string()
509         return ajp_log_overflow(msg, "ajp_msg_get_string");  in ajp_msg_get_string()
512     msg->pos += (apr_size_t)size;  in ajp_msg_get_string()
513     msg->pos++;                   /* a String in AJP is NULL terminated */  in ajp_msg_get_string()
515     *rvalue = (const char *)(msg->buf + start);  in ajp_msg_get_string()
528 apr_status_t ajp_msg_get_bytes(ajp_msg_t *msg, apr_byte_t **rvalue,  in ajp_msg_get_bytes()  argument
535     status = ajp_msg_get_uint16(msg, &size);  in ajp_msg_get_bytes()
537     start = msg->pos;  in ajp_msg_get_bytes()
539     if ((status != APR_SUCCESS) || (size + start > msg->max_size)) {  in ajp_msg_get_bytes()
540         return ajp_log_overflow(msg, "ajp_msg_get_bytes");  in ajp_msg_get_bytes()
542     msg->pos += (apr_size_t)size;   /* only bytes, no trailer */  in ajp_msg_get_bytes()
544     *rvalue     = msg->buf + start;  in ajp_msg_get_bytes()
561     ajp_msg_t *msg = (ajp_msg_t *)apr_pcalloc(pool, sizeof(ajp_msg_t));  in ajp_msg_create()  local
563     msg->server_side = 0;  in ajp_msg_create()
565     msg->buf = (apr_byte_t *)apr_palloc(pool, size);  in ajp_msg_create()
566     msg->len = 0;  in ajp_msg_create()
567     msg->header_len = AJP_HEADER_LEN;  in ajp_msg_create()
568     msg->max_size = size;  in ajp_msg_create()
569     *rmsg = msg;  in ajp_msg_create()
609 apr_status_t ajp_msg_serialize_ping(ajp_msg_t *msg)  in ajp_msg_serialize_ping()  argument
612     ajp_msg_reset(msg);  in ajp_msg_serialize_ping()
614     if ((rc = ajp_msg_append_uint8(msg, CMD_AJP13_PING)) != APR_SUCCESS)  in ajp_msg_serialize_ping()
630 apr_status_t ajp_msg_serialize_cping(ajp_msg_t *msg)  in ajp_msg_serialize_cping()  argument
633     ajp_msg_reset(msg);  in ajp_msg_serialize_cping()
635     if ((rc = ajp_msg_append_uint8(msg, CMD_AJP13_CPING)) != APR_SUCCESS)  in ajp_msg_serialize_cping()