Lines Matching refs:nxt_conn_t

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,
109 nxt_conn_t *next;
184 nxt_timer_data(ev, nxt_conn_t, read_timer)
188 nxt_timer_data(ev, nxt_conn_t, write_timer)
221 NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
222 NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
223 NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
225 NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
227 NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
229 nxt_conn_t *c);
233 nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
241 nxt_conn_t *c);
245 void nxt_conn_wait(nxt_conn_t *c);
248 ssize_t nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
249 ssize_t nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size,
259 size_t nxt_event_conn_write_limit(nxt_conn_t *c);
261 nxt_conn_t *c, size_t sent);
262 ssize_t nxt_event_conn_io_writev(nxt_conn_t *c, nxt_iobuf_t *iob,
264 ssize_t nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size);
267 nxt_conn_t *c);
305 nxt_conn_t *client;
306 nxt_conn_t *peer;
329 NXT_EXPORT nxt_conn_proxy_t *nxt_conn_proxy_create(nxt_conn_t *c);
334 #define nxt_event_conn_t nxt_conn_t