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()
377 thread = task->thread; in nxt_process_setup()
488 rt = task->thread->runtime; in nxt_process_whoami()
559 rt = task->thread->runtime; in nxt_process_whoami_ok()
581 nxt_process_quit(task, 1); in nxt_process_whoami_error()
662 nxt_process_quit(task, 1); in nxt_process_created_ok()
678 nxt_process_quit(task, 1); in nxt_process_created_error()
921 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()
194 nxt_debug(task, "client: %*s", in nxt_conn_accept()
253 engine = task->thread->engine; in nxt_conn_accept_close_idle()
[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.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()
2824 task = &c->task; in nxt_h1p_peer_close()
2825 c->socket.task = task; in nxt_h1p_peer_close()
[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_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_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()
104 nxt_debug(task, "conn close handler fd:%d", c->socket.fd); in nxt_conn_close_handler()
119 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_handler()
125 task, c, c->socket.data); in nxt_conn_close_handler()
150 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_timer_handler()
156 task, c, c->socket.data); in nxt_conn_close_timer_handler()
[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_router.c3109 job->work.task = &job->task; in nxt_router_engine_joints_create()
3155 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3157 job->work.task = &job->task; in nxt_router_engine_quit()
3187 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3238 link->work.task = task; in nxt_router_thread_create()
3339 task = &engine->task; in nxt_router_thread_start()
3351 thread->task = &engine->task; in nxt_router_thread_start()
3389 work->task = link->work.task; in nxt_router_thread_start()
3585 task = &task->thread->engine->task; in nxt_router_listen_socket_close()
5264 r->timer.task = &engine->task; in nxt_router_process_http_request()
[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.c166 rt = task->thread->runtime; in nxt_controller_prefork()
259 nxt_file_close(task, &file); in nxt_controller_file_read()
422 rt = task->thread->runtime; in nxt_controller_send_current_conf()
441 rt = task->thread->runtime; in nxt_controller_router_ready_handler()
460 rt = task->thread->runtime; in nxt_controller_remove_pid_handler()
568 rt = task->thread->runtime; in nxt_controller_conf_send()
584 fd = nxt_shm_open(task, size); in nxt_controller_conf_send()
991 nxt_conn_free(task, c); in nxt_controller_conn_free()
1446 rt = task->thread->runtime; in nxt_controller_check_postpone_request()
1809 rt = task->thread->runtime; in nxt_controller_process_control()
[all …]
H A Dnxt_application.c167 rt = task->thread->runtime; in nxt_discovery_start()
225 nxt_log(task, NXT_LOG_NOTICE, in nxt_discovery_modules()
597 rt = task->thread->runtime; in nxt_proto_start_process_handler()
667 nxt_proto_quit_children(task); in nxt_proto_quit_handler()
672 nxt_process_quit(task, 0); in nxt_proto_quit_handler()
740 nxt_proto_quit_children(task); in nxt_proto_sigterm_handler()
745 nxt_process_quit(task, 0); in nxt_proto_sigterm_handler()
813 nxt_process_quit(task, 0); in nxt_proto_sigchld_handler()
1021 rt = task->thread->runtime; in nxt_unit_default_init()
1108 rt = task->thread->runtime; in nxt_proto_process_add()
[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_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_http.h166 nxt_task_t task; member
254 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
295 nxt_int_t nxt_http_init(nxt_task_t *task);
296 nxt_int_t nxt_h1p_init(nxt_task_t *task);
297 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
300 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
326 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
328 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
330 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
337 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[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