/unit/src/ |
H A D | nxt_file_event.h | 14 nxt_task_t *task; member
|
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_credential.h | 22 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 D | nxt_conn_proxy.c | 158 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 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 …]
|
H A D | nxt_devpoll_engine.c | 154 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 …]
|
H A D | nxt_event_conn_job_sendfile.c | 30 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 D | nxt_capability.h | 15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
|
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_conn_connect.c | 21 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 D | nxt_aix_send_file.c | 35 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()
|