Searched refs:write_timer (Results 1 – 11 of 11) sorted by relevance
/unit/src/ |
H A D | nxt_conn_close.c | 114 timers_pending += nxt_timer_delete(engine, &c->write_timer); in nxt_conn_close_handler() 134 c->write_timer.handler = nxt_conn_close_timer_handler; in nxt_conn_close_handler() 135 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler() 137 nxt_timer_add(engine, &c->write_timer, 0); in nxt_conn_close_handler()
|
H A D | nxt_conn.c | 74 c->write_timer.task = &c->task; in nxt_conn_create() 84 nxt_conn_timer_init(&c->write_timer, c, c->socket.write_work_queue); in nxt_conn_create() 127 c->write_timer.work_queue = wq; in nxt_conn_work_queue_set()
|
H A D | nxt_conn_connect.c | 59 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_conn_io_connect() 108 c->write_timer.task = task; in nxt_conn_socket() 134 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_conn_connect_test()
|
H A D | nxt_conn_write.c | 91 nxt_timer_disable(engine, &c->write_timer); in nxt_conn_io_write() 102 c->write_timer.handler = nxt_conn_write_timer_handler; in nxt_conn_io_write() 103 nxt_timer_add(engine, &c->write_timer, 0); in nxt_conn_io_write() 113 nxt_conn_timer(engine, c, c->write_state, &c->write_timer); in nxt_conn_io_write()
|
H A D | nxt_event_conn_job_sendfile.c | 209 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_event_conn_job_sendfile_return() 216 &c->write_timer); in nxt_event_conn_job_sendfile_return()
|
H A D | nxt_conn.h | 134 nxt_timer_t write_timer; member 189 nxt_timer_data(ev, nxt_conn_t, write_timer)
|
H A D | nxt_conn_proxy.c | 90 peer->write_timer.work_queue = client->write_work_queue; in nxt_conn_proxy_create() 814 peer->write_timer.handler = nxt_conn_proxy_reconnect_handler; in nxt_conn_proxy_refused() 815 nxt_timer_add(task->thread->engine, &peer->write_timer, in nxt_conn_proxy_refused()
|
H A D | nxt_epoll_engine.c | 1081 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_epoll_edge_conn_io_connect() 1089 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_epoll_edge_conn_io_connect() 1142 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_epoll_edge_conn_connected()
|
H A D | nxt_h1proto.c | 500 c->write_timer.task = task; in nxt_h1p_conn_request_init() 1712 c->write_timer.task = task; in nxt_h1p_request_close() 2200 c->write_timer.work_queue = wq; in nxt_h1p_peer_connect() 2420 if (c->write_timer.enabled) { in nxt_h1p_peer_header_read() 2526 nxt_timer_disable(engine, &c->write_timer); in nxt_h1p_peer_header_read_done() 2838 c->write_timer.task = task; in nxt_h1p_peer_close()
|
H A D | nxt_kqueue_engine.c | 875 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_kqueue_conn_io_connect() 905 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_kqueue_conn_connected()
|
H A D | nxt_openssl.c | 1524 c->write_timer.handler = nxt_openssl_conn_io_shutdown_timeout; 1525 nxt_timer_add(task->thread->engine, &c->write_timer, 5000);
|