Lines Matching refs:nxt_task_t

165     nxt_task_t                      task;
238 nxt_http_action_t *(*handler)(nxt_task_t *task,
255 void (*body_read)(nxt_task_t *task, nxt_http_request_t *r);
256 void (*local_addr)(nxt_task_t *task, nxt_http_request_t *r);
257 void (*header_send)(nxt_task_t *task, nxt_http_request_t *r,
259 void (*send)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out);
260 nxt_off_t (*body_bytes_sent)(nxt_task_t *task, nxt_http_proto_t proto);
261 void (*discard)(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *last);
262 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
265 void (*peer_connect)(nxt_task_t *task, nxt_http_peer_t *peer);
266 void (*peer_header_send)(nxt_task_t *task, nxt_http_peer_t *peer);
267 void (*peer_header_read)(nxt_task_t *task, nxt_http_peer_t *peer);
268 void (*peer_read)(nxt_task_t *task, nxt_http_peer_t *peer);
269 void (*peer_close)(nxt_task_t *task, nxt_http_peer_t *peer);
271 void (*ws_frame_start)(nxt_task_t *task, nxt_http_request_t *r,
309 nxt_int_t nxt_http_init(nxt_task_t *task);
310 nxt_int_t nxt_h1p_init(nxt_task_t *task);
311 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
313 void nxt_http_conn_init(nxt_task_t *task, void *obj, void *data);
314 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
315 void nxt_http_request_error(nxt_task_t *task, nxt_http_request_t *r,
317 void nxt_http_request_read_body(nxt_task_t *task, nxt_http_request_t *r);
318 void nxt_http_request_header_send(nxt_task_t *task, nxt_http_request_t *r,
320 void nxt_http_request_ws_frame_start(nxt_task_t *task, nxt_http_request_t *r,
322 void nxt_http_request_send(nxt_task_t *task, nxt_http_request_t *r,
324 nxt_buf_t *nxt_http_buf_mem(nxt_task_t *task, nxt_http_request_t *r,
327 void nxt_http_request_error_handler(nxt_task_t *task, void *obj, void *data);
328 void nxt_http_request_close_handler(nxt_task_t *task, void *obj, void *data);
346 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
348 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
350 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
354 nxt_http_action_t *nxt_http_pass_application(nxt_task_t *task,
357 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
360 nxt_http_route_rule_t *nxt_http_route_types_rule_create(nxt_task_t *task,
365 nxt_int_t nxt_http_action_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf,
367 void nxt_http_request_action(nxt_task_t *task, nxt_http_request_t *r,
370 nxt_int_t nxt_upstreams_create(nxt_task_t *task, nxt_router_temp_conf_t *tmcf,
378 nxt_int_t nxt_http_static_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf,
386 nxt_http_action_t *nxt_http_application_handler(nxt_task_t *task,
390 nxt_http_action_t *nxt_upstream_proxy_handler(nxt_task_t *task,
401 nxt_buf_t *nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r,
403 void nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r,
412 void nxt_h1p_websocket_first_frame_start(nxt_task_t *task,
414 void nxt_h1p_websocket_frame_start(nxt_task_t *task, nxt_http_request_t *r,
416 void nxt_h1p_complete_buffers(nxt_task_t *task, nxt_h1proto_t *h1p,