Home
last modified time | relevance | path

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

123456

/unit/src/
H A Dnxt_aix_send_file.c35 nhd = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_aix_event_conn_io_send_file()
56 ntr = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_aix_event_conn_io_send_file()
74 nxt_debug(c->socket.task, "send_file(%d) fd:%FD @%O:%O hd:%ui tr:%ui", in nxt_aix_event_conn_io_send_file()
82 nxt_debug(c->socket.task, "send_file(%d): %d sent:%O", in nxt_aix_event_conn_io_send_file()
104 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_aix_event_conn_io_send_file()
112 nxt_debug(c->socket.task, "sendfile() %E", err); in nxt_aix_event_conn_io_send_file()
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_application.h30 typedef nxt_int_t (*nxt_application_setup_t)(nxt_task_t *task,
142 NXT_EXPORT nxt_int_t nxt_unit_default_init(nxt_task_t *task,
H A Dnxt_buf.c10 static void nxt_buf_completion(nxt_task_t *task, void *obj, void *data);
84 ts->engine = task->thread->engine; in nxt_buf_mem_ts_alloc()
87 ts->work.task = task; in nxt_buf_mem_ts_alloc()
198 nxt_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_completion() argument
216 nxt_buf_parent_completion(task, parent); in nxt_buf_completion()
227 nxt_debug(task, "parent retain:%uD", parent->retain); in nxt_buf_parent_completion()
241 nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_handle() argument
252 if (ts->engine != task->thread->engine) { in nxt_buf_ts_handle()
255 b, task->thread->engine, ts->engine); in nxt_buf_ts_handle()
278 if (nxt_buf_ts_handle(task, obj, data)) { in nxt_buf_ts_completion()
[all …]
H A Dnxt_buf.h217 NXT_EXPORT nxt_buf_t *nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp,
224 NXT_EXPORT nxt_int_t nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data);
226 NXT_EXPORT void nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent);
264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion() argument
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_buf_filter.h109 NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f,
111 NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data);
112 NXT_EXPORT void nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f);
H A Dnxt_capability.c31 static nxt_int_t nxt_capability_specific_set(nxt_task_t *task,
36 nxt_capability_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_set() argument
46 return nxt_capability_specific_set(task, cap); in nxt_capability_set()
66 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set() argument
91 nxt_alert(task, "failed to get process capabilities: %E", nxt_errno); in nxt_capability_specific_set()
114 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set() argument
H A Dnxt_capability.h15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
H A Dnxt_cert.c69 cert = nxt_cert_bio(task, bio); in nxt_cert_mem()
78 nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd) in nxt_cert_fd() argument
89 cert = nxt_cert_bio(task, bio); in nxt_cert_fd()
98 nxt_cert_bio(nxt_task_t *task, BIO *bio) in nxt_cert_bio() argument
827 rt = task->thread->runtime; in nxt_cert_store_load()
972 rt = task->thread->runtime;
1082 rt = task->thread->runtime; in nxt_cert_store_get()
1104 handler(task, NULL, ctx); in nxt_cert_store_get()
1156 rt = task->thread->runtime; in nxt_cert_store_get_handler()
1204 rt = task->thread->runtime; in nxt_cert_store_delete()
[all …]
H A Dnxt_cert.h13 nxt_cert_t *nxt_cert_mem(nxt_task_t *task, nxt_buf_mem_t *mbuf);
16 void nxt_cert_info_init(nxt_task_t *task, nxt_array_t *certs);
22 nxt_array_t *nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
25 void nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
27 void nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
29 void nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
30 void nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
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 …]
H A Dnxt_clone.h45 NXT_EXPORT nxt_int_t nxt_clone_credential_map(nxt_task_t *task, pid_t pid,
47 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_uidmap(nxt_task_t *task,
49 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_gidmap(nxt_task_t *task,
H A Dnxt_conn.c43 nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task) in nxt_conn_create() argument
58 c->log = *task->log; in nxt_conn_create()
69 c->task.thread = thr; in nxt_conn_create()
70 c->task.log = &c->log; in nxt_conn_create()
71 c->task.ident = c->log.ident; in nxt_conn_create()
72 c->socket.task = &c->task; in nxt_conn_create()
73 c->read_timer.task = &c->task; in nxt_conn_create()
74 c->write_timer.task = &c->task; in nxt_conn_create()
93 nxt_conn_free(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_free() argument
97 task->thread->engine->connections--; in nxt_conn_free()
[all …]
H A Dnxt_conn.h11 typedef ssize_t (*nxt_conn_io_read_t)(nxt_task_t *task, nxt_conn_t *c);
66 ssize_t (*sendbuf)(nxt_task_t *task,
99 nxt_task_t task; member
151 nxt_task_t task; member
223 NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
229 NXT_EXPORT nxt_sockaddr_t *nxt_conn_local_addr(nxt_task_t *task,
234 nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
248 void nxt_conn_io_read(nxt_task_t *task, void *obj, void *data);
255 ssize_t nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb,
267 NXT_EXPORT void nxt_event_conn_job_sendfile(nxt_task_t *task,
[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_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_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_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_conn_read.c16 nxt_debug(c->socket.task, "conn wait fd:%d rdy:%d", in nxt_conn_wait()
19 engine = c->socket.task->thread->engine; in nxt_conn_wait()
24 c->socket.task, c, c->socket.data); in nxt_conn_wait()
38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read() argument
56 engine = task->thread->engine; in nxt_conn_io_read()
72 n = state->io_read_handler(task, c); in nxt_conn_io_read()
101 handler, task, c, data); in nxt_conn_io_read()
178 nxt_debug(c->socket.task, "readv() %E", err); in nxt_conn_io_recvbuf()
183 nxt_debug(c->socket.task, "readv() %E", err); in nxt_conn_io_recvbuf()
234 nxt_debug(c->socket.task, "recv() %E", err); in nxt_conn_io_recv()
[all …]
H A Dnxt_conn_write.c27 nxt_debug(task, "conn write fd:%d er:%d bl:%d", in nxt_conn_io_write()
38 engine = task->thread->engine; in nxt_conn_io_write()
58 ret = c->io->sendbuf(task, &sb); in nxt_conn_io_write()
129 task, c, data); in nxt_conn_io_write()
142 task, c, data); in nxt_conn_io_write()
154 nxt_debug(task, "conn write timer"); in nxt_conn_write_timer_handler()
159 c->io->write(task, c, c->socket.data); in nxt_conn_write_timer_handler()
176 return nxt_conn_io_sendfile(task, sb); in nxt_conn_io_sendbuf()
325 nxt_debug(task, "writev() %E", err); in nxt_conn_io_writev()
367 nxt_debug(task, "send() %E", err); in nxt_conn_io_send()
[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_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_credential.h22 NXT_EXPORT nxt_int_t nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp,
24 NXT_EXPORT nxt_int_t nxt_credential_setuid(nxt_task_t *task,
26 NXT_EXPORT nxt_int_t nxt_credential_setgids(nxt_task_t *task,
H A Dnxt_devpoll_engine.c154 nxt_debug(&engine->task, "devpoll %d free", fd); in nxt_devpoll_free()
402 nxt_debug(&engine->task, "devpoll %d changes:%ui", in nxt_devpoll_commit_changes()
487 ev->task, ev, ev->data); in nxt_devpoll_change_error()
523 nxt_debug(&engine->task, "devpoll %d remove fd:%d", in nxt_devpoll_remove()
585 nxt_thread_time_update(engine->task.thread); in nxt_devpoll_poll()
587 nxt_debug(&engine->task, "ioctl(%d, DP_POLL): %d", in nxt_devpoll_poll()
609 nxt_alert(&engine->task, in nxt_devpoll_poll()
622 nxt_alert(ev->task, in nxt_devpoll_poll()
627 ev->task, ev, ev->data); in nxt_devpoll_poll()
636 ev->task, ev, ev->data); in nxt_devpoll_poll()
[all …]

123456