Lines Matching refs:state
14 const nxt_conn_state_t *state; in nxt_conn_wait() local
20 state = c->read_state; in nxt_conn_wait()
23 nxt_work_queue_add(&engine->fast_work_queue, state->ready_handler, in nxt_conn_wait()
28 c->socket.read_handler = state->ready_handler; in nxt_conn_wait()
29 c->socket.error_handler = state->error_handler; in nxt_conn_wait()
31 nxt_conn_timer(engine, c, state, &c->read_timer); in nxt_conn_wait()
44 const nxt_conn_state_t *state; in nxt_conn_io_read() local
63 state = c->read_state; in nxt_conn_io_read()
64 c->socket.error_handler = state->error_handler; in nxt_conn_io_read()
68 if (state->io_read_handler == NULL) { in nxt_conn_io_read()
72 n = state->io_read_handler(task, c); in nxt_conn_io_read()
74 state = c->read_state; in nxt_conn_io_read()
84 if (state->timer_autoreset) { in nxt_conn_io_read()
89 state->ready_handler, task, c, data); in nxt_conn_io_read()
95 handler = (n == 0) ? state->close_handler : state->error_handler; 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()