Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 136) sorted by relevance

123456

/unit/src/
H A Dnxt_fiber.c68 fib->task.thread = thr; in nxt_fiber_create()
92 fib->task.thread = thr; in nxt_fiber_create()
93 fib->task.log = thr->log; in nxt_fiber_create()
235 nxt_task_t *task; in nxt_fiber_trampoline() local
241 task = &fib->task; in nxt_fiber_trampoline()
246 nxt_fiber_enqueue(task->thread, task, fib); in nxt_fiber_trampoline()
300 nxt_task_t *task; in nxt_fiber_trampoline() local
302 task = &fib->task; in nxt_fiber_trampoline()
307 nxt_fiber_enqueue(task->thread, task, fib); in nxt_fiber_trampoline()
373 nxt_fiber_enqueue(task->thread, &fib->main->engine->task, fib); in nxt_fiber_yield()
[all …]
H A Dnxt_process.c139 rt = task->thread->runtime; in nxt_process_init_start()
264 task->thread->tid = 0; in nxt_process_child_fixup()
272 rt = task->thread->runtime; in nxt_process_child_fixup()
366 rt = task->thread->runtime; in nxt_process_create()
401 thread = task->thread; in nxt_process_setup()
512 rt = task->thread->runtime; in nxt_process_whoami()
605 nxt_process_quit(task, 1); in nxt_process_whoami_error()
686 nxt_process_quit(task, 1); in nxt_process_created_ok()
702 nxt_process_quit(task, 1); in nxt_process_created_error()
897 task->thread->tid = 0; in nxt_process_daemon()
[all …]
H A Dnxt_conn_accept.c66 lev->task.thread = task->thread; in nxt_listen_event()
69 lev->socket.task = &lev->task; in nxt_listen_event()
70 lev->timer.task = &lev->task; in nxt_listen_event()
92 engine = task->thread->engine; in nxt_conn_accept_alloc()
115 nxt_conn_free(task, c); in nxt_conn_accept_alloc()
131 lev->accept(task, lev, data); in nxt_conn_listen_handler()
176 nxt_socket_close(task, s); in nxt_conn_io_accept()
183 nxt_conn_accept(task, lev, c); in nxt_conn_io_accept()
195 nxt_debug(task, "client: %*s", in nxt_conn_accept()
199 engine = task->thread->engine; in nxt_conn_accept()
[all …]
H A Dnxt_conn_connect.c21 if (nxt_conn_socket(task, c) == NXT_OK) { in nxt_conn_sys_socket()
30 handler, task, c, data); in nxt_conn_sys_socket()
57 engine = task->thread->engine; in nxt_conn_io_connect()
78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket() argument
83 nxt_debug(task, "event conn socket"); in nxt_conn_socket()
106 c->socket.task = task; in nxt_conn_socket()
107 c->read_timer.task = task; in nxt_conn_socket()
108 c->write_timer.task = task; in nxt_conn_socket()
112 nxt_socket_close(task, s); in nxt_conn_socket()
141 task, c, data); in nxt_conn_connect_test()
[all …]
H A Dnxt_stream_source.c47 nxt_log(task, NXT_LOG_ERR, in nxt_stream_source_connect()
66 nxt_event_conn_connect(task, c); in nxt_stream_source_connect()
71 stream->error_handler(task, stream); in nxt_stream_source_connect()
107 nxt_event_conn_write(task, c); in nxt_stream_source_connected()
115 c->io->write(task, c, stream); in nxt_stream_source_connected()
161 nxt_conn_read(task, c); in nxt_stream_source_write_ready()
204 nxt_source_filter(task->thread, c->write_work_queue, task, in nxt_stream_source_read_ready()
215 nxt_conn_read(task, c); in nxt_stream_source_read_ready()
428 nxt_conn_close(task, c); in nxt_stream_source_closed()
438 nxt_source_filter(task->thread, c->write_work_queue, task, stream->next, b); in nxt_stream_source_closed()
[all …]
H A Dnxt_port.c197 nxt_runtime_quit(task, 0); in nxt_port_quit_handler()
235 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_send_port()
266 rt = task->thread->runtime; in nxt_port_new_port_handler()
301 port->socket.task = task; in nxt_port_new_port_handler()
316 rt = task->thread->runtime; in nxt_port_process_ready_handler()
350 rt = task->thread->runtime; in nxt_port_mmap_handler()
415 rt = task->thread->runtime; in nxt_port_change_log_file_handler()
468 rt = task->thread->runtime; in nxt_port_remove_notify_others()
485 buf = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_remove_notify_others()
567 handler(task, port, data); in nxt_port_post_handler()
[all …]
H A Dnxt_signal_handlers.c14 static void nxt_signal_handler(nxt_task_t *task, void *obj, void *data);
32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler() argument
34 nxt_trace(task, "signal signo:%d (%s) recevied, ignored", in nxt_signal_handler()
40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler() argument
42 nxt_process_quit(task, 0); in nxt_signal_quit_handler()
47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler() argument
49 nxt_debug(task, "sigterm handler signo:%d (%s)", in nxt_signal_sigterm_handler()
54 nxt_runtime_quit(task, 0); in nxt_signal_sigterm_handler()
59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler() argument
61 nxt_debug(task, "sigquit handler signo:%d (%s)", in nxt_signal_sigquit_handler()
[all …]
H A Dnxt_h1proto_websocket.c87 nxt_conn_tcp_nodelay_on(task, c); in nxt_h1p_websocket_first_frame_start()
105 timer->task = &c->task; in nxt_h1p_websocket_first_frame_start()
125 nxt_debug(task, "h1p ws frame start"); in nxt_h1p_websocket_frame_start()
181 out = nxt_http_buf_mem(task, r, 2); in nxt_h1p_conn_ws_keepalive()
196 nxt_http_request_send(task, r, out); in nxt_h1p_conn_ws_keepalive()
234 engine = task->thread->engine; in nxt_h1p_conn_ws_frame_header_read()
449 nxt_debug(task, "h1p conn ws error"); in nxt_h1p_conn_ws_error()
570 engine = task->thread->engine; in nxt_h1p_conn_ws_frame_payload_read()
628 nxt_http_request_send(task, r, out); in hxt_h1p_send_ws_error()
654 nxt_debug(task, "h1p conn ws pong"); in nxt_h1p_conn_ws_pong()
[all …]
H A Dnxt_h1proto.c496 r->task = c->task; in nxt_h1p_conn_request_init()
497 task = &r->task; in nxt_h1p_conn_request_init()
498 c->socket.task = task; in nxt_h1p_conn_request_init()
499 c->read_timer.task = task; in nxt_h1p_conn_request_init()
1699 task = &c->task; in nxt_h1p_request_close()
1700 c->socket.task = task; in nxt_h1p_request_close()
1701 c->read_timer.task = task; in nxt_h1p_request_close()
1702 c->write_timer.task = task; in nxt_h1p_request_close()
2825 task = &c->task; in nxt_h1p_peer_close()
2826 c->socket.task = task; in nxt_h1p_peer_close()
[all …]
H A Dnxt_conn_proxy.c158 nxt_conn_proxy_complete(task, p); in nxt_conn_proxy_client_buffer_alloc()
255 nxt_conn_tcp_nodelay_on(task, peer); in nxt_conn_proxy_connected()
307 nxt_conn_proxy_complete(task, p); in nxt_conn_proxy_peer_read()
723 nxt_conn_proxy_complete(task, p); in nxt_conn_proxy_close()
742 nxt_conn_proxy_close(task, c, p); in nxt_conn_proxy_error()
802 nxt_conn_proxy_complete(task, p); in nxt_conn_proxy_refused()
835 nxt_conn_proxy_complete(task, p); in nxt_conn_proxy_reconnect_handler()
856 nxt_debug(source->socket.task, in nxt_conn_proxy_shutdown()
860 nxt_debug(sink->socket.task, in nxt_conn_proxy_shutdown()
901 nxt_conn_proxy_close(task, c, p); in nxt_conn_proxy_read_error()
[all …]
H A Dnxt_socketpair.c24 nxt_socketpair_create(nxt_task_t *task, nxt_socket_t *pair) in nxt_socketpair_create() argument
27 nxt_alert(task, "socketpair() failed %E", nxt_errno); in nxt_socketpair_create()
31 nxt_debug(task, "socketpair(): %d:%d", pair[0], pair[1]); in nxt_socketpair_create()
55 nxt_alert(task, "failed to set SO_PASSCRED %E", nxt_errno); in nxt_socketpair_create()
71 nxt_socketpair_close(task, pair); in nxt_socketpair_create()
78 nxt_socketpair_close(nxt_task_t *task, nxt_socket_t *pair) in nxt_socketpair_close() argument
80 nxt_socket_close(task, pair[0]); in nxt_socketpair_close()
81 nxt_socket_close(task, pair[1]); in nxt_socketpair_close()
112 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd); in nxt_socketpair_send()
152 nxt_debug(ev->task, "recvmsg(%d, %ui, %uz): %z", in nxt_socketpair_recv()
[all …]
H A Dnxt_job.c60 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
109 nxt_debug(task, "%s start", job->name); in nxt_job_start()
114 job->engine = task->thread->engine; in nxt_job_start()
117 job->task, job, (void *) handler); in nxt_job_start()
128 handler(job->task, job, job->data); in nxt_job_start()
143 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline()
146 nxt_job_return(task, job, job->abort_handler); in nxt_job_thread_trampoline()
149 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
157 nxt_debug(task, "%s return", job->name); in nxt_job_return()
189 job->task->thread = task->thread; in nxt_job_thread_return_handler()
[all …]
H A Dnxt_event_conn_job_sendfile.c30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile() argument
32 nxt_fd_event_disable(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile()
35 nxt_event_conn_job_sendfile_start(task, c, NULL); in nxt_event_conn_job_sendfile()
54 c->write_state->error_handler(task, c, NULL); in nxt_event_conn_job_sendfile_start()
91 nxt_event_conn_job_sendfile_return(task, jbs, c); in nxt_event_conn_job_sendfile_start()
150 nxt_job_return(task, &jbs->job, jbs->ready_handler); in nxt_event_conn_job_sendfile_handler()
156 jbs->job.task, jbs, c); in nxt_event_conn_job_sendfile_handler()
180 nxt_debug(task, "event conn sendfile sent:%z", sent); in nxt_event_conn_job_sendfile_return()
185 nxt_job_destroy(task, jbs); in nxt_event_conn_job_sendfile_return()
223 task, c, c->socket.data); in nxt_event_conn_job_sendfile_return()
[all …]
H A Dnxt_credential.c9 static nxt_int_t nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp,
47 nxt_alert(task, in nxt_credential_get()
63 if (nxt_credential_groups_get(task, mp, uc) != NXT_OK) { in nxt_credential_get()
95 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get() argument
193 nxt_debug(task, "getgroups(0, NULL): %d", nsaved); in nxt_credential_groups_get()
219 nxt_debug(task, "getgroups(): %d", nsaved); in nxt_credential_groups_get()
223 nxt_log(task, NXT_LOG_NOTICE, in nxt_credential_groups_get()
232 nxt_alert(task, "initgroups(%s, %d) failed %E", in nxt_credential_groups_get()
245 nxt_debug(task, "getgroups(0, NULL): %d", ngroups); in nxt_credential_groups_get()
283 nxt_credential_setuid(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setuid() argument
[all …]
H A Dnxt_http_proxy.c18 static void nxt_http_proxy_server_get(nxt_task_t *task,
20 static void nxt_http_proxy_upstream_ready(nxt_task_t *task,
22 static void nxt_http_proxy_upstream_error(nxt_task_t *task,
24 static nxt_http_action_t *nxt_http_proxy(nxt_task_t *task,
111 nxt_debug(task, "http proxy: \"%V\"", &u->name); in nxt_http_proxy()
113 return nxt_upstream_proxy_handler(task, r, u); in nxt_http_proxy()
146 upstream->proto->get(task, us); in nxt_upstream_proxy_handler()
162 us->state->ready(task, us); in nxt_http_proxy_server_get()
269 nxt_http_proxy_error(task, r, peer); in nxt_http_proxy_header_read()
305 nxt_http_request_send(task, r, out); in nxt_http_proxy_send_body()
[all …]
H A Dnxt_controller.c174 rt = task->thread->runtime; in nxt_controller_prefork()
267 nxt_file_close(task, &file); in nxt_controller_file_read()
430 rt = task->thread->runtime; in nxt_controller_send_current_conf()
449 rt = task->thread->runtime; in nxt_controller_router_ready_handler()
468 rt = task->thread->runtime; in nxt_controller_remove_pid_handler()
576 rt = task->thread->runtime; in nxt_controller_conf_send()
1007 nxt_conn_free(task, c); in nxt_controller_conn_free()
1493 rt = task->thread->runtime; in nxt_controller_check_postpone_request()
1515 rt = task->thread->runtime; in nxt_controller_process_status()
1978 rt = task->thread->runtime; in nxt_controller_process_control()
[all …]
H A Dnxt_conn_close.c12 static void nxt_conn_close_timer_handler(nxt_task_t *task, void *obj,
14 static void nxt_conn_close_error_ignore(nxt_task_t *task, void *obj,
30 nxt_debug(c->socket.task, "conn close fd:%d, to:%d", in nxt_conn_close()
87 nxt_socket_shutdown(task, c->socket.fd, SHUT_RDWR); in nxt_conn_shutdown_handler()
90 task, c, engine); in nxt_conn_shutdown_handler()
119 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_handler()
129 task, c, c->socket.data); in nxt_conn_close_handler()
154 engine = task->thread->engine; in nxt_conn_close_timer_handler()
157 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_timer_handler()
166 task, c, c->socket.data); in nxt_conn_close_timer_handler()
[all …]
H A Dnxt_router.c3183 job->work.task = &job->task; in nxt_router_engine_joints_create()
3229 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3231 job->work.task = &job->task; in nxt_router_engine_quit()
3261 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3312 link->work.task = task; in nxt_router_thread_create()
3413 task = &engine->task; in nxt_router_thread_start()
3425 thread->task = &engine->task; in nxt_router_thread_start()
3463 work->task = link->work.task; in nxt_router_thread_start()
3659 task = &task->thread->engine->task; in nxt_router_listen_socket_close()
4960 r->timer.task = &engine->task; in nxt_router_process_http_request()
[all …]
H A Dnxt_router_access_log.c25 static void nxt_router_access_log_writer(nxt_task_t *task,
32 static void nxt_router_access_log_ready(nxt_task_t *task,
34 static void nxt_router_access_log_error(nxt_task_t *task,
86 nxt_alert(task, "access log map error"); in nxt_router_access_log_create()
158 nxt_router_access_log_write_ready(task, r, ctx); in nxt_router_access_log_writer()
167 nxt_var_query_resolve(task, r->var_query, ctx, in nxt_router_access_log_writer()
218 rt = task->thread->runtime; 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()
272 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_error()
[all …]
H A Dnxt_buf_filter.c28 nxt_buf_filter(task, f, NULL); in nxt_buf_filter_add()
41 nxt_debug(task, "buf filter"); in nxt_buf_filter()
169 task, f, f->data); in nxt_buf_filter()
218 task, f, NULL); in nxt_buf_filter_enqueue()
250 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_file_read_start()
321 task, f, f->data); in nxt_buf_filter_file_read()
374 nxt_buf_filter(task, f, NULL); in nxt_buf_filter_file_job_completion()
387 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_file_job_completion()
395 task, f, f->data); in nxt_buf_filter_file_job_completion()
422 nxt_buf_filter_file_read(task, f); in nxt_buf_filter_buf_completion()
[all …]
H A Dnxt_main_process.c91 nxt_main_process_title(task); in nxt_main_process_start()
380 rt = task->thread->runtime; in nxt_main_start_process_handler()
460 rt = task->thread->runtime; in nxt_main_start_process_handler()
558 rt = task->thread->runtime; in nxt_main_process_created_handler()
634 rt = task->thread->runtime; in nxt_main_process_whoami_handler()
662 port->socket.task = task; in nxt_main_process_whoami_handler()
765 nxt_runtime_quit(task, 0); in nxt_main_process_sigterm_handler()
779 nxt_runtime_quit(task, 0); in nxt_main_process_sigquit_handler()
797 rt = task->thread->runtime; in nxt_main_process_sigusr1_handler()
897 rt = task->thread->runtime; in nxt_main_process_sigchld_handler()
[all …]
H A Dnxt_socket.h96 NXT_EXPORT void nxt_socket_defer_accept(nxt_task_t *task, nxt_socket_t s,
98 NXT_EXPORT nxt_int_t nxt_socket_getsockopt(nxt_task_t *task, nxt_socket_t s,
100 NXT_EXPORT nxt_int_t nxt_socket_setsockopt(nxt_task_t *task, nxt_socket_t s,
102 NXT_EXPORT nxt_int_t nxt_socket_bind(nxt_task_t *task, nxt_socket_t s,
104 NXT_EXPORT nxt_int_t nxt_socket_connect(nxt_task_t *task, nxt_socket_t s,
106 NXT_EXPORT void nxt_socket_shutdown(nxt_task_t *task, nxt_socket_t s,
108 NXT_EXPORT void nxt_socket_close(nxt_task_t *task, nxt_socket_t s);
112 NXT_EXPORT nxt_int_t nxt_socketpair_create(nxt_task_t *task,
114 NXT_EXPORT void nxt_socketpair_close(nxt_task_t *task, nxt_socket_t *pair);
122 nxt_fd_nonblocking(task, fd)
[all …]
H A Dnxt_application.c174 rt = task->thread->runtime; in nxt_discovery_start()
232 nxt_log(task, NXT_LOG_NOTICE, in nxt_discovery_modules()
604 rt = task->thread->runtime; in nxt_proto_start_process_handler()
676 nxt_proto_quit_children(task); in nxt_proto_quit_handler()
681 nxt_process_quit(task, 0); in nxt_proto_quit_handler()
753 nxt_proto_quit_children(task); in nxt_proto_sigterm_handler()
758 nxt_process_quit(task, 0); in nxt_proto_sigterm_handler()
773 rt = task->thread->runtime; in nxt_proto_sigchld_handler()
1064 rt = task->thread->runtime; in nxt_unit_default_init()
1151 rt = task->thread->runtime; in nxt_proto_process_add()
[all …]
H A Dnxt_socket.c36 nxt_debug(task, "socket(): %d", s); in nxt_socket_create()
42 nxt_socket_close(task, s); in nxt_socket_create()
84 nxt_debug(task, "getsockopt(%d, %ui, %s): %d", in nxt_socket_getsockopt()
89 nxt_alert(task, "getsockopt(%d, %ui, %s) failed %E", in nxt_socket_getsockopt()
106 nxt_debug(task, "setsockopt(%d, %ui, %s): %d", in nxt_socket_setsockopt()
184 nxt_alert(task, "bind(%d, %*s) failed %E", in nxt_socket_bind()
198 nxt_debug(task, "connect(%d, %*s)", in nxt_socket_connect()
240 nxt_log(task, level, "connect(%d, %*s) failed %E", in nxt_socket_connect()
254 nxt_debug(task, "shutdown(%d, %ui)", s, how); in nxt_socket_shutdown()
283 nxt_socket_close(nxt_task_t *task, nxt_socket_t s) in nxt_socket_close() argument
[all …]
H A Dnxt_clone.c75 nxt_alert(task, "write(%s): %E", path, nxt_errno); in nxt_clone_credential_setgroups()
96 nxt_alert(task, "writing past the buffer"); in nxt_clone_credential_map_write()
189 nxt_alert(task, "write past mapinfo buffer"); in nxt_clone_credential_map_set()
204 nxt_clone_credential_map(nxt_task_t *task, pid_t pid, in nxt_clone_credential_map() argument
213 rt = task->thread->runtime; in nxt_clone_credential_map()
257 nxt_clone_vldt_credential_uidmap(nxt_task_t *task, in nxt_clone_vldt_credential_uidmap() argument
269 rt = task->thread->runtime; in nxt_clone_vldt_credential_uidmap()
311 nxt_clone_vldt_credential_gidmap(nxt_task_t *task, in nxt_clone_vldt_credential_gidmap() argument
319 rt = task->thread->runtime; in nxt_clone_vldt_credential_gidmap()
324 nxt_log(task, NXT_LOG_NOTICE, in nxt_clone_vldt_credential_gidmap()
[all …]

123456