nxt_conn.h (62:5e1efcc7b740) nxt_conn.h (65:10688b89aa16)
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_

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

150#endif
151#if (NXT_THREADS)
152 nxt_thread_pool_t *thread_pool;
153#endif
154 } u;
155
156#endif
157
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_

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

150#endif
151#if (NXT_THREADS)
152 nxt_thread_pool_t *thread_pool;
153#endif
154 } u;
155
156#endif
157
158 nxt_mem_pool_t *mem_pool;
158 nxt_mp_t *mem_pool;
159
160 nxt_task_t task;
161 nxt_log_t log;
162
163 nxt_listen_event_t *listen;
164 nxt_sockaddr_t *remote;
165 nxt_sockaddr_t *local;
166 const char *action;

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

221 TCP_NODELAY, 1); \
222 \
223 (c)->tcp_nodelay = (ret == NXT_OK); \
224 } while (0)
225
226#endif
227
228
159
160 nxt_task_t task;
161 nxt_log_t log;
162
163 nxt_listen_event_t *listen;
164 nxt_sockaddr_t *remote;
165 nxt_sockaddr_t *local;
166 const char *action;

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

221 TCP_NODELAY, 1); \
222 \
223 (c)->tcp_nodelay = (ret == NXT_OK); \
224 } while (0)
225
226#endif
227
228
229NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mem_pool_t *mp, nxt_task_t *task);
229NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
230void nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data);
231NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
232
233NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
234 const nxt_conn_state_t *state, nxt_timer_t *tev);
235NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
236
237void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data);

--- 113 unchanged lines hidden ---
230void nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data);
231NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
232
233NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
234 const nxt_conn_state_t *state, nxt_timer_t *tev);
235NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq);
236
237void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data);

--- 113 unchanged lines hidden ---