Lines Matching refs:c

89     nxt_conn_t          *c;  in nxt_conn_accept_alloc()  local
99 c = nxt_conn_create(mp, lev->socket.task); in nxt_conn_accept_alloc()
100 if (nxt_slow_path(c == NULL)) { in nxt_conn_accept_alloc()
106 c->socket.read_work_queue = lev->socket.read_work_queue; in nxt_conn_accept_alloc()
107 c->socket.write_ready = 1; in nxt_conn_accept_alloc()
109 c->remote = nxt_sockaddr_cache_alloc(engine, lev->listen); in nxt_conn_accept_alloc()
110 if (nxt_fast_path(c->remote != NULL)) { in nxt_conn_accept_alloc()
111 lev->next = c; in nxt_conn_accept_alloc()
112 return c; in nxt_conn_accept_alloc()
115 nxt_conn_free(task, c); in nxt_conn_accept_alloc()
139 nxt_conn_t *c; in nxt_conn_io_accept() local
145 c = lev->next; in nxt_conn_io_accept()
150 sa = &c->remote->u.sockaddr; in nxt_conn_io_accept()
151 socklen = c->remote->socklen; in nxt_conn_io_accept()
168 c->socket.fd = s; in nxt_conn_io_accept()
183 nxt_conn_accept(task, lev, c); in nxt_conn_io_accept()
188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept() argument
193 nxt_sockaddr_text(c->remote); in nxt_conn_accept()
196 (size_t) c->remote->address_length, in nxt_conn_accept()
197 nxt_sockaddr_address(c->remote)); in nxt_conn_accept()
203 nxt_conn_idle(engine, c); in nxt_conn_accept()
205 c->listen = lev; in nxt_conn_accept()
208 c->socket.data = NULL; in nxt_conn_accept()
210 c->read_work_queue = lev->work_queue; in nxt_conn_accept()
211 c->write_work_queue = lev->work_queue; in nxt_conn_accept()
217 nxt_work_queue_add(c->read_work_queue, lev->listen->handler, in nxt_conn_accept()
218 &c->task, c, lev); in nxt_conn_accept()
221 nxt_work_queue_add(c->write_work_queue, lev->listen->handler, in nxt_conn_accept()
222 &c->task, c, lev); in nxt_conn_accept()
237 nxt_conn_t *c; in nxt_conn_accept_next() local
239 c = lev->next; in nxt_conn_accept_next()
241 if (c == NULL) { in nxt_conn_accept_next()
242 c = nxt_conn_accept_alloc(task, lev); in nxt_conn_accept_next()
244 if (nxt_slow_path(c == NULL)) { in nxt_conn_accept_next()
249 return c; in nxt_conn_accept_next()
275 nxt_conn_t *c; in nxt_conn_accept_close_idle_handler() local
294 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
296 nxt_debug(c->socket.task, "idle connection: %d rdy:%d", in nxt_conn_accept_close_idle_handler()
297 c->socket.fd, c->socket.read_ready); in nxt_conn_accept_close_idle_handler()
299 if (!c->socket.read_ready) { in nxt_conn_accept_close_idle_handler()
304 c->read_state->close_handler(c->socket.task, c, c->socket.data); in nxt_conn_accept_close_idle_handler()
359 nxt_conn_t *c; in nxt_conn_listen_timer_handler() local
367 c = nxt_conn_accept_next(task, lev); in nxt_conn_listen_timer_handler()
368 if (c == NULL) { in nxt_conn_listen_timer_handler()
374 lev->accept(task, lev, c); in nxt_conn_listen_timer_handler()