Lines Matching refs:task

26 static void nxt_router_access_log_writer(nxt_task_t *task,
29 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj,
31 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj,
33 static void nxt_router_access_log_ready(nxt_task_t *task,
35 static void nxt_router_access_log_error(nxt_task_t *task,
37 static void nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj,
39 static void nxt_router_access_log_reopen_ready(nxt_task_t *task,
41 static void nxt_router_access_log_reopen_error(nxt_task_t *task,
67 nxt_router_access_log_create(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_access_log_create() argument
95 nxt_alert(task, "access log map error"); in nxt_router_access_log_create()
111 nxt_alert(task, "failed to allocate access log structure"); in nxt_router_access_log_create()
130 nxt_alert(task, "failed to allocate log format structure"); in nxt_router_access_log_create()
166 nxt_router_access_log_writer(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_access_log_writer() argument
183 nxt_router_access_log_write_ready(task, r, ctx); in nxt_router_access_log_writer()
194 nxt_tstr_query(task, r->tstr_query, format, &ctx->text); in nxt_router_access_log_writer()
195 nxt_tstr_query_resolve(task, r->tstr_query, ctx, in nxt_router_access_log_writer()
203 nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_ready() argument
213 nxt_http_request_close_handler(task, r, r->proto.any); in nxt_router_access_log_write_ready()
218 nxt_router_access_log_write_error(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_error() argument
225 nxt_router_access_log_open(nxt_task_t *task, nxt_router_temp_conf_t *tmcf) in nxt_router_access_log_open() argument
246 rt = task->thread->runtime; in nxt_router_access_log_open()
250 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open()
258 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_open()
262 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
270 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_open()
275 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready() argument
287 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
288 nxt_router_conf_apply, task, tmcf, NULL); in nxt_router_access_log_ready()
293 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error() argument
300 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_error()
321 nxt_router_access_log_release(nxt_task_t *task, nxt_thread_spinlock_t *lock, in nxt_router_access_log_release() argument
354 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler() argument
394 rt = task->thread->runtime; in nxt_router_access_log_reopen_handler()
398 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler()
406 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_reopen_handler()
410 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
425 nxt_router_access_log_reopen_completion(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_reopen_completion() argument
438 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready() argument
451 nxt_alert(task, "dup2(%FD, %FD) failed %E", in nxt_router_access_log_reopen_ready()
462 nxt_router_access_log_reopen_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_error() argument