Lines Matching refs:msg
26 * @param msg AJP Message to dump
30 char * ajp_msg_dump(apr_pool_t *pool, ajp_msg_t *msg, char *err)
38 apr_size_t len = msg->len;
47 err, msg->pos, msg->len, msg->max_size);
54 x = msg->buf[i + j];
64 x = msg->buf[i + j];
90 * @param msg AJP Message to check
94 apr_status_t ajp_msg_check_header(ajp_msg_t *msg, apr_size_t *len)
96 apr_byte_t *head = msg->buf;
112 if (msglen > msg->max_size) {
116 msglen, msg->max_size);
120 msg->len = msglen + AJP_HEADER_LEN;
121 msg->pos = AJP_HEADER_LEN;
130 * @param msg AJP Message to reset
133 apr_status_t ajp_msg_reset(ajp_msg_t *msg)
135 msg->len = AJP_HEADER_LEN;
136 msg->pos = AJP_HEADER_LEN;
144 * @param msg AJP Message to reuse
147 apr_status_t ajp_msg_reuse(ajp_msg_t *msg)
152 buf = msg->buf;
153 max_size = msg->max_size;
154 memset(msg, 0, sizeof(ajp_msg_t));
155 msg->buf = buf;
156 msg->max_size = max_size;
157 msg->header_len = AJP_HEADER_LEN;
158 ajp_msg_reset(msg);
165 * @param msg AJP Message to end
168 apr_status_t ajp_msg_end(ajp_msg_t *msg)
170 apr_size_t len = msg->len - AJP_HEADER_LEN;
172 if (msg->server_side) {
173 msg->buf[0] = 0x41;
174 msg->buf[1] = 0x42;
177 msg->buf[0] = 0x12;
178 msg->buf[1] = 0x34;
181 msg->buf[2] = (apr_byte_t)((len >> 8) & 0xFF);
182 msg->buf[3] = (apr_byte_t)(len & 0xFF);
187 static APR_INLINE int ajp_log_overflow(ajp_msg_t *msg, const char *context)
192 context, msg->pos, msg->len);
199 * @param msg AJP Message to get value from
203 apr_status_t ajp_msg_append_uint32(ajp_msg_t *msg, apr_uint32_t value)
205 apr_size_t len = msg->len;
207 if ((len + 4) > msg->max_size) {
208 return ajp_log_overflow(msg, "ajp_msg_append_uint32");
211 msg->buf[len] = (apr_byte_t)((value >> 24) & 0xFF);
212 msg->buf[len + 1] = (apr_byte_t)((value >> 16) & 0xFF);
213 msg->buf[len + 2] = (apr_byte_t)((value >> 8) & 0xFF);
214 msg->buf[len + 3] = (apr_byte_t)(value & 0xFF);
216 msg->len += 4;
224 * @param msg AJP Message to get value from
228 apr_status_t ajp_msg_append_uint16(ajp_msg_t *msg, apr_uint16_t value)
230 apr_size_t len = msg->len;
232 if ((len + 2) > msg->max_size) {
233 return ajp_log_overflow(msg, "ajp_msg_append_uint16");
236 msg->buf[len] = (apr_byte_t)((value >> 8) & 0xFF);
237 msg->buf[len + 1] = (apr_byte_t)(value & 0xFF);
239 msg->len += 2;
247 * @param msg AJP Message to get value from
251 apr_status_t ajp_msg_append_uint8(ajp_msg_t *msg, apr_byte_t value)
253 apr_size_t len = msg->len;
255 if ((len + 1) > msg->max_size) {
256 return ajp_log_overflow(msg, "ajp_msg_append_uint8");
259 msg->buf[len] = value;
260 msg->len += 1;
269 * @param msg AJP Message to get value from
274 apr_status_t ajp_msg_append_string_ex(ajp_msg_t *msg, const char *value,
280 return(ajp_msg_append_uint16(msg, 0xFFFF));
284 if ((msg->len + len + 2) > msg->max_size) {
285 return ajp_log_overflow(msg, "ajp_msg_append_cvt_string");
289 ajp_msg_append_uint16(msg, (apr_uint16_t)len);
292 memcpy(msg->buf + msg->len, value, len + 1); /* including \0 */
295 ajp_xlate_to_ascii((char *)msg->buf + msg->len, len + 1);
297 msg->len += len + 1;
305 * @param msg AJP Message to get value from
310 apr_status_t ajp_msg_append_bytes(ajp_msg_t *msg, const apr_byte_t *value,
317 if ((msg->len + valuelen) > msg->max_size) {
318 return ajp_log_overflow(msg, "ajp_msg_append_bytes");
322 memcpy(msg->buf + msg->len, value, valuelen);
323 msg->len += valuelen;
331 * @param msg AJP Message to get value from
335 apr_status_t ajp_msg_get_uint32(ajp_msg_t *msg, apr_uint32_t *rvalue)
339 if ((msg->pos + 3) > msg->len) {
340 return ajp_log_overflow(msg, "ajp_msg_get_uint32");
343 value = ((msg->buf[(msg->pos++)] & 0xFF) << 24);
344 value |= ((msg->buf[(msg->pos++)] & 0xFF) << 16);
345 value |= ((msg->buf[(msg->pos++)] & 0xFF) << 8);
346 value |= ((msg->buf[(msg->pos++)] & 0xFF));
356 * @param msg AJP Message to get value from
360 apr_status_t ajp_msg_get_uint16(ajp_msg_t *msg, apr_uint16_t *rvalue)
364 if ((msg->pos + 1) > msg->len) {
365 return ajp_log_overflow(msg, "ajp_msg_get_uint16");
368 value = ((msg->buf[(msg->pos++)] & 0xFF) << 8);
369 value += ((msg->buf[(msg->pos++)] & 0xFF));
379 * @param msg AJP Message to get value from
383 apr_status_t ajp_msg_peek_uint16(ajp_msg_t *msg, apr_uint16_t *rvalue)
387 if ((msg->pos + 1) > msg->len) {
388 return ajp_log_overflow(msg, "ajp_msg_peek_uint16");
391 value = ((msg->buf[(msg->pos)] & 0xFF) << 8);
392 value += ((msg->buf[(msg->pos + 1)] & 0xFF));
402 * @param msg AJP Message to get value from
406 apr_status_t ajp_msg_peek_uint8(ajp_msg_t *msg, apr_byte_t *rvalue)
408 if (msg->pos > msg->len) {
409 return ajp_log_overflow(msg, "ajp_msg_peek_uint8");
412 *rvalue = msg->buf[msg->pos];
419 * @param msg AJP Message to get value from
423 apr_status_t ajp_msg_get_uint8(ajp_msg_t *msg, apr_byte_t *rvalue)
426 if (msg->pos > msg->len) {
427 return ajp_log_overflow(msg, "ajp_msg_get_uint8");
430 *rvalue = msg->buf[msg->pos++];
438 * @param msg AJP Message to get value from
442 apr_status_t ajp_msg_get_string(ajp_msg_t *msg, const char **rvalue)
448 status = ajp_msg_get_uint16(msg, &size);
449 start = msg->pos;
451 if ((status != APR_SUCCESS) || (size + start > msg->max_size)) {
452 return ajp_log_overflow(msg, "ajp_msg_get_string");
455 msg->pos += (apr_size_t)size;
456 msg->pos++; /* a String in AJP is NULL terminated */
458 *rvalue = (const char *)(msg->buf + start);
466 * @param msg AJP Message to get value from
471 apr_status_t ajp_msg_get_bytes(ajp_msg_t *msg, apr_byte_t **rvalue,
478 status = ajp_msg_get_uint16(msg, &size);
480 start = msg->pos;
482 if ((status != APR_SUCCESS) || (size + start > msg->max_size)) {
483 return ajp_log_overflow(msg, "ajp_msg_get_bytes");
485 msg->pos += (apr_size_t)size; /* only bytes, no trailer */
487 *rvalue = msg->buf + start;
504 ajp_msg_t *msg = (ajp_msg_t *)apr_pcalloc(pool, sizeof(ajp_msg_t));
506 if (!msg) {
512 msg->server_side = 0;
514 msg->buf = (apr_byte_t *)apr_palloc(pool, size);
522 if (msg->buf == NULL) {
528 msg->len = 0;
529 msg->header_len = AJP_HEADER_LEN;
530 msg->max_size = size;
531 *rmsg = msg;
547 "ajp_msg_copy(): destination msg is null");
577 apr_status_t ajp_msg_serialize_ping(ajp_msg_t *msg)
580 ajp_msg_reset(msg);
582 if ((rc = ajp_msg_append_uint8(msg, CMD_AJP13_PING)) != APR_SUCCESS)
598 apr_status_t ajp_msg_serialize_cping(ajp_msg_t *msg)
601 ajp_msg_reset(msg);
603 if ((rc = ajp_msg_append_uint8(msg, CMD_AJP13_CPING)) != APR_SUCCESS)