Searched refs:read_timer (Results 1 – 8 of 8) sorted by relevance
/unit/src/ |
H A D | nxt_conn_read.c | 31 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 D | nxt_conn.c | 73 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 D | nxt_conn.h | 128 nxt_timer_t read_timer; member 185 nxt_timer_data(ev, nxt_conn_t, read_timer)
|
H A D | nxt_conn_close.c | 113 timers_pending = nxt_timer_delete(engine, &c->read_timer); in nxt_conn_close_handler()
|
H A D | nxt_conn_connect.c | 107 c->read_timer.task = task; in nxt_conn_socket()
|
H A D | nxt_h1proto.c | 499 c->read_timer.task = task; in nxt_h1p_conn_request_init() 565 nxt_timer_disable(task->thread->engine, &c->read_timer); in nxt_h1p_conn_request_header_parse() 1711 c->read_timer.task = task; in nxt_h1p_request_close() 2195 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect() 2527 nxt_timer_disable(engine, &c->read_timer); in nxt_h1p_peer_header_read_done() 2837 c->read_timer.task = task; in nxt_h1p_peer_close()
|
H A D | nxt_gnutls.c | 614 nxt_event_timer_add(thr->engine, &c->read_timer, 5000); in nxt_gnutls_conn_io_shutdown()
|
H A D | nxt_conn_proxy.c | 89 peer->read_timer.work_queue = client->read_work_queue; in nxt_conn_proxy_create()
|