Home
last modified time | relevance | path

Searched refs:task (Results 126 – 137 of 137) sorted by last modified time

123456

/unit/src/
H A Dnxt_file_event.h14 nxt_task_t *task; member
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_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_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_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 …]
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_capability.h15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
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_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_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()

123456