nxt_conn.h (386:d9e23ae1617d) nxt_conn.h (431:5817734dd9b9)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_CONN_H_INCLUDED_
8#define _NXT_CONN_H_INCLUDED_

--- 127 unchanged lines hidden (view full) ---

136 nxt_timer_t write_timer;
137
138 nxt_off_t sent;
139 uint32_t max_chunk;
140 uint32_t nbytes;
141
142 nxt_conn_io_t *io;
143
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_CONN_H_INCLUDED_
8#define _NXT_CONN_H_INCLUDED_

--- 127 unchanged lines hidden (view full) ---

136 nxt_timer_t write_timer;
137
138 nxt_off_t sent;
139 uint32_t max_chunk;
140 uint32_t nbytes;
141
142 nxt_conn_io_t *io;
143
144 nxt_queue_t requests; /* of nxt_req_conn_link_t */
145
146 union {
147#if (NXT_SSLTLS)
148 void *ssltls;
149#endif
150 nxt_thread_pool_t *thread_pool;
151 } u;
152
153 nxt_mp_t *mem_pool;

--- 72 unchanged lines hidden (view full) ---

226NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
227NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
228void nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data);
229NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
230
231NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
232 const nxt_conn_state_t *state, nxt_timer_t *tev);
233NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
144 union {
145#if (NXT_SSLTLS)
146 void *ssltls;
147#endif
148 nxt_thread_pool_t *thread_pool;
149 } u;
150
151 nxt_mp_t *mem_pool;

--- 72 unchanged lines hidden (view full) ---

224NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
225NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
226void nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data);
227NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
228
229NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
230 const nxt_conn_state_t *state, nxt_timer_t *tev);
231NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
232NXT_EXPORT nxt_sockaddr_t *nxt_conn_local_addr(nxt_task_t *task,
233 nxt_conn_t *c);
234
235void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data);
236void nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data);
237nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
238void nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data);
239void nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data);
240
241NXT_EXPORT nxt_listen_event_t *nxt_listen_event(nxt_task_t *task,

--- 42 unchanged lines hidden (view full) ---

284 \
285 c->socket.read_work_queue = &e->read_work_queue; \
286 \
287 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
288 c->socket.task, c, c->socket.data); \
289 } while (0)
290
291
234
235void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data);
236void nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data);
237nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
238void nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data);
239void nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data);
240
241NXT_EXPORT nxt_listen_event_t *nxt_listen_event(nxt_task_t *task,

--- 42 unchanged lines hidden (view full) ---

284 \
285 c->socket.read_work_queue = &e->read_work_queue; \
286 \
287 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
288 c->socket.task, c, c->socket.data); \
289 } while (0)
290
291
292#define nxt_conn_write(e, c) \
292#define nxt_conn_write(engine, c) \
293 do { \
293 do { \
294 nxt_event_engine_t *engine = e; \
294 nxt_event_engine_t *e = engine; \
295 \
295 \
296 c->socket.write_work_queue = &engine->write_work_queue; \
296 c->socket.write_work_queue = &e->write_work_queue; \
297 \
297 \
298 nxt_work_queue_add(&engine->write_work_queue, c->io->write, \
298 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
299 c->socket.task, c, c->socket.data); \
300 } while (0)
301
302
303extern nxt_conn_io_t nxt_unix_conn_io;
304
305
306typedef struct {

--- 42 unchanged lines hidden --- 		299 c->socket.task, c, c->socket.data); \
300 } while (0)
301
302
303extern nxt_conn_io_t nxt_unix_conn_io;
304
305
306typedef struct {

--- 42 unchanged lines hidden ---