Home
last modified time | relevance | path

Searched refs:task (Results 26 – 50 of 137) sorted by relevance

123456

/unit/src/
H A Dnxt_http.h168 nxt_task_t task; member
273 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
320 nxt_int_t nxt_http_init(nxt_task_t *task);
321 nxt_int_t nxt_h1p_init(nxt_task_t *task);
322 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
325 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
357 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
359 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
361 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
368 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[all …]
H A Dnxt_http_websocket.c16 static void nxt_http_websocket_error_handler(nxt_task_t *task, void *obj,
29 nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data) in nxt_http_websocket_client() argument
48 nxt_debug(task, "http websocket client frame"); in nxt_http_websocket_client()
101 res = nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_client()
104 task->thread->engine->port->id, out); in nxt_http_websocket_client()
122 nxt_http_request_ws_frame_start(task, r, r->ws_frame); in nxt_http_websocket_client()
132 nxt_debug(task, "http websocket error handler"); in nxt_http_websocket_error_handler()
138 nxt_debug(task, " req_rpc_data is NULL"); in nxt_http_websocket_error_handler()
143 nxt_debug(task, " app_port is NULL"); in nxt_http_websocket_error_handler()
147 (void) nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_error_handler()
[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()
183 return nxt_conn_io_sendfile(task, sb); in nxt_conn_io_sendbuf()
332 nxt_debug(task, "writev() %E", err); in nxt_conn_io_writev()
374 nxt_debug(task, "send() %E", err); in nxt_conn_io_send()
[all …]
H A Dnxt_port_memory.c128 if (nxt_buf_ts_handle(task, obj, data)) { in nxt_port_mmap_buf_completion()
181 nxt_process_broadcast_shm_ack(task, process); in nxt_port_mmap_buf_completion()
313 fd = nxt_shm_open(task, PORT_MMAP_SIZE); in nxt_port_new_port_mmap()
368 nxt_shm_open(nxt_task_t *task, size_t size) in nxt_shm_open() argument
404 nxt_debug(task, "shm_open(SHM_ANON): %FD", fd); in nxt_shm_open()
419 nxt_debug(task, "shm_open(%s): %FD", name, fd); in nxt_shm_open()
562 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, 0); in nxt_port_mmap_get_buf()
572 mp = task->thread->engine->mem_pool; in nxt_port_mmap_get_buf()
609 nxt_log(task, NXT_LOG_WARN, in nxt_port_mmap_increase_buf()
737 nxt_log_error(NXT_LOG_ERR, task->log, in nxt_port_mmap_write()
[all …]
H A Dnxt_openssl.c57 static void nxt_openssl_library_free(nxt_task_t *task);
133 nxt_openssl_library_init(nxt_task_t *task) in nxt_openssl_library_init() argument
171 nxt_log(task, NXT_LOG_INFO, "%s, %xl", in nxt_openssl_library_init()
194 nxt_openssl_log_error(task, NXT_LOG_ALERT, in nxt_openssl_library_init()
208 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() argument
268 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() argument
795 nxt_debug(c->socket.task,
1225 nxt_debug(task, "openssl conn free");
1271 nxt_thread_time_debug_update(task->thread);
1537 nxt_openssl_conn_free(task, c);
[all …]
H A Dnxt_port_socket.c47 port->socket.task = task; in nxt_port_socket_init()
110 nxt_socket_close(task, port->pair[0]); in nxt_port_socket_init()
111 nxt_socket_close(task, port->pair[1]); in nxt_port_socket_init()
134 port->engine = task->thread->engine; in nxt_port_write_enable()
320 nxt_port_use(task, port, 1); in nxt_port_msg_chk_insert()
428 nxt_sendbuf_mem_coalesce(task, &sb); in nxt_port_write_handler()
563 nxt_port_use(task, port, use_delta); in nxt_port_write_handler()
708 port->engine = task->thread->engine; in nxt_port_read_enable()
1218 port->handler(task, fmsg); in nxt_port_read_msg_process()
1271 port->handler(task, msg); in nxt_port_read_msg_process()
[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_port_rpc.h11 typedef void (*nxt_port_rpc_handler_t)(nxt_task_t *task,
16 uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port,
19 void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port,
24 void nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port,
27 void nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
28 void nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port,
30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream);
31 void nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port);
H A Dnxt_event_engine.c42 nxt_event_engine_create(nxt_task_t *task, in nxt_event_engine_create() argument
57 thread = task->thread; in nxt_event_engine_create()
59 engine->task.thread = thread; in nxt_event_engine_create()
60 engine->task.log = thread->log; in nxt_event_engine_create()
132 thread = task->thread; in nxt_event_engine_create()
205 pipe->event.task = &engine->task; in nxt_event_engine_signal_pipe_create()
335 thread = task->thread; in nxt_event_engine_post_handler()
349 engine = task->thread->engine; in nxt_event_engine_signal_pipe_error()
512 nxt_task_t *task; in nxt_event_engine_start() local
529 thr->log = engine->task.log; in nxt_event_engine_start()
[all …]
H A Dnxt_cgroup.c11 static int nxt_mk_cgpath_relative(nxt_task_t *task, const char *dir,
13 static nxt_int_t nxt_mk_cgpath(nxt_task_t *task, const char *dir,
18 nxt_cgroup_proc_add(nxt_task_t *task, nxt_process_t *process) in nxt_cgroup_proc_add() argument
25 if (task->thread->runtime->type != NXT_PROCESS_MAIN in nxt_cgroup_proc_add()
50 fp = nxt_file_fopen(task, cgprocs, "we"); in nxt_cgroup_proc_add()
57 nxt_file_fclose(task, fp); in nxt_cgroup_proc_add()
74 ret = nxt_mk_cgpath(task, "", cgroot); in nxt_cgroup_cleanup()
102 fp = nxt_file_fopen(task, "/proc/self/cgroup", "re"); in nxt_mk_cgpath_relative()
117 nxt_file_fclose(task, fp); in nxt_mk_cgpath_relative()
148 nxt_mk_cgpath(nxt_task_t *task, const char *dir, char *cgpath) in nxt_mk_cgpath() argument
[all …]
H A Dnxt_port_memory.h24 nxt_port_mmap_get_buf(nxt_task_t *task, nxt_port_mmaps_t *mmaps, size_t size);
26 nxt_int_t nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b,
30 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process,
34 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port,
38 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg);
49 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
51 nxt_int_t nxt_shm_open(nxt_task_t *task, size_t size);
53 void nxt_process_broadcast_shm_ack(nxt_task_t *task, nxt_process_t *process);
H A Dnxt_runtime.c47 nxt_runtime_create(nxt_task_t *task) in nxt_runtime_create() argument
65 task->thread->runtime = rt; in nxt_runtime_create()
299 thread = task->thread; in nxt_runtime_event_engines()
370 nxt_runtime_quit(task, 1); in nxt_runtime_start()
382 thr = task->thread; in nxt_runtime_initial_start()
426 nxt_runtime_quit(task, 1); in nxt_runtime_initial_start()
437 rt = task->thread->runtime; in nxt_runtime_quit()
441 nxt_debug(task, "exiting"); in nxt_runtime_quit()
708 cont(task, 0); in nxt_runtime_thread_pool_destroy()
744 rt = task->thread->runtime; in nxt_runtime_thread_pool_exit()
[all …]
H A Dnxt_port_rpc.c107 nxt_port_rpc_ex_set_peer(task, port, ex, peer); in nxt_port_rpc_register_handler()
205 nxt_port_rpc_remove_from_peers(task, port, reg); in nxt_port_rpc_ex_set_peer()
344 reg->error_handler(task, msg, reg->data); in nxt_port_rpc_handler()
347 reg->ready_handler(task, msg, reg->data); in nxt_port_rpc_handler()
362 nxt_port_use(task, port, -1); in nxt_port_rpc_handler()
433 reg->error_handler(task, &msg, reg->data); in nxt_port_rpc_remove_peer()
446 nxt_log_error(NXT_LOG_ERR, task->log, in nxt_port_rpc_remove_peer()
454 nxt_port_use(task, port, -1); in nxt_port_rpc_remove_peer()
487 nxt_port_use(task, port, -1); in nxt_port_rpc_cancel()
493 nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_rpc_close() argument
[all …]
H A Dnxt_http_error.c11 static void nxt_http_request_send_error_body(nxt_task_t *task, void *r,
28 nxt_http_request_error(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_error() argument
33 nxt_debug(task, "http request error: %d", status); in nxt_http_request_error()
60 nxt_http_request_header_send(task, r, in nxt_http_request_error()
66 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_request_error()
78 nxt_http_request_send_error_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_error_body() argument
85 nxt_debug(task, "http request send error body"); in nxt_http_request_send_error_body()
87 out = nxt_http_buf_mem(task, r, NXT_HTTP_ERROR_LEN); in nxt_http_request_send_error_body()
97 nxt_http_request_send(task, r, out); in nxt_http_request_send_error_body()
103 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_request_send_error_body()
H A Dnxt_external.c31 nxt_external_fd_no_cloexec(nxt_task_t *task, nxt_socket_t fd) in nxt_external_fd_no_cloexec() argument
60 nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_external_start() argument
76 rt = task->thread->runtime; in nxt_external_start()
89 rc = nxt_external_fd_no_cloexec(task, proto_port->pair[1]); in nxt_external_start()
94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start()
99 rc = nxt_external_fd_no_cloexec(task, my_port->pair[0]); in nxt_external_start()
104 rc = nxt_external_fd_no_cloexec(task, my_port->pair[1]); in nxt_external_start()
109 rc = nxt_external_fd_no_cloexec(task, conf->shared_port_fd); in nxt_external_start()
114 rc = nxt_external_fd_no_cloexec(task, conf->shared_queue_fd); in nxt_external_start()
142 nxt_debug(task, "update "NXT_UNIT_INIT_ENV"=%s", buf); in nxt_external_start()
[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_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_kqueue_engine.c544 ev->error_handler(task, ev, data); in nxt_kqueue_fd_error_handler()
557 ev->handler(task, ev, data); in nxt_kqueue_file_error_handler()
671 nxt_task_t *task; in nxt_kqueue_poll() local
723 nxt_debug(&engine->task, in nxt_kqueue_poll()
731 nxt_alert(&engine->task, in nxt_kqueue_poll()
737 task = &engine->task; in nxt_kqueue_poll()
771 task = ev->task; in nxt_kqueue_poll()
802 task = ev->task; in nxt_kqueue_poll()
810 task = fev->task; in nxt_kqueue_poll()
833 nxt_alert(&engine->task, in nxt_kqueue_poll()
[all …]
H A Dnxt_script.h13 nxt_script_t *nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data,
17 void nxt_script_info_init(nxt_task_t *task, nxt_array_t *scripts);
23 nxt_array_t *nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
26 void nxt_script_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
28 void nxt_script_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
30 void nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
31 void nxt_script_store_delete_handler(nxt_task_t *task,
H A Dnxt_thread_pool.c32 tp->task.thread = engine->task.thread; in nxt_thread_pool_create()
33 tp->task.log = engine->task.log; in nxt_thread_pool_create()
124 tp->task.thread = thr; in nxt_thread_pool_start()
134 nxt_task_t *task; in nxt_thread_pool_loop() local
153 task->thread = thr; in nxt_thread_pool_loop()
157 handler(task, obj, data); in nxt_thread_pool_loop()
240 &tp->engine->task, tp, NULL); in nxt_thread_pool_destroy()
275 thread = task->thread; in nxt_thread_pool_exit()
277 nxt_debug(task, "thread pool exit"); in nxt_thread_pool_exit()
286 nxt_debug(task, "thread pool threads: %A", threads); in nxt_thread_pool_exit()
[all …]
H A Dnxt_http_variables.c11 static nxt_int_t nxt_http_var_dollar(nxt_task_t *task, nxt_str_t *str,
13 static nxt_int_t nxt_http_var_request_time(nxt_task_t *task, nxt_str_t *str,
15 static nxt_int_t nxt_http_var_method(nxt_task_t *task, nxt_str_t *str,
17 static nxt_int_t nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str,
33 static nxt_int_t nxt_http_var_status(nxt_task_t *task, nxt_str_t *str,
37 static nxt_int_t nxt_http_var_referer(nxt_task_t *task, nxt_str_t *str,
41 static nxt_int_t nxt_http_var_response_connection(nxt_task_t *task,
49 static nxt_int_t nxt_http_var_header(nxt_task_t *task, nxt_str_t *str,
51 static nxt_int_t nxt_http_var_cookie(nxt_task_t *task, nxt_str_t *str,
247 now = nxt_thread_monotonic_time(task->thread); in nxt_http_var_request_time()
[all …]
H A Dnxt_epoll_engine.c659 ev->error_handler(ev->task, ev, data); in nxt_epoll_error_handler()
699 nxt_debug(&engine->task, "signalfd(): %d", fd); in nxt_epoll_add_signal()
705 engine->u.epoll.signalfd.task = &engine->task; in nxt_epoll_add_signal()
732 nxt_debug(task, "signalfd handler"); in nxt_epoll_signalfd_handler()
788 engine->u.epoll.eventfd.task = &engine->task; in nxt_epoll_enable_post()
833 nxt_debug(task, "read(%d): %d events:%uL", in nxt_epoll_eventfd_handler()
900 nxt_thread_time_update(engine->task.thread); in nxt_epoll_poll()
1035 nxt_conn_accept(task, lev, c); in nxt_epoll_conn_io_accept4()
1080 engine = task->thread->engine; in nxt_epoll_edge_conn_io_connect()
1146 task, c, data); in nxt_epoll_edge_conn_connected()
[all …]
H A Dnxt_file.c26 nxt_thread_time_update(task->thread); in nxt_file_open()
68 nxt_thread_time_update(task->thread); in nxt_file_openat2()
90 nxt_file_close(nxt_task_t *task, nxt_file_t *file) in nxt_file_close() argument
92 nxt_debug(task, "close(%FD)", file->fd); in nxt_file_close()
444 nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_nonblocking() argument
462 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking() argument
504 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking() argument
592 nxt_thread_time_update(task->thread); in nxt_file_fopen()
612 nxt_file_fclose(nxt_task_t *task, FILE *fp) in nxt_file_fclose() argument
614 nxt_debug(task, "fclose(%p)", fp); in nxt_file_fclose()
[all …]
H A Dnxt_http_return.c23 static nxt_http_action_t *nxt_http_return(nxt_task_t *task,
75 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return() argument
101 nxt_http_request_error(task, r, conf->status); in nxt_http_return()
123 nxt_http_return_send_ready(task, r, ctx); in nxt_http_return()
136 nxt_tstr_query_resolve(task, r->tstr_query, ctx, in nxt_http_return()
145 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_http_return()
177 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready() argument
209 nxt_http_request_header_send(task, r, NULL, NULL); in nxt_http_return_send_ready()
215 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_http_return_send_ready()
220 nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_error() argument
[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 …]

123456