Home
last modified time | relevance | path

Searched refs:completion_handler (Results 1 – 25 of 26) sorted by relevance

12

/unit/src/
H A Dnxt_buf.c43 b->completion_handler = nxt_buf_completion; in nxt_buf_mem_alloc()
72 b->completion_handler = nxt_buf_ts_completion; in nxt_buf_mem_ts_alloc()
108 b->completion_handler = nxt_buf_completion; in nxt_buf_file_alloc()
131 b->completion_handler = nxt_buf_completion; in nxt_buf_mmap_alloc()
151 b->completion_handler = nxt_buf_completion; in nxt_buf_sync_alloc()
234 parent->completion_handler(task, parent, parent->parent); in nxt_buf_parent_completion()
257 ts->work.handler = b->completion_handler; in nxt_buf_ts_handle()
H A Dnxt_http_chunk_parse.c176 b->completion_handler, task, b, b->parent); in nxt_http_chunk_parse()
218 b->completion_handler = nxt_http_chunk_buf_completion; in nxt_http_chunk_buffer()
H A Dnxt_fastcgi_source.c439 b->completion_handler(task, b, b->parent); in nxt_fastcgi_source_record_filter()
696 b->completion_handler = fs->upstream->state->completion_handler; in nxt_fastcgi_source_body_filter()
722 b->completion_handler = fs->upstream->state->completion_handler; in nxt_fastcgi_source_last_buf()
H A Dnxt_buf_filter.c143 b->completion_handler, in nxt_buf_filter()
368 b->completion_handler = nxt_buf_filter_buf_completion; in nxt_buf_filter_file_job_completion()
432 fb->completion_handler, in nxt_buf_filter_buf_completion()
H A Dnxt_stream_module.c87 p->completion_handler = nxt_stream_connection_close; in nxt_stream_connection_peer()
H A Dnxt_http_websocket.c93 b->completion_handler, task, b, b->parent); in nxt_http_websocket_client()
H A Dnxt_router_access_log.c213 b->completion_handler = nxt_buf_dummy_completion; in nxt_router_access_log_open()
361 b->completion_handler = nxt_router_access_log_reopen_completion; in nxt_router_access_log_reopen_handler()
H A Dnxt_sendbuf.c416 handler = b->completion_handler; in nxt_sendbuf_coalesce_completion()
432 if (handler == b->completion_handler) { in nxt_sendbuf_coalesce_completion()
H A Dnxt_fastcgi_record_parse.c212 b->completion_handler, in nxt_fastcgi_record_parse()
H A Dnxt_buf.h69 nxt_work_handler_t completion_handler; member
H A Dnxt_event_conn_job_sendfile.c253 b->completion_handler, task, b, b->parent); in nxt_event_conn_job_sendfile_completion()
H A Dnxt_http_source.c563 b->completion_handler = hs->upstream->state->completion_handler; in nxt_http_source_body_filter()
H A Dnxt_port_socket.c217 b->completion_handler, task, b, b->parent); in nxt_port_socket_write2()
670 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_buf_completion()
1290 b->completion_handler, task, b, b->parent); in nxt_port_read_msg_process()
1371 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_error_handler()
H A Dnxt_conn.h347 nxt_work_handler_t completion_handler; member
H A Dnxt_h1proto_websocket.c625 out->next->completion_handler = nxt_h1p_conn_ws_error_sent; in hxt_h1p_send_ws_error()
689 b->completion_handler, task, b, b->parent); in nxt_h1p_conn_ws_pong()
H A Dnxt_port_memory.c567 b->completion_handler = nxt_port_mmap_buf_completion; in nxt_port_mmap_get_buf()
683 b->completion_handler = nxt_port_mmap_buf_completion; in nxt_port_mmap_get_incoming_buf()
H A Dnxt_stream_source.c305 b->completion_handler = nxt_stream_source_buf_completion; in nxt_stream_source_process_buffers()
H A Dnxt_http_proxy.c327 b->completion_handler = nxt_http_proxy_buf_mem_completion; in nxt_http_proxy_buf_mem_alloc()
H A Dnxt_cert.c1051 b->completion_handler(task, b, b->parent);
1077 b->completion_handler = nxt_cert_buf_completion; in nxt_cert_store_get()
H A Dnxt_http_request.c272 last->completion_handler = nxt_http_request_done; in nxt_http_request_create()
717 b->completion_handler = nxt_http_request_mem_buf_completion; in nxt_http_buf_mem()
H A Dnxt_event_engine.c696 b->completion_handler = nxt_event_engine_buf_mem_completion; in nxt_event_engine_buf_mem_alloc()
H A Dnxt_router.c555 b->completion_handler(task, b, b->parent); in nxt_router_msg_cancel()
2642 b->completion_handler = nxt_buf_dummy_completion; in nxt_router_listen_socket_rpc_create()
2871 b->completion_handler = nxt_buf_dummy_completion; in nxt_router_app_rpc_create()
3971 b->completion_handler, task, b, b->parent); in nxt_router_response_ready_handler()
4981 r->last->completion_handler = nxt_router_http_request_done; in nxt_router_process_http_request()
5410 out->completion_handler(task, out, out->parent); in nxt_router_prepare_msg()
H A Dnxt_h1proto.c1420 b->completion_handler(task, b, b->parent); in nxt_h1p_complete_buffers()
1433 in->completion_handler(task, in, in->parent); in nxt_h1p_complete_buffers()
1924 last->completion_handler = nxt_h1p_idle_response_sent; in nxt_h1p_idle_response()
H A Dnxt_conn_proxy.c985 p->completion_handler(task, p, NULL); in nxt_conn_proxy_completion()
H A Dnxt_http_static.c808 b->completion_handler = nxt_http_static_buf_completion; in nxt_http_static_body_handler()

12