Lines Matching refs:incoming_buf

231     nxt_unit_mmap_buf_t      *incoming_buf;  member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1121 while (recv_msg.incoming_buf != NULL) { in nxt_unit_process_msg()
1122 nxt_unit_mmap_buf_free(recv_msg.incoming_buf); in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1317 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1406 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_req_body()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
1633 for (b = recv_msg->incoming_buf; b != NULL; b = b->next) { in nxt_unit_process_websocket()
1638 ws_impl->buf = recv_msg->incoming_buf; in nxt_unit_process_websocket()
1640 recv_msg->incoming_buf = NULL; in nxt_unit_process_websocket()
1788 while (req_impl->incoming_buf != NULL) { in nxt_unit_request_info_release()
1789 nxt_unit_mmap_buf_free(req_impl->incoming_buf); in nxt_unit_request_info_release()
4221 incoming_tail = &recv_msg->incoming_buf; in nxt_unit_mmap_read()
4230 while (recv_msg->incoming_buf != NULL) { in nxt_unit_mmap_read()
4231 nxt_unit_mmap_buf_release(recv_msg->incoming_buf); in nxt_unit_mmap_read()
4241 b = recv_msg->incoming_buf; in nxt_unit_mmap_read()
4256 while (recv_msg->incoming_buf != NULL) { in nxt_unit_mmap_read()
4257 nxt_unit_mmap_buf_release(recv_msg->incoming_buf); in nxt_unit_mmap_read()