/unit/src/ |
H A D | nxt_http.h | 168 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 D | nxt_http_websocket.c | 16 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 D | nxt_conn_write.c | 27 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 D | nxt_port_memory.c | 128 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 D | nxt_openssl.c | 57 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 D | nxt_port_socket.c | 47 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 D | nxt_conn.h | 11 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 D | nxt_port_rpc.h | 11 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 D | nxt_event_engine.c | 42 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 D | nxt_cgroup.c | 11 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 D | nxt_port_memory.h | 24 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 D | nxt_runtime.c | 47 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 D | nxt_port_rpc.c | 107 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 D | nxt_http_error.c | 11 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 D | nxt_external.c | 31 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 D | nxt_cert.h | 13 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 D | nxt_conn.c | 43 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 D | nxt_kqueue_engine.c | 544 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 D | nxt_script.h | 13 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 D | nxt_thread_pool.c | 32 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 D | nxt_http_variables.c | 11 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 D | nxt_epoll_engine.c | 659 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 D | nxt_file.c | 26 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 D | nxt_http_return.c | 23 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 D | nxt_conn_read.c | 16 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 …]
|