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