Lines Matching refs:c

11 typedef ssize_t (*nxt_conn_io_read_t)(nxt_task_t *task, nxt_conn_t *c);
12 typedef nxt_msec_t (*nxt_conn_timer_value_t)(nxt_conn_t *c, uintptr_t data);
54 ssize_t (*recvbuf)(nxt_conn_t *c, nxt_buf_t *b);
56 ssize_t (*recv)(nxt_conn_t *c, void *buf,
72 ssize_t (*old_sendbuf)(nxt_conn_t *c, nxt_buf_t *b,
77 ssize_t (*writev)(nxt_conn_t *c,
83 ssize_t (*send)(nxt_conn_t *c, void *buf,
176 #define nxt_conn_timer_init(ev, c, wq) \ argument
179 (ev)->log = &(c)->log; \
194 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
198 if ((c)->remote->u.sockaddr.sa_family != AF_UNIX) { \
199 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
202 (c)->tcp_nodelay = (ret == NXT_OK); \
209 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
213 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
216 (c)->tcp_nodelay = (ret == NXT_OK); \
223 NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
224 NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
226 NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
228 NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
230 nxt_conn_t *c);
234 nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
242 nxt_conn_t *c);
246 void nxt_conn_wait(nxt_conn_t *c);
249 ssize_t nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
250 ssize_t nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size,
260 size_t nxt_event_conn_write_limit(nxt_conn_t *c);
262 nxt_conn_t *c, size_t sent);
263 ssize_t nxt_event_conn_io_writev(nxt_conn_t *c, nxt_iobuf_t *iob,
265 ssize_t nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size);
268 nxt_conn_t *c);
271 #define nxt_conn_connect(engine, c) \ argument
273 c->socket.task, c, c->socket.data)
276 #define nxt_conn_read(engine, c) \ argument
280 c->socket.read_work_queue = &e->read_work_queue; \
282 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
283 c->socket.task, c, c->socket.data); \
287 #define nxt_conn_write(engine, c) \ argument
291 c->socket.write_work_queue = &e->write_work_queue; \
293 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
294 c->socket.task, c, c->socket.data); \
298 #define nxt_conn_idle(engine, c) \ argument
302 nxt_queue_insert_head(&e->idle_connections, &c->link); \
304 c->idle = 1; \
309 #define nxt_conn_active(engine, c) \ argument
313 nxt_queue_remove(&c->link); \
315 e->idle_conns_cnt -= c->idle; \
351 NXT_EXPORT nxt_conn_proxy_t *nxt_conn_proxy_create(nxt_conn_t *c);