Lines Matching refs:incoming_buf

233     nxt_unit_mmap_buf_t      *incoming_buf;  member
252 nxt_unit_mmap_buf_t *incoming_buf; member
971 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1152 while (recv_msg.incoming_buf != NULL) { in nxt_unit_process_msg()
1153 nxt_unit_mmap_buf_free(recv_msg.incoming_buf); in nxt_unit_process_msg()
1308 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1325 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_req_headers()
1330 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1331 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1332 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1414 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_req_body()
1419 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1427 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1430 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
1641 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_websocket()
1646 ws_impl->buf = recv_msg->incoming_buf; in nxt_unit_process_websocket()
1648 recv_msg->incoming_buf = NULL; in nxt_unit_process_websocket()
1796 while (req_impl->incoming_buf != NULL) { in nxt_unit_request_info_release()
1797 nxt_unit_mmap_buf_free(req_impl->incoming_buf); in nxt_unit_request_info_release()
4223 incoming_tail = &recv_msg->incoming_buf; in nxt_unit_mmap_read()
4232 while (recv_msg->incoming_buf != NULL) { in nxt_unit_mmap_read()
4233 nxt_unit_mmap_buf_release(recv_msg->incoming_buf); in nxt_unit_mmap_read()
4243 b = recv_msg->incoming_buf; in nxt_unit_mmap_read()
4258 while (recv_msg->incoming_buf != NULL) { in nxt_unit_mmap_read()
4259 nxt_unit_mmap_buf_release(recv_msg->incoming_buf); in nxt_unit_mmap_read()