Lines Matching refs:buf

523     if (msg_info->buf == NULL) {  in nxt_router_msg_cancel()
543 for (b = msg_info->buf; b != NULL; b = next) { in nxt_router_msg_cancel()
554 msg_info->buf = NULL; in nxt_router_msg_cancel()
766 if (nxt_buf_mem_used_size(&msg->buf->mem) != sizeof(size_t)) { in nxt_router_conf_data_handler()
768 (int) nxt_buf_mem_used_size(&msg->buf->mem)); in nxt_router_conf_data_handler()
772 nxt_memcpy(&size, msg->buf->mem.pos, sizeof(size_t)); in nxt_router_conf_data_handler()
842 app_name.length = nxt_buf_mem_used_size(&msg->buf->mem); in nxt_router_app_restart_handler()
843 app_name.start = msg->buf->mem.pos; in nxt_router_app_restart_handler()
2660 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error()
3783 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler()
3810 if (msg->buf == b) { in nxt_router_response_ready_handler()
3812 msg->buf = NULL; in nxt_router_response_ready_handler()
4040 b = req_rpc_data->msg_info.buf; in nxt_router_req_headers_ack_handler()
4046 req_rpc_data->msg_info.buf->next = NULL; in nxt_router_req_headers_ack_handler()
4948 nxt_buf_t *buf, *body; in nxt_router_app_prepare_request() local
4970 buf = nxt_router_prepare_msg(task, req_rpc_data->request, app, in nxt_router_app_prepare_request()
4972 if (nxt_slow_path(buf == NULL)) { in nxt_router_app_prepare_request()
4983 nxt_buf_used_size(buf), in nxt_router_app_prepare_request()
4986 req_rpc_data->msg_info.buf = buf; in nxt_router_app_prepare_request()
5008 nxt_port_mmap_handler_t *mmap_handler = buf->parent; in nxt_router_app_prepare_request()
5012 msg.mm.chunk_id = nxt_port_mmap_chunk_id(hdr, buf->mem.pos); in nxt_router_app_prepare_request()
5013 msg.mm.size = nxt_buf_used_size(buf); in nxt_router_app_prepare_request()
5029 buf->is_port_mmap_sent = 1; in nxt_router_app_prepare_request()
5030 buf->mem.pos = buf->mem.free; in nxt_router_app_prepare_request()
5103 nxt_buf_t *b, *buf, *out, **tail; in nxt_router_prepare_msg() local
5312 buf = out; in nxt_router_prepare_msg()
5313 tail = &buf->next; in nxt_router_prepare_msg()
5320 if (buf == NULL) { in nxt_router_prepare_msg()
5323 buf = nxt_port_mmap_get_buf(task, &app->outgoing, free_size); in nxt_router_prepare_msg()
5324 if (nxt_slow_path(buf == NULL)) { in nxt_router_prepare_msg()
5326 buf = out->next; in nxt_router_prepare_msg()
5329 out = buf; in nxt_router_prepare_msg()
5334 *tail = buf; in nxt_router_prepare_msg()
5335 tail = &buf->next; in nxt_router_prepare_msg()
5338 free_size = nxt_buf_mem_free_size(&buf->mem); in nxt_router_prepare_msg()
5340 && nxt_port_mmap_increase_buf(task, buf, size, 1) in nxt_router_prepare_msg()
5343 free_size = nxt_buf_mem_free_size(&buf->mem); in nxt_router_prepare_msg()
5350 buf->mem.free = nxt_cpymem(buf->mem.free, pos, copy_size); in nxt_router_prepare_msg()
5360 buf = NULL; in nxt_router_prepare_msg()
5487 if (nxt_slow_path(nxt_buf_used_size(msg->buf) in nxt_router_get_mmap_handler()
5491 (int) nxt_buf_used_size(msg->buf)); in nxt_router_get_mmap_handler()
5496 get_mmap_msg = (nxt_port_msg_get_mmap_t *) msg->buf->mem.pos; in nxt_router_get_mmap_handler()
5557 if (nxt_slow_path(nxt_buf_used_size(msg->buf) in nxt_router_get_port_handler()
5561 (int) nxt_buf_used_size(msg->buf)); in nxt_router_get_port_handler()
5566 get_port_msg = (nxt_port_msg_get_port_t *) msg->buf->mem.pos; in nxt_router_get_port_handler()