Home
last modified time | relevance | path

Searched refs:read_timer (Results 1 – 8 of 8) sorted by last modified time

/unit/src/
H A Dnxt_conn.h128 nxt_timer_t read_timer; member
185 nxt_timer_data(ev, nxt_conn_t, read_timer)
H A Dnxt_conn_close.c113 timers_pending = nxt_timer_delete(engine, &c->read_timer); in nxt_conn_close_handler()
H A Dnxt_h1proto.c499 c->read_timer.task = task; in nxt_h1p_conn_request_init()
564 nxt_timer_disable(task->thread->engine, &c->read_timer); in nxt_h1p_conn_request_header_parse()
1701 c->read_timer.task = task; in nxt_h1p_request_close()
2185 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect()
2517 nxt_timer_disable(engine, &c->read_timer); in nxt_h1p_peer_header_read_done()
2827 c->read_timer.task = task; in nxt_h1p_peer_close()
H A Dnxt_gnutls.c614 nxt_event_timer_add(thr->engine, &c->read_timer, 5000); in nxt_gnutls_conn_io_shutdown()
H A Dnxt_conn_proxy.c89 peer->read_timer.work_queue = client->read_work_queue; in nxt_conn_proxy_create()
H A Dnxt_conn_read.c31 nxt_conn_timer(engine, c, state, &c->read_timer); in nxt_conn_wait()
85 nxt_timer_disable(engine, &c->read_timer); in nxt_conn_io_read()
98 nxt_timer_disable(engine, &c->read_timer); in nxt_conn_io_read()
113 if (!c->read_timer.enabled) { in nxt_conn_io_read()
114 nxt_conn_timer(engine, c, state, &c->read_timer); in nxt_conn_io_read()
125 if (state->timer_autoreset || !c->read_timer.enabled) { in nxt_conn_io_read()
126 nxt_conn_timer(engine, c, state, &c->read_timer); in nxt_conn_io_read()
H A Dnxt_conn.c73 c->read_timer.task = &c->task; in nxt_conn_create()
83 nxt_conn_timer_init(&c->read_timer, c, c->socket.read_work_queue); in nxt_conn_create()
126 c->read_timer.work_queue = wq; in nxt_conn_work_queue_set()
H A Dnxt_conn_connect.c107 c->read_timer.task = task; in nxt_conn_socket()