Lines Matching refs:task

25 static void nxt_router_access_log_writer(nxt_task_t *task,
28 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj,
30 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj,
32 static void nxt_router_access_log_ready(nxt_task_t *task,
34 static void nxt_router_access_log_error(nxt_task_t *task,
36 static void nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj,
38 static void nxt_router_access_log_reopen_ready(nxt_task_t *task,
40 static void nxt_router_access_log_reopen_error(nxt_task_t *task,
60 nxt_router_access_log_create(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_access_log_create() argument
86 nxt_alert(task, "access log map error"); in nxt_router_access_log_create()
102 nxt_alert(task, "failed to allocate access log structure"); in nxt_router_access_log_create()
121 nxt_alert(task, "failed to allocate log format structure"); in nxt_router_access_log_create()
142 nxt_router_access_log_writer(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_access_log_writer() argument
158 nxt_router_access_log_write_ready(task, r, ctx); in nxt_router_access_log_writer()
166 nxt_var_query(task, r->var_query, format, &ctx->text); in nxt_router_access_log_writer()
167 nxt_var_query_resolve(task, r->var_query, ctx, in nxt_router_access_log_writer()
175 nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_ready() argument
185 nxt_http_request_close_handler(task, r, r->proto.any); in nxt_router_access_log_write_ready()
190 nxt_router_access_log_write_error(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_error() argument
197 nxt_router_access_log_open(nxt_task_t *task, nxt_router_temp_conf_t *tmcf) in nxt_router_access_log_open() argument
218 rt = task->thread->runtime; in nxt_router_access_log_open()
222 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open()
230 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_open()
234 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
242 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_open()
247 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready() argument
259 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
260 nxt_router_conf_apply, task, tmcf, NULL); in nxt_router_access_log_ready()
265 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error() argument
272 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_error()
293 nxt_router_access_log_release(nxt_task_t *task, nxt_thread_spinlock_t *lock, in nxt_router_access_log_release() argument
326 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler() argument
366 rt = task->thread->runtime; in nxt_router_access_log_reopen_handler()
370 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler()
378 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_reopen_handler()
382 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
397 nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_reopen_completion() argument
410 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready() argument
423 nxt_alert(task, "dup2(%FD, %FD) failed %E", in nxt_router_access_log_reopen_ready()
434 nxt_router_access_log_reopen_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_error() argument