diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-12-28 16:01:06 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-12-28 16:01:06 +0300 |
| commit | 9a6d3c5775d945509c7c2cbec48be59757da42c3 (patch) | |
| tree | 7129c13d6027a45e1a324deab373125bd7a14794 /src/nxt_conn.h | |
| parent | 497faf1b9abb188cab40c389a9e6221add5dd496 (diff) | |
| download | unit-9a6d3c5775d945509c7c2cbec48be59757da42c3.tar.gz unit-9a6d3c5775d945509c7c2cbec48be59757da42c3.tar.bz2 | |
HTTP keep-alive connections support.
Diffstat (limited to 'src/nxt_conn.h')
| -rw-r--r-- | src/nxt_conn.h | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/nxt_conn.h b/src/nxt_conn.h index d2f3db3b..110b1634 100644 --- a/src/nxt_conn.h +++ b/src/nxt_conn.h @@ -141,8 +141,6 @@ struct nxt_conn_s { nxt_conn_io_t *io; - nxt_queue_t requests; /* of nxt_req_conn_link_t */ - union { #if (NXT_SSLTLS) void *ssltls; @@ -231,6 +229,8 @@ NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c); NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, const nxt_conn_state_t *state, nxt_timer_t *tev); NXT_EXPORT void nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq); +NXT_EXPORT nxt_sockaddr_t *nxt_conn_local_addr(nxt_task_t *task, + nxt_conn_t *c); void nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data); void nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data); @@ -289,13 +289,13 @@ NXT_EXPORT void nxt_event_conn_job_sendfile(nxt_task_t *task, } while (0) -#define nxt_conn_write(e, c) \ +#define nxt_conn_write(engine, c) \ do { \ - nxt_event_engine_t *engine = e; \ + nxt_event_engine_t *e = engine; \ \ - c->socket.write_work_queue = &engine->write_work_queue; \ + c->socket.write_work_queue = &e->write_work_queue; \ \ - nxt_work_queue_add(&engine->write_work_queue, c->io->write, \ + nxt_work_queue_add(&e->write_work_queue, c->io->write, \ c->socket.task, c, c->socket.data); \ } while (0) |