nxt_conn.h (65:10688b89aa16) nxt_conn.h (88:c6879c7b5bdf)
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
144#if (NXT_SSLTLS || NXT_THREADS)
145 /* SunC does not support "zero-sized struct/union". */
146
147 union {
148#if (NXT_SSLTLS)
149 void *ssltls;
150#endif
151#if (NXT_THREADS)

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

175
176 uint8_t sendfile; /* 2 bits */
177 uint8_t tcp_nodelay; /* 1 bit */
178
179 nxt_queue_link_t link;
180};
181
182
146#if (NXT_SSLTLS || NXT_THREADS)
147 /* SunC does not support "zero-sized struct/union". */
148
149 union {
150#if (NXT_SSLTLS)
151 void *ssltls;
152#endif
153#if (NXT_THREADS)

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

177
178 uint8_t sendfile; /* 2 bits */
179 uint8_t tcp_nodelay; /* 1 bit */
180
181 nxt_queue_link_t link;
182};
183
184
185typedef uint32_t nxt_req_id_t;
186
187typedef struct {
188 nxt_req_id_t req_id;
189 nxt_conn_t *conn;
190
191 nxt_queue_link_t link;
192} nxt_req_conn_link_t;
193
194
183#define nxt_conn_timer_init(ev, c, wq) \
184 do { \
185 (ev)->work_queue = (wq); \
186 (ev)->log = &(c)->log; \
187 (ev)->precision = NXT_TIMER_DEFAULT_PRECISION; \
188 } while (0)
189
190

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

342#define nxt_event_conn_t nxt_conn_t
343#define nxt_event_conn_state_t nxt_conn_state_t
344#define nxt_event_conn_proxy_t nxt_conn_proxy_t
345#define nxt_event_conn_read nxt_conn_read
346#define nxt_event_conn_write nxt_conn_write
347#define nxt_event_conn_close nxt_conn_close
348
349
195#define nxt_conn_timer_init(ev, c, wq) \
196 do { \
197 (ev)->work_queue = (wq); \
198 (ev)->log = &(c)->log; \
199 (ev)->precision = NXT_TIMER_DEFAULT_PRECISION; \
200 } while (0)
201
202

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

354#define nxt_event_conn_t nxt_conn_t
355#define nxt_event_conn_state_t nxt_conn_state_t
356#define nxt_event_conn_proxy_t nxt_conn_proxy_t
357#define nxt_event_conn_read nxt_conn_read
358#define nxt_event_conn_write nxt_conn_write
359#define nxt_event_conn_close nxt_conn_close
360
361
362NXT_EXPORT nxt_req_conn_link_t *nxt_conn_request_add(nxt_conn_t *c,
363 nxt_req_id_t req_id);
364NXT_EXPORT void nxt_conn_request_remove(nxt_conn_t *c,
365 nxt_req_conn_link_t *rc);
366
367
350#endif /* _NXT_CONN_H_INCLUDED_ */
368#endif /* _NXT_CONN_H_INCLUDED_ */