Home
last modified time | relevance | path

Searched refs:write_timer (Results 1 – 11 of 11) sorted by relevance

/unit/src/
H A Dnxt_conn_close.c114 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 Dnxt_conn.c74 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 Dnxt_conn_connect.c59 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 Dnxt_conn_write.c91 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 Dnxt_event_conn_job_sendfile.c209 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 Dnxt_conn.h134 nxt_timer_t write_timer; member
189 nxt_timer_data(ev, nxt_conn_t, write_timer)
H A Dnxt_conn_proxy.c90 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 Dnxt_epoll_engine.c1081 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 Dnxt_h1proto.c500 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 Dnxt_kqueue_engine.c875 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 Dnxt_openssl.c1524 c->write_timer.handler = nxt_openssl_conn_io_shutdown_timeout;
1525 nxt_timer_add(task->thread->engine, &c->write_timer, 5000);