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_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}
|