summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_select.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/nxt_select.c')
-rw-r--r--src/nxt_select.c390
1 files changed, 0 insertions, 390 deletions
diff --git a/src/nxt_select.c b/src/nxt_select.c
deleted file mode 100644
index 8ee5808e..00000000
--- a/src/nxt_select.c
+++ /dev/null
@@ -1,390 +0,0 @@
-
-/*
- * Copyright (C) Igor Sysoev
- * Copyright (C) NGINX, Inc.
- */
-
-#include <nxt_main.h>
-
-
-static nxt_event_set_t *nxt_select_create(nxt_event_signals_t *signals,
- nxt_uint_t mchanges, nxt_uint_t mevents);
-static void nxt_select_free(nxt_event_set_t *event_set);
-static void nxt_select_enable(nxt_event_set_t *event_set, nxt_event_fd_t *ev);
-static void nxt_select_disable(nxt_event_set_t *event_set, nxt_event_fd_t *ev);
-static void nxt_select_enable_read(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_enable_write(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_error_handler(nxt_task_t *task, void *obj, void *data);
-static void nxt_select_disable_read(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_disable_write(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_block_read(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_block_write(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_oneshot_read(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_oneshot_write(nxt_event_set_t *event_set,
- nxt_event_fd_t *ev);
-static void nxt_select_poll(nxt_task_t *task, nxt_event_set_t *event_set,
- nxt_msec_t timeout);
-
-
-const nxt_event_set_ops_t nxt_select_event_set = {
- "select",
- nxt_select_create,
- nxt_select_free,
- nxt_select_enable,
- nxt_select_disable,
- nxt_select_disable,
- nxt_select_disable,
- nxt_select_enable_read,
- nxt_select_enable_write,
- nxt_select_disable_read,
- nxt_select_disable_write,
- nxt_select_block_read,
- nxt_select_block_write,
- nxt_select_oneshot_read,
- nxt_select_oneshot_write,
- nxt_select_enable_read,
- NULL,
- NULL,
- NULL,
- NULL,
- nxt_select_poll,
-
- &nxt_unix_event_conn_io,
-
- NXT_NO_FILE_EVENTS,
- NXT_NO_SIGNAL_EVENTS,
-};
-
-
-static nxt_event_set_t *
-nxt_select_create(nxt_event_signals_t *signals, nxt_uint_t mchanges,
- nxt_uint_t mevents)
-{
- nxt_event_set_t *event_set;
- nxt_select_event_set_t *ss;
-
- event_set = nxt_zalloc(sizeof(nxt_select_event_set_t));
- if (event_set == NULL) {
- return NULL;
- }
-
- ss = &event_set->select;
-
- ss->nfds = -1;
- ss->update_nfds = 0;
-
- ss->events = nxt_zalloc(FD_SETSIZE * sizeof(nxt_event_fd_t *));
- if (ss->events != NULL) {
- return event_set;
- }
-
- nxt_select_free(event_set);
-
- return NULL;
-}
-
-
-static void
-nxt_select_free(nxt_event_set_t *event_set)
-{
- nxt_select_event_set_t *ss;
-
- nxt_main_log_debug("select free");
-
- ss = &event_set->select;
-
- nxt_free(ss->events);
- nxt_free(ss);
-}
-
-
-static void
-nxt_select_enable(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_select_enable_read(event_set, ev);
- nxt_select_enable_write(event_set, ev);
-}
-
-
-static void
-nxt_select_disable(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- if (ev->read != NXT_EVENT_INACTIVE) {
- nxt_select_disable_read(event_set, ev);
- }
-
- if (ev->write != NXT_EVENT_INACTIVE) {
- nxt_select_disable_write(event_set, ev);
- }
-}
-
-
-static void
-nxt_select_enable_read(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_fd_t fd;
- nxt_thread_t *thr;
- nxt_select_event_set_t *ss;
-
- fd = ev->fd;
-
- nxt_log_debug(ev->log, "select enable read: fd:%d", fd);
-
- ss = &event_set->select;
-
- if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) {
- thr = nxt_thread();
- nxt_work_queue_add(&thr->engine->fast_work_queue,
- nxt_select_error_handler, ev->task, ev, ev->data);
- return;
- }
-
- ev->read = NXT_EVENT_DEFAULT;
-
- FD_SET(fd, &ss->main_read_fd_set);
- ss->events[fd] = ev;
-
- if (ss->nfds < fd) {
- ss->nfds = fd;
- ss->update_nfds = 0;
- }
-}
-
-
-static void
-nxt_select_enable_write(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_fd_t fd;
- nxt_thread_t *thr;
- nxt_select_event_set_t *ss;
-
- fd = ev->fd;
-
- nxt_log_debug(ev->log, "select enable write: fd:%d", fd);
-
- ss = &event_set->select;
-
- if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) {
- thr = nxt_thread();
- nxt_work_queue_add(&thr->engine->fast_work_queue,
- nxt_select_error_handler, ev->task, ev, ev->data);
- return;
- }
-
- ev->write = NXT_EVENT_DEFAULT;
-
- FD_SET(fd, &ss->main_write_fd_set);
- ss->events[fd] = ev;
-
- if (ss->nfds < fd) {
- ss->nfds = fd;
- ss->update_nfds = 0;
- }
-}
-
-
-static void
-nxt_select_error_handler(nxt_task_t *task, void *obj, void *data)
-{
- nxt_event_fd_t *ev;
-
- ev = obj;
-
- ev->read = NXT_EVENT_INACTIVE;
- ev->write = NXT_EVENT_INACTIVE;
-
- ev->error_handler(task, ev, data);
-}
-
-
-static void
-nxt_select_disable_read(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_fd_t fd;
- nxt_select_event_set_t *ss;
-
- fd = ev->fd;
-
- nxt_log_debug(ev->log, "select disable read: fd:%d", fd);
-
- if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) {
- return;
- }
-
- ss = &event_set->select;
- FD_CLR(fd, &ss->main_read_fd_set);
-
- ev->read = NXT_EVENT_INACTIVE;
-
- if (ev->write == NXT_EVENT_INACTIVE) {
- ss->events[fd] = NULL;
- ss->update_nfds = 1;
- }
-}
-
-
-static void
-nxt_select_disable_write(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_fd_t fd;
- nxt_select_event_set_t *ss;
-
- fd = ev->fd;
-
- nxt_log_debug(ev->log, "select disable write: fd:%d", fd);
-
- if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) {
- return;
- }
-
- ss = &event_set->select;
- FD_CLR(fd, &ss->main_write_fd_set);
-
- ev->write = NXT_EVENT_INACTIVE;
-
- if (ev->read == NXT_EVENT_INACTIVE) {
- ss->events[fd] = NULL;
- ss->update_nfds = 1;
- }
-}
-
-
-static void
-nxt_select_block_read(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- if (ev->read != NXT_EVENT_INACTIVE) {
- nxt_select_disable_read(event_set, ev);
- }
-}
-
-
-static void
-nxt_select_block_write(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- if (ev->write != NXT_EVENT_INACTIVE) {
- nxt_select_disable_write(event_set, ev);
- }
-}
-
-
-static void
-nxt_select_oneshot_read(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_select_enable_read(event_set, ev);
-
- ev->read = NXT_EVENT_ONESHOT;
-}
-
-
-static void
-nxt_select_oneshot_write(nxt_event_set_t *event_set, nxt_event_fd_t *ev)
-{
- nxt_select_enable_write(event_set, ev);
-
- ev->write = NXT_EVENT_ONESHOT;
-}
-
-
-static void
-nxt_select_poll(nxt_task_t *task, nxt_event_set_t *event_set,
- nxt_msec_t timeout)
-{
- int nevents, nfds, found;
- nxt_err_t err;
- nxt_int_t i;
- nxt_uint_t fd, level;
- nxt_event_fd_t *ev;
- struct timeval tv, *tp;
- nxt_select_event_set_t *ss;
-
- if (timeout == NXT_INFINITE_MSEC) {
- tp = NULL;
-
- } else {
- tv.tv_sec = (long) (timeout / 1000);
- tv.tv_usec = (long) ((timeout % 1000) * 1000);
- tp = &tv;
- }
-
- ss = &event_set->select;
-
- if (ss->update_nfds) {
- for (i = ss->nfds; i >= 0; i--) {
- if (ss->events[i] != NULL) {
- ss->nfds = i;
- ss->update_nfds = 0;
- break;
- }
- }
- }
-
- ss->work_read_fd_set = ss->main_read_fd_set;
- ss->work_write_fd_set = ss->main_write_fd_set;
-
- nfds = ss->nfds + 1;
-
- nxt_debug(task, "select() nfds:%d timeout:%M", nfds, timeout);
-
- nevents = select(nfds, &ss->work_read_fd_set, &ss->work_write_fd_set,
- NULL, tp);
-
- err = (nevents == -1) ? nxt_errno : 0;
-
- nxt_thread_time_update(task->thread);
-
- nxt_debug(task, "select(): %d", nevents);
-
- if (nevents == -1) {
- level = (err == NXT_EINTR) ? NXT_LOG_INFO : NXT_LOG_ALERT;
- nxt_log(task, level, "select() failed %E", err);
- return;
- }
-
- for (fd = 0; fd < (nxt_uint_t) nfds && nevents != 0; fd++) {
-
- found = 0;
-
- if (FD_ISSET(fd, &ss->work_read_fd_set)) {
- ev = ss->events[fd];
-
- nxt_debug(ev->task, "select() fd:%ui read rd:%d wr:%d",
- fd, ev->read, ev->write);
-
- ev->read_ready = 1;
-
- if (ev->read == NXT_EVENT_ONESHOT) {
- nxt_select_disable_read(event_set, ev);
- }
-
- nxt_work_queue_add(ev->read_work_queue, ev->read_handler,
- ev->task, ev, ev->data);
- found = 1;
- }
-
- if (FD_ISSET(fd, &ss->work_write_fd_set)) {
- ev = ss->events[fd];
-
- nxt_log_debug(ev->log, "select() fd:%ui write rd:%d wr:%d",
- fd, ev->read, ev->write);
-
- ev->write_ready = 1;
-
- if (ev->write == NXT_EVENT_ONESHOT) {
- nxt_select_disable_write(event_set, ev);
- }
-
- nxt_work_queue_add(ev->write_work_queue, ev->write_handler,
- ev->task, ev, ev->data);
- found = 1;
- }
-
- nevents -= found;
- }
-}
generated by cgit (git 2.34.1) at 2024-11-17 19:38:54 +0000