nxt_conn.c (318:c2442f5e054d) nxt_conn.c (386:d9e23ae1617d)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8
9
10nxt_conn_io_t nxt_unix_conn_io = {
11 nxt_conn_io_connect,
12 nxt_conn_io_accept,
13
14 nxt_conn_io_read,
15 nxt_conn_io_recvbuf,
16 nxt_conn_io_recv,
17
18 nxt_conn_io_write,
19 nxt_event_conn_io_write_chunk,
20
21#if (NXT_HAVE_LINUX_SENDFILE)
22 nxt_linux_event_conn_io_sendfile,
23#elif (NXT_HAVE_FREEBSD_SENDFILE)
24 nxt_freebsd_event_conn_io_sendfile,
25#elif (NXT_HAVE_MACOSX_SENDFILE)
26 nxt_macosx_event_conn_io_sendfile,
27#elif (NXT_HAVE_SOLARIS_SENDFILEV)
28 nxt_solaris_event_conn_io_sendfilev,
29#elif (NXT_HAVE_AIX_SEND_FILE)
30 nxt_aix_event_conn_io_send_file,
31#elif (NXT_HAVE_HPUX_SENDFILE)
32 nxt_hpux_event_conn_io_sendfile,
33#else
34 nxt_event_conn_io_sendbuf,
35#endif
36
37 nxt_event_conn_io_writev,
38 nxt_event_conn_io_send,
39
40 nxt_conn_io_shutdown,
41};
42
43
44nxt_conn_t *
45nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task)
46{
47 nxt_conn_t *c;
48 nxt_thread_t *thr;
49
50 c = nxt_mp_zget(mp, sizeof(nxt_conn_t));
51 if (nxt_slow_path(c == NULL)) {
52 return NULL;
53 }
54
55 c->mem_pool = mp;
56
57 c->socket.fd = -1;
58
59 c->socket.log = &c->log;
60 c->log = *task->log;
61
62 /* The while loop skips possible uint32_t overflow. */
63
64 while (c->log.ident == 0) {
65 c->log.ident = nxt_task_next_ident();
66 }
67
68 thr = nxt_thread();
69 thr->engine->connections++;
70
71 c->task.thread = thr;
72 c->task.log = &c->log;
73 c->task.ident = c->log.ident;
74 c->socket.task = &c->task;
75 c->read_timer.task = &c->task;
76 c->write_timer.task = &c->task;
77
78 c->io = thr->engine->event.io;
79 c->max_chunk = NXT_INT32_T_MAX;
80 c->sendfile = NXT_CONN_SENDFILE_UNSET;
81
82 c->socket.read_work_queue = &thr->engine->fast_work_queue;
83 c->socket.write_work_queue = &thr->engine->fast_work_queue;
84
85 nxt_conn_timer_init(&c->read_timer, c, c->socket.read_work_queue);
86 nxt_conn_timer_init(&c->write_timer, c, c->socket.write_work_queue);
87
88 nxt_queue_init(&c->requests);
89
90 nxt_log_debug(&c->log, "connections: %uD", thr->engine->connections);
91
92 return c;
93}
94
95
96void
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8
9
10nxt_conn_io_t nxt_unix_conn_io = {
11 nxt_conn_io_connect,
12 nxt_conn_io_accept,
13
14 nxt_conn_io_read,
15 nxt_conn_io_recvbuf,
16 nxt_conn_io_recv,
17
18 nxt_conn_io_write,
19 nxt_event_conn_io_write_chunk,
20
21#if (NXT_HAVE_LINUX_SENDFILE)
22 nxt_linux_event_conn_io_sendfile,
23#elif (NXT_HAVE_FREEBSD_SENDFILE)
24 nxt_freebsd_event_conn_io_sendfile,
25#elif (NXT_HAVE_MACOSX_SENDFILE)
26 nxt_macosx_event_conn_io_sendfile,
27#elif (NXT_HAVE_SOLARIS_SENDFILEV)
28 nxt_solaris_event_conn_io_sendfilev,
29#elif (NXT_HAVE_AIX_SEND_FILE)
30 nxt_aix_event_conn_io_send_file,
31#elif (NXT_HAVE_HPUX_SENDFILE)
32 nxt_hpux_event_conn_io_sendfile,
33#else
34 nxt_event_conn_io_sendbuf,
35#endif
36
37 nxt_event_conn_io_writev,
38 nxt_event_conn_io_send,
39
40 nxt_conn_io_shutdown,
41};
42
43
44nxt_conn_t *
45nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task)
46{
47 nxt_conn_t *c;
48 nxt_thread_t *thr;
49
50 c = nxt_mp_zget(mp, sizeof(nxt_conn_t));
51 if (nxt_slow_path(c == NULL)) {
52 return NULL;
53 }
54
55 c->mem_pool = mp;
56
57 c->socket.fd = -1;
58
59 c->socket.log = &c->log;
60 c->log = *task->log;
61
62 /* The while loop skips possible uint32_t overflow. */
63
64 while (c->log.ident == 0) {
65 c->log.ident = nxt_task_next_ident();
66 }
67
68 thr = nxt_thread();
69 thr->engine->connections++;
70
71 c->task.thread = thr;
72 c->task.log = &c->log;
73 c->task.ident = c->log.ident;
74 c->socket.task = &c->task;
75 c->read_timer.task = &c->task;
76 c->write_timer.task = &c->task;
77
78 c->io = thr->engine->event.io;
79 c->max_chunk = NXT_INT32_T_MAX;
80 c->sendfile = NXT_CONN_SENDFILE_UNSET;
81
82 c->socket.read_work_queue = &thr->engine->fast_work_queue;
83 c->socket.write_work_queue = &thr->engine->fast_work_queue;
84
85 nxt_conn_timer_init(&c->read_timer, c, c->socket.read_work_queue);
86 nxt_conn_timer_init(&c->write_timer, c, c->socket.write_work_queue);
87
88 nxt_queue_init(&c->requests);
89
90 nxt_log_debug(&c->log, "connections: %uD", thr->engine->connections);
91
92 return c;
93}
94
95
96void
97nxt_conn_free(nxt_task_t *task, nxt_conn_t *c)
98{
99 task->thread->engine->connections--;
100
101 nxt_mp_release(c->mem_pool, c);
102}
103
104
105void
97nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data)
98{
99 int ret;
100 nxt_conn_t *c;
101
102 static const struct linger linger_off = {
103 .l_onoff = 1,
104 .l_linger = 0,
105 };
106
107 c = obj;
108
109 nxt_debug(task, "event conn shutdown");
110
111 if (c->socket.timedout) {
112 /*
113 * Resetting of timed out connection on close
114 * releases kernel memory associated with socket.
115 * This also causes sending TCP/IP RST to a peer.
116 */
117 ret = setsockopt(c->socket.fd, SOL_SOCKET, SO_LINGER, &linger_off,
118 sizeof(struct linger));
119
120 if (nxt_slow_path(ret != 0)) {
121 nxt_log(task, NXT_LOG_CRIT, "setsockopt(%d, SO_LINGER) failed %E",
122 c->socket.fd, nxt_socket_errno);
123 }
124 }
125
126 c->write_state->close_handler(task, c, data);
127}
128
129
130void
131nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
132 const nxt_conn_state_t *state, nxt_timer_t *timer)
133{
134 nxt_msec_t value;
135
136 if (state->timer_value != NULL) {
137 value = state->timer_value(c, state->timer_data);
138
139 if (value != 0) {
140 timer->handler = state->timer_handler;
141 nxt_timer_add(engine, timer, value);
142 }
143 }
144}
145
146
147void
148nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq)
149{
150 c->read_work_queue = wq;
151 c->write_work_queue = wq;
152 c->read_timer.work_queue = wq;
153 c->write_timer.work_queue = wq;
154}
106nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data)
107{
108 int ret;
109 nxt_conn_t *c;
110
111 static const struct linger linger_off = {
112 .l_onoff = 1,
113 .l_linger = 0,
114 };
115
116 c = obj;
117
118 nxt_debug(task, "event conn shutdown");
119
120 if (c->socket.timedout) {
121 /*
122 * Resetting of timed out connection on close
123 * releases kernel memory associated with socket.
124 * This also causes sending TCP/IP RST to a peer.
125 */
126 ret = setsockopt(c->socket.fd, SOL_SOCKET, SO_LINGER, &linger_off,
127 sizeof(struct linger));
128
129 if (nxt_slow_path(ret != 0)) {
130 nxt_log(task, NXT_LOG_CRIT, "setsockopt(%d, SO_LINGER) failed %E",
131 c->socket.fd, nxt_socket_errno);
132 }
133 }
134
135 c->write_state->close_handler(task, c, data);
136}
137
138
139void
140nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
141 const nxt_conn_state_t *state, nxt_timer_t *timer)
142{
143 nxt_msec_t value;
144
145 if (state->timer_value != NULL) {
146 value = state->timer_value(c, state->timer_data);
147
148 if (value != 0) {
149 timer->handler = state->timer_handler;
150 nxt_timer_add(engine, timer, value);
151 }
152 }
153}
154
155
156void
157nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq)
158{
159 c->read_work_queue = wq;
160 c->write_work_queue = wq;
161 c->read_timer.work_queue = wq;
162 c->write_timer.work_queue = wq;
163}