Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 134) 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_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_process.c155 rt = task->thread->runtime; in nxt_process_init_start()
280 task->thread->tid = 0; in nxt_process_child_fixup()
288 rt = task->thread->runtime; in nxt_process_child_fixup()
607 rt = task->thread->runtime; in nxt_process_create()
653 thread = task->thread; in nxt_process_setup()
768 rt = task->thread->runtime; in nxt_process_whoami()
861 nxt_process_quit(task, 1); in nxt_process_whoami_error()
942 nxt_process_quit(task, 1); in nxt_process_created_ok()
958 nxt_process_quit(task, 1); in nxt_process_created_error()
1153 task->thread->tid = 0; in nxt_process_daemon()
[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) received, 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()
1709 task = &c->task; in nxt_h1p_request_close()
1710 c->socket.task = task; in nxt_h1p_request_close()
1711 c->read_timer.task = task; in nxt_h1p_request_close()
1712 c->write_timer.task = task; in nxt_h1p_request_close()
2835 task = &c->task; in nxt_h1p_peer_close()
2836 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.c62 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() argument
111 nxt_debug(task, "%s start", job->name); in nxt_job_start()
116 job->engine = task->thread->engine; in nxt_job_start()
119 job->task, job, (void *) handler); in nxt_job_start()
130 handler(job->task, job, job->data); in nxt_job_start()
145 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline()
148 nxt_job_return(task, job, job->abort_handler); in nxt_job_thread_trampoline()
151 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
159 nxt_debug(task, "%s return", job->name); in nxt_job_return()
191 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_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_controller.c184 rt = task->thread->runtime; in nxt_controller_prefork()
284 nxt_file_close(task, &file); in nxt_controller_file_read()
454 rt = task->thread->runtime; in nxt_controller_send_current_conf()
473 rt = task->thread->runtime; in nxt_controller_router_ready_handler()
492 rt = task->thread->runtime; in nxt_controller_remove_pid_handler()
600 rt = task->thread->runtime; in nxt_controller_conf_send()
1031 nxt_conn_free(task, c); in nxt_controller_conn_free()
1558 rt = task->thread->runtime; in nxt_controller_check_postpone_request()
1580 rt = task->thread->runtime; in nxt_controller_process_status()
2331 rt = task->thread->runtime; in nxt_controller_process_control()
[all …]
H A Dnxt_router.c3359 job->work.task = &job->task; in nxt_router_engine_joints_create()
3405 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3407 job->work.task = &job->task; in nxt_router_engine_quit()
3437 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3488 link->work.task = task; in nxt_router_thread_create()
3589 task = &engine->task; in nxt_router_thread_start()
3601 thread->task = &engine->task; in nxt_router_thread_start()
3639 work->task = link->work.task; in nxt_router_thread_start()
3835 task = &task->thread->engine->task; in nxt_router_listen_socket_close()
5173 r->timer.task = &engine->task; in nxt_router_process_http_request()
[all …]
H A Dnxt_application.c174 rt = task->thread->runtime; in nxt_discovery_start()
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()
773 rt = task->thread->runtime; in nxt_proto_sigchld_handler()
941 nxt_task_t *task; in nxt_app_set_logs() local
949 task = thr->task; in nxt_app_set_logs()
951 rt = task->thread->runtime; in nxt_app_set_logs()
1120 rt = task->thread->runtime; in nxt_unit_default_init()
1207 rt = task->thread->runtime; in nxt_proto_process_add()
[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_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_process.h56 typedef void (*nxt_isolation_cleanup_t)(nxt_task_t *task,
58 typedef void (*nxt_cgroup_cleanup_t)(nxt_task_t *task,
132 typedef nxt_int_t (*nxt_process_prefork_t)(nxt_task_t *task,
134 typedef nxt_int_t (*nxt_process_postfork_t)(nxt_task_t *task,
136 typedef nxt_int_t (*nxt_process_setup_t)(nxt_task_t *task,
138 typedef nxt_int_t (*nxt_process_start_t)(nxt_task_t *task,
164 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
166 NXT_EXPORT nxt_int_t nxt_process_daemon(nxt_task_t *task);
191 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
193 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
[all …]
H A Dnxt_clone.c61 nxt_alert(task, "write(%s): %E", path, nxt_errno); in nxt_clone_credential_setgroups()
82 nxt_alert(task, "writing past the buffer"); in nxt_clone_credential_map_write()
175 nxt_alert(task, "write past mapinfo buffer"); in nxt_clone_credential_map_set()
190 nxt_clone_credential_map(nxt_task_t *task, pid_t pid, in nxt_clone_credential_map() argument
199 rt = task->thread->runtime; in nxt_clone_credential_map()
243 nxt_clone_vldt_credential_uidmap(nxt_task_t *task, in nxt_clone_vldt_credential_uidmap() argument
255 rt = task->thread->runtime; in nxt_clone_vldt_credential_uidmap()
297 nxt_clone_vldt_credential_gidmap(nxt_task_t *task, in nxt_clone_vldt_credential_gidmap() argument
305 rt = task->thread->runtime; in nxt_clone_vldt_credential_gidmap()
310 nxt_log(task, NXT_LOG_NOTICE, in nxt_clone_vldt_credential_gidmap()
[all …]
H A Dnxt_isolation.c16 static nxt_int_t nxt_isolation_set(nxt_task_t *task,
20 static nxt_int_t nxt_isolation_set_cgroup(nxt_task_t *task,
79 rt = task->thread->runtime; in nxt_isolation_main_prefork()
146 nxt_log(task, NXT_LOG_WARN, in nxt_isolation_main_prefork()
154 ret = nxt_isolation_vldt_creds(task, process); in nxt_isolation_main_prefork()
580 rt = task->thread->runtime; in nxt_isolation_set_mounts()
727 rt = task->thread->runtime; in nxt_isolation_unmount_all()
789 ret = nxt_fs_mount(task, &mnt[i]); in nxt_isolation_prepare_rootfs()
819 nxt_debug(task, "change root: %s", rootfs); in nxt_isolation_change_root()
825 ret = nxt_isolation_chroot(task, rootfs); in nxt_isolation_change_root()
[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()
170 nxt_tstr_query_resolve(task, r->tstr_query, ctx, in nxt_router_access_log_writer()
221 rt = task->thread->runtime; in nxt_router_access_log_open()
237 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
245 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_open()
275 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_error()
[all …]
H A Dnxt_main_process.c96 nxt_main_process_title(task); in nxt_main_process_start()
440 rt = task->thread->runtime; in nxt_main_start_process_handler()
520 rt = task->thread->runtime; in nxt_main_start_process_handler()
618 rt = task->thread->runtime; in nxt_main_process_created_handler()
699 rt = task->thread->runtime; in nxt_main_process_whoami_handler()
727 port->socket.task = task; in nxt_main_process_whoami_handler()
830 nxt_runtime_quit(task, 0); in nxt_main_process_sigterm_handler()
844 nxt_runtime_quit(task, 0); in nxt_main_process_sigquit_handler()
862 rt = task->thread->runtime; in nxt_main_process_sigusr1_handler()
962 rt = task->thread->runtime; in nxt_main_process_sigchld_handler()
[all …]

123456