summaryrefslogtreecommitdiffhomepage
path: root/src/event
diff options
context:
space:
mode:
Diffstat (limited to 'src/event')
-rw-r--r--src/event/modules/ngx_devpoll_module.c318
-rw-r--r--src/event/modules/ngx_devpoll_module.h21
-rw-r--r--src/event/modules/ngx_kqueue_module.c44
-rw-r--r--src/event/modules/ngx_poll_module.c258
-rw-r--r--src/event/modules/ngx_poll_module.h16
-rw-r--r--src/event/modules/ngx_select_module.c3
-rw-r--r--src/event/modules/ngx_select_module.h1
-rw-r--r--src/event/ngx_event.c18
-rw-r--r--src/event/ngx_event.h10
9 files changed, 670 insertions, 19 deletions
diff --git a/src/event/modules/ngx_devpoll_module.c b/src/event/modules/ngx_devpoll_module.c
new file mode 100644
index 000000000..0bc9ef71a
--- /dev/null
+++ b/src/event/modules/ngx_devpoll_module.c
@@ -0,0 +1,318 @@
+/*
+ * Copyright (C) 2002 Igor Sysoev, http://sysoev.ru
+ */
+
+
+#include <ngx_config.h>
+#include <ngx_core.h>
+#include <ngx_types.h>
+#include <ngx_log.h>
+#include <ngx_connection.h>
+#include <ngx_event.h>
+#include <ngx_devpoll_module.h>
+
+#if (USE_DEVPOLL) && !(HAVE_DEVPOLL)
+#error "/dev/poll is not supported on this platform"
+#endif
+
+
+/* should be per-thread */
+static int dp;
+static struct pollfd *change_list, *event_list;
+static int nchanges, nevents;
+
+static ngx_event_t timer_queue;
+/* */
+
+
+int ngx_devpoll_init(int max_connections, ngx_log_t *log)
+{
+ int size;
+
+ size = sizeof(struct pollfd) * 512;
+ nchanges = 0;
+ nevents = 512;
+
+ dp = open("/dev/poll", O_RDWR);
+
+ if (dp == -1) {
+ ngx_log_error(NGX_LOG_EMERG, log, ngx_errno, "open(/dev/poll) failed");
+ return NGX_ERROR;
+ }
+
+ ngx_test_null(change_list, ngx_alloc(size, log), NGX_ERROR);
+ ngx_test_null(event_list, ngx_alloc(size, log), NGX_ERROR);
+ ngx_test_null(event_index, ngx_alloc(sizeof(ngx_event_t *) * nevents, log),
+ NGX_ERROR);
+
+ timer_queue.timer_prev = &timer_queue;
+ timer_queue.timer_next = &timer_queue;
+
+#if !(USE_DEVPOLL)
+ ngx_event_actions.add = ngx_devpoll_add_event;
+ ngx_event_actions.del = ngx_devpoll_del_event;
+ ngx_event_actions.timer = ngx_devpoll_add_timer;
+ ngx_event_actions.process = ngx_devpoll_process_events;
+#endif
+
+ return NGX_OK;
+}
+
+
+/* NOT READY */
+
+int ngx_devpoll_add_event(ngx_event_t *ev, int event, u_int flags)
+{
+ ngx_event_t *e;
+ ngx_connection_t *c;
+
+ c = (ngx_connection_t *) ev->data;
+
+ ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0;
+
+ if (event == NGX_READ_EVENT) {
+ e = c->write;
+#if (NGX_READ_EVENT != POLLIN)
+ event = POLLIN;
+#endif
+
+ } else {
+ e = c->read;
+#if (NGX_WRITE_EVENT != POLLOUT)
+ event = POLLOUT;
+#endif
+ }
+
+ ngx_log_debug(ev->log, "poll fd:%d event:%d" _ c->fd _ event);
+
+ if (e == NULL || e->index == NGX_INVALID_INDEX) {
+ event_list[nevents].fd = c->fd;
+ event_list[nevents].events = event;
+ event_list[nevents].revents = 0;
+
+ event_index[nevents] = ev;
+ ev->index = nevents;
+ nevents++;
+
+ } else {
+ event_list[e->index].events |= event;
+ ev->index = e->index;
+ }
+
+ return ngx_devpoll_set_event(ev, event, EV_ADD | flags);
+}
+
+/* NOT READY */
+
+int ngx_devpoll_del_event(ngx_event_t *ev, int event, u_int flags)
+{
+ ngx_event_t *e;
+
+ if (nchanges > 0 && ev->index < nchanges
+ && change_list[ev->index].udata == ev)
+ {
+ ngx_connection_t *cn = (ngx_connection_t *) ev->data;
+ ngx_log_debug(ev->log, "kqueue del event: %d: ft:%d" _
+ cn->fd _ event);
+
+ if (ev->index < --nchanges) {
+ e = (ngx_event_t *) change_list[nchanges].udata;
+ change_list[ev->index] = change_list[nchanges];
+ e->index = ev->index;
+ }
+
+ return NGX_OK;
+ }
+
+ if (flags & NGX_CLOSE_EVENT)
+ return NGX_OK;
+
+ return ngx_devpoll_set_event(ev, POLLREMOVE);
+}
+
+/* NOT READY */
+
+int ngx_devpoll_set_event(ngx_event_t *ev, int event)
+{
+ int n;
+ ngx_connection_t *c;
+
+ c = (ngx_connection_t *) ev->data;
+
+ ngx_log_debug(ev->log, "devpoll fd:%d event:%d" _ c->fd _ event);
+
+ if (nchanges >= nevents) {
+ ngx_log_error(NGX_LOG_WARN, ev->log, 0,
+ "/dev/pool change list is filled up");
+
+ n = nchanges * sizeof(struct pollfd);
+ if (write(dp, change_list, n) != n) {
+ ngx_log_error(NGX_LOG_ALERT, log, ngx_errno,
+ "write(/dev/poll) failed");
+ return NGX_ERROR;
+ }
+
+ nchanges = 0;
+ }
+
+ event_list[nchanges].fd = c->fd;
+ event_list[nchanges].events = event;
+ event_list[nchanges].revents = 0;
+
+ event_index[nchanges] = ev;
+ ev->index = nchanges;
+
+/*
+ if (flags == EV_ADD)
+ ev->index = nchanges;
+*/
+
+ nchanges++;
+
+ return NGX_OK;
+}
+
+
+int ngx_devpoll_process_events(ngx_log_t *log)
+{
+ int events, i;
+ u_int timer, delta;
+ ngx_event_t *ev;
+ struct dvpoll dvpoll;
+ struct timeval tv;
+
+ if (timer_queue.timer_next != &timer_queue) {
+ timer = timer_queue.timer_next->timer_delta;
+#if 1
+ gettimeofday(&tv, NULL);
+ delta = tv.tv_sec * 1000 + tv.tv_usec / 1000;
+#else
+ delta = ngx_msec();
+#endif
+
+ } else {
+ timer = INFTIM;
+ delta = 0;
+ }
+
+ ngx_log_debug(log, "devpoll timer: %d" _ timer);
+
+ n = nchanges * sizeof(struct pollfd);
+ if (write(dp, change_list, n) != n) {
+ ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, "write(/dev/poll) failed");
+ return NGX_ERROR;
+ }
+
+ dvpoll.dp_fds = event_list;
+ dvpoll.dp_nfds = nevents;
+ dvpoll.dp_timeout = timer;
+ events = ioctl(dp, DP_POLL, &dvpoll);
+
+ if (events == -1) {
+ ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, "ioctl(DP_POLL) failed");
+ return NGX_ERROR;
+ }
+
+ nchanges = 0;
+
+ if (timer != INFTIM) {
+#if 1
+ gettimeofday(&tv, NULL);
+ delta = tv.tv_sec * 1000 + tv.tv_usec / 1000 - delta;
+#else
+ delta = ngx_msec() - delta;
+#endif
+
+ } else {
+ ngx_assert((events != 0), return NGX_ERROR, log,
+ "ioctl(DP_POLL) returns no events without timeout");
+ }
+
+ ngx_log_debug(log, "devpoll timer: %d, delta: %d" _ timer _ delta);
+
+ if (timer != INFTIM) {
+ if (delta >= timer) {
+ for ( ;; ) {
+ ev = timer_queue.timer_next;
+
+ if (ev == &timer_queue || delta < ev->timer_delta)
+ break;
+
+ delta -= ev->timer_delta;
+ ngx_del_timer(ev);
+ ev->timedout = 1;
+ if (ev->event_handler(ev) == NGX_ERROR)
+ ev->close_handler(ev);
+ }
+
+ } else {
+ timer_queue.timer_next->timer_delta -= delta;
+ }
+ }
+
+ for (i = 0; i < events; i++) {
+
+ ngx_log_debug(log, "devpoll: %d: ev:%d rev:%d" _
+ event_list[i].fd _
+ event_list[i].events _ event_list[i].revents);
+
+
+ if (event_list[i].revents & POLLIN) {
+ c->read->ready = 1;
+
+ if (c->read->oneshot) {
+ ngx_del_timer(c->read);
+ ngx_select_del_event(c->read, NGX_READ_EVENT, 0);
+ }
+
+ if (c->read->event_handler(c->read) == NGX_ERROR) {
+ c->read->close_handler(c->read);
+ }
+ }
+
+ if (event_list[i].revents & POLLOUT) {
+ c->write->ready = 1;
+
+ if (c->write->oneshot) {
+ ngx_del_timer(c->write);
+ ngx_select_del_event(c->write, NGX_WRITE_EVENT, 0);
+ }
+
+ if (c->write->event_handler(c->write) == NGX_ERROR) {
+ c->write->close_handler(c->write);
+ }
+ }
+
+ if (event_list[i].revents & (POLLERR|POLLHUP|POLLNVAL)) {
+ ngx_log_error(NGX_LOG_ERR, log, ngx_errno,
+ "ioctl(DP_POLL) error on %d:%d",
+ event_list[i].fd, event_list[i].revents);
+ }
+ }
+
+ return NGX_OK;
+}
+
+
+void ngx_devpoll_add_timer(ngx_event_t *ev, ngx_msec_t timer)
+{
+ ngx_event_t *e;
+
+ ngx_log_debug(ev->log, "set timer: %d" _ timer);
+
+ ngx_assert((!ev->timer_next && !ev->timer_prev), return, ev->log,
+ "timer already set");
+
+ for (e = timer_queue.timer_next;
+ e != &timer_queue && timer > e->timer_delta;
+ e = e->timer_next)
+ timer -= e->timer_delta;
+
+ ev->timer_delta = timer;
+
+ ev->timer_next = e;
+ ev->timer_prev = e->timer_prev;
+
+ e->timer_prev->timer_next = ev;
+ e->timer_prev = ev;
+}
diff --git a/src/event/modules/ngx_devpoll_module.h b/src/event/modules/ngx_devpoll_module.h
new file mode 100644
index 000000000..f6818f5b8
--- /dev/null
+++ b/src/event/modules/ngx_devpoll_module.h
@@ -0,0 +1,21 @@
+#ifndef _NGX_DEVPOLL_MODULE_H_INCLUDED_
+#define _NGX_DEVPOLL_MODULE_H_INCLUDED_
+
+
+#include <ngx_types.h>
+#include <ngx_log.h>
+#include <ngx_event.h>
+
+int ngx_devpoll_init(int max_connections, ngx_log_t *log);
+int ngx_devpoll_add_event(ngx_event_t *ev, int event, u_int flags);
+int ngx_devpoll_del_event(ngx_event_t *ev, int event, u_int flags);
+void ngx_devpoll_add_timer(ngx_event_t *ev, ngx_msec_t timer);
+int ngx_devpoll_process_events(ngx_log_t *log);
+
+
+/* DEBUG */
+#define POLLREMOVE 0x0800
+#define DP_POLL 1
+
+
+#endif /* _NGX_DEVPOLL_MODULE_H_INCLUDED_ */
diff --git a/src/event/modules/ngx_kqueue_module.c b/src/event/modules/ngx_kqueue_module.c
index e3c9e3a4f..028dfe767 100644
--- a/src/event/modules/ngx_kqueue_module.c
+++ b/src/event/modules/ngx_kqueue_module.c
@@ -61,6 +61,22 @@ int ngx_kqueue_add_event(ngx_event_t *ev, int event, u_int flags)
{
ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0;
+#if 1
+ if (nchanges > 0
+ && ev->index < nchanges
+ && change_list[ev->index].udata == ev)
+ {
+ /* DEBUG */
+ ngx_connection_t *c = (ngx_connection_t *) ev->data;
+ ngx_log_debug(ev->log, "kqueue add event: %d: ft:%d" _ c->fd _ event);
+
+ change_list[ev->index].filter = event;
+ change_list[ev->index].flags = flags;
+
+ return NGX_OK;
+ }
+#endif
+
return ngx_kqueue_set_event(ev, event, EV_ADD | flags);
}
@@ -69,12 +85,13 @@ int ngx_kqueue_del_event(ngx_event_t *ev, int event, u_int flags)
{
ngx_event_t *e;
- if (nchanges > 0 && ev->index < nchanges
+ if (nchanges > 0
+ && ev->index < nchanges
&& change_list[ev->index].udata == ev)
{
- ngx_connection_t *cn = (ngx_connection_t *) ev->data;
- ngx_log_debug(ev->log, "kqueue del event: %d: ft:%d" _
- cn->fd _ event);
+ /* DEBUG */
+ ngx_connection_t *c = (ngx_connection_t *) ev->data;
+ ngx_log_debug(ev->log, "kqueue del event: %d: ft:%d" _ c->fd _ event);
if (ev->index < --nchanges) {
e = (ngx_event_t *) change_list[nchanges].udata;
@@ -95,12 +112,12 @@ int ngx_kqueue_del_event(ngx_event_t *ev, int event, u_int flags)
int ngx_kqueue_set_event(ngx_event_t *ev, int filter, u_int flags)
{
struct timespec ts;
- ngx_connection_t *cn;
+ ngx_connection_t *c;
- cn = (ngx_connection_t *) ev->data;
+ c = (ngx_connection_t *) ev->data;
ngx_log_debug(ev->log, "kqueue set event: %d: ft:%d f:%08x" _
- cn->fd _ filter _ flags);
+ c->fd _ filter _ flags);
if (nchanges >= nevents) {
ngx_log_error(NGX_LOG_WARN, ev->log, 0,
@@ -116,14 +133,16 @@ int ngx_kqueue_set_event(ngx_event_t *ev, int filter, u_int flags)
nchanges = 0;
}
- change_list[nchanges].ident = cn->fd;
+ change_list[nchanges].ident = c->fd;
change_list[nchanges].filter = filter;
change_list[nchanges].flags = flags;
change_list[nchanges].fflags = 0;
change_list[nchanges].data = 0;
change_list[nchanges].udata = ev;
+#if 0
if (flags == EV_ADD)
+#endif
ev->index = nchanges;
nchanges++;
@@ -140,10 +159,6 @@ int ngx_kqueue_process_events(ngx_log_t *log)
struct timeval tv;
struct timespec ts, *tp;
- timer = 0;
- delta = 0;
- tp = NULL;
-
if (timer_queue.timer_next != &timer_queue) {
timer = timer_queue.timer_next->timer_delta;
ts.tv_sec = timer / 1000;
@@ -151,6 +166,11 @@ int ngx_kqueue_process_events(ngx_log_t *log)
tp = &ts;
gettimeofday(&tv, NULL);
delta = tv.tv_sec * 1000 + tv.tv_usec / 1000;
+
+ } else {
+ timer = 0;
+ delta = 0;
+ tp = NULL;
}
ngx_log_debug(log, "kevent timer: %d" _ timer);
diff --git a/src/event/modules/ngx_poll_module.c b/src/event/modules/ngx_poll_module.c
new file mode 100644
index 000000000..e10e61538
--- /dev/null
+++ b/src/event/modules/ngx_poll_module.c
@@ -0,0 +1,258 @@
+
+#include <ngx_config.h>
+#include <ngx_core.h>
+#include <ngx_types.h>
+#include <ngx_log.h>
+#include <ngx_time.h>
+#include <ngx_connection.h>
+#include <ngx_event.h>
+#include <ngx_poll_module.h>
+
+
+/* should be per-thread */
+static struct pollfd *event_list;
+static int nevents;
+
+static ngx_event_t **event_index;
+static ngx_event_t timer_queue;
+/* */
+
+int ngx_poll_init(int max_connections, ngx_log_t *log)
+{
+ ngx_test_null(event_list,
+ ngx_alloc(sizeof(struct pollfd) * max_connections, log),
+ NGX_ERROR);
+
+ ngx_test_null(event_index,
+ ngx_alloc(sizeof(ngx_event_t *) * max_connections, log),
+ NGX_ERROR);
+
+ nevents = 0;
+
+ timer_queue.timer_prev = &timer_queue;
+ timer_queue.timer_next = &timer_queue;
+
+ ngx_event_actions.add = ngx_poll_add_event;
+ ngx_event_actions.del = ngx_poll_del_event;
+ ngx_event_actions.timer = ngx_poll_add_timer;
+ ngx_event_actions.process = ngx_poll_process_events;
+
+ return NGX_OK;
+}
+
+int ngx_poll_add_event(ngx_event_t *ev, int event, u_int flags)
+{
+ ngx_event_t *e;
+ ngx_connection_t *c;
+
+ c = (ngx_connection_t *) ev->data;
+
+ ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1: 0;
+
+ if (event == NGX_READ_EVENT) {
+ e = c->write;
+#if (NGX_READ_EVENT != POLLIN)
+ event = POLLIN;
+#endif
+
+ } else {
+ e = c->read;
+#if (NGX_WRITE_EVENT != POLLOUT)
+ event = POLLOUT;
+#endif
+ }
+
+ ngx_log_debug(ev->log, "poll fd:%d event:%d" _ c->fd _ event);
+
+ if (e == NULL || e->index == NGX_INVALID_INDEX) {
+ event_list[nevents].fd = c->fd;
+ event_list[nevents].events = event;
+ event_list[nevents].revents = 0;
+
+ event_index[nevents] = ev;
+ ev->index = nevents;
+ nevents++;
+
+ } else {
+ event_list[e->index].events |= event;
+ ev->index = e->index;
+ }
+
+ return NGX_OK;
+}
+
+int ngx_poll_del_event(ngx_event_t *ev, int event, u_int flags)
+{
+ ngx_event_t *e;
+ ngx_connection_t *c;
+
+ c = (ngx_connection_t *) ev->data;
+
+ if (ev->index == NGX_INVALID_INDEX)
+ return NGX_OK;
+
+ if (event == NGX_READ_EVENT) {
+ e = c->write;
+#if (NGX_READ_EVENT != POLLIN)
+ event = POLLIN;
+#endif
+
+ } else {
+ e = c->read;
+#if (NGX_WRITE_EVENT != POLLOUT)
+ event = POLLOUT;
+#endif
+ }
+
+ ngx_log_debug(c->log, "del event: %d, %d" _ c->fd _ event);
+
+ if (e == NULL || e->index == NGX_INVALID_INDEX) {
+ if (ev->index < --nevents) {
+ event_index[ev->index] = event_index[nevents];
+ event_index[ev->index]->index = ev->index;
+ }
+
+ } else {
+ event_list[e->index].events &= ~event;
+ }
+
+ ev->index = NGX_INVALID_INDEX;
+
+ return NGX_OK;
+}
+
+int ngx_poll_process_events(ngx_log_t *log)
+{
+ int i, ready, found;
+ u_int timer, delta;
+ ngx_event_t *ev;
+ ngx_connection_t *c;
+
+ if (timer_queue.timer_next != &timer_queue) {
+ timer = timer_queue.timer_next->timer_delta;
+ delta = ngx_msec();
+
+ } else {
+ timer = INFTIM;
+ delta = 0;
+ }
+
+#if 1
+ /* DEBUG */
+ for (i = 0; i < nevents; i++) {
+ ngx_log_debug(log, "poll: %d, %d" _
+ event_list[i].fd _ event_list[i].events);
+ }
+#endif
+
+ ngx_log_debug(log, "poll timer: %d" _ timer);
+
+ if ((ready = poll(event_list, nevents, timer)) == -1) {
+ ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, "poll() failed");
+ return NGX_ERROR;
+ }
+
+ ngx_log_debug(log, "poll ready %d" _ ready);
+
+ if (timer != INFTIM) {
+ delta = ngx_msec() - delta;
+
+ } else {
+ ngx_assert((ready != 0), return NGX_ERROR, log,
+ "poll() returns no events without timeout");
+ }
+
+ ngx_log_debug(log, "poll timer: %d, delta: %d" _ timer _ delta);
+
+ if (timer != INFTIM) {
+ if (delta >= timer) {
+ for ( ;; ) {
+ ev = timer_queue.timer_next;
+
+ if (ev == &timer_queue || delta < ev->timer_delta) {
+ break;
+ }
+
+ delta -= ev->timer_delta;
+ ngx_del_timer(ev);
+ ev->timedout = 1;
+
+ if (ev->event_handler(ev) == NGX_ERROR) {
+ ev->close_handler(ev);
+ }
+ }
+
+ } else {
+ timer_queue.timer_next->timer_delta -= delta;
+ }
+ }
+
+ for (i = 0; ready; i++) {
+ c = &ngx_connections[event_list[i].fd];
+
+ ngx_log_debug(log, "poll: fd:%d, ev:%d, rev:%d" _
+ event_list[i].fd _
+ event_list[i].events _ event_list[i].revents);
+
+ found = 0;
+
+ if (event_list[i].revents & POLLIN) {
+ found = 1;
+ c->read->ready = 1;
+
+ if (c->read->oneshot) {
+ ngx_del_timer(c->read);
+ ngx_select_del_event(c->read, NGX_READ_EVENT, 0);
+ }
+
+ if (c->read->event_handler(c->read) == NGX_ERROR) {
+ c->read->close_handler(c->read);
+ }
+ }
+
+ if (event_list[i].revents & POLLOUT) {
+ found = 1;
+ c->write->ready = 1;
+
+ if (c->write->oneshot) {
+ ngx_del_timer(c->write);
+ ngx_select_del_event(c->write, NGX_WRITE_EVENT, 0);
+ }
+
+ if (c->write->event_handler(c->write) == NGX_ERROR) {
+ c->write->close_handler(c->write);
+ }
+ }
+
+ if (event_list[i].revents & (POLLERR|POLLHUP|POLLNVAL)) {
+ found = 1;
+ ngx_log_error(NGX_LOG_ERR, log, ngx_errno,
+ "poll() error on %d:%d",
+ event_list[i].fd, event_list[i].revents);
+ }
+
+ if (found) {
+ ready--;
+ }
+ }
+
+ return NGX_OK;
+}
+
+void ngx_poll_add_timer(ngx_event_t *ev, ngx_msec_t timer)
+{
+ ngx_event_t *e;
+
+ for (e = timer_queue.timer_next;
+ e != &timer_queue && timer > e->timer_delta;
+ e = e->timer_next)
+ timer -= e->timer_delta;
+
+ ev->timer_delta = timer;
+
+ ev->timer_next = e;
+ ev->timer_prev = e->timer_prev;
+
+ e->timer_prev->timer_next = ev;
+ e->timer_prev = ev;
+}
diff --git a/src/event/modules/ngx_poll_module.h b/src/event/modules/ngx_poll_module.h
new file mode 100644
index 000000000..b9fcec281
--- /dev/null
+++ b/src/event/modules/ngx_poll_module.h
@@ -0,0 +1,16 @@
+#ifndef _NGX_POLL_MODULE_H_INCLUDED_
+#define _NGX_POLL_MODULE_H_INCLUDED_
+
+
+#include <ngx_types.h>
+#include <ngx_log.h>
+#include <ngx_event.h>
+
+int ngx_poll_init(int max_connections, ngx_log_t *log);
+int ngx_poll_add_event(ngx_event_t *ev, int event, u_int flags);
+int ngx_poll_del_event(ngx_event_t *ev, int event, u_int flags);
+void ngx_poll_add_timer(ngx_event_t *ev, ngx_msec_t timer);
+int ngx_poll_process_events(ngx_log_t *log);
+
+
+#endif /* _NGX_POLL_MODULE_H_INCLUDED_ */
diff --git a/src/event/modules/ngx_select_module.c b/src/event/modules/ngx_select_module.c
index c87c59238..c75c71934 100644
--- a/src/event/modules/ngx_select_module.c
+++ b/src/event/modules/ngx_select_module.c
@@ -29,9 +29,6 @@ static ngx_event_t **ready_index;
static ngx_event_t timer_queue;
/* */
-static fd_set *ngx_select_get_fd_set(ngx_socket_t fd, int event,
- ngx_log_t *log);
-
int ngx_select_init(int max_connections, ngx_log_t *log)
{
if (max_connections > FD_SETSIZE) {
diff --git a/src/event/modules/ngx_select_module.h b/src/event/modules/ngx_select_module.h
index 7460790fb..143a2cb3c 100644
--- a/src/event/modules/ngx_select_module.h
+++ b/src/event/modules/ngx_select_module.h
@@ -9,7 +9,6 @@
int ngx_select_init(int max_connections, ngx_log_t *log);
int ngx_select_add_event(ngx_event_t *ev, int event, u_int flags);
int ngx_select_del_event(ngx_event_t *ev, int event, u_int flags);
-int ngx_select_set_event(ngx_event_t *ev, int filter, u_int flags);
void ngx_select_add_timer(ngx_event_t *ev, ngx_msec_t timer);
int ngx_select_process_events(ngx_log_t *log);
diff --git a/src/event/ngx_event.c b/src/event/ngx_event.c
index c2e10aef3..3cb070c28 100644
--- a/src/event/ngx_event.c
+++ b/src/event/ngx_event.c
@@ -12,6 +12,9 @@
#include <ngx_event_accept.h>
#include <ngx_select_module.h>
+#if (HAVE_POLL)
+#include <ngx_poll_module.h>
+#endif
#if (HAVE_KQUEUE)
#include <ngx_kqueue_module.h>
#endif
@@ -23,11 +26,15 @@ ngx_event_t *ngx_read_events, *ngx_write_events;
#if !(USE_KQUEUE)
#if (HAVE_KQUEUE)
-#if 1
+
+#if 0
ngx_event_type_e ngx_event_type = NGX_SELECT_EVENT;
+#elif 1
+ngx_event_type_e ngx_event_type = NGX_POLL_EVENT;
#else
ngx_event_type_e ngx_event_type = NGX_KQUEUE_EVENT;
#endif
+
#else
ngx_event_type_e ngx_event_type = NGX_SELECT_EVENT;
#endif
@@ -51,7 +58,10 @@ static int (*ngx_event_init[]) (int max_connections, ngx_log_t *log) = {
void ngx_pre_thread(ngx_array_t *ls, ngx_pool_t *pool, ngx_log_t *log)
{
int i, fd;
- ngx_listen_t *s;
+
+ ngx_listen_t *s;
+ ngx_event_t *ev;
+ ngx_connection_t *c;
/* STUB */
int max_connections = 512;
@@ -70,6 +80,9 @@ void ngx_pre_thread(ngx_array_t *ls, ngx_pool_t *pool, ngx_log_t *log)
fd = s[i].fd;
+ c = &ngx_connections[fd];
+ ev = &ngx_read_events[fd];
+
ngx_memzero(&ngx_connections[fd], sizeof(ngx_connection_t));
ngx_memzero(&ngx_read_events[fd], sizeof(ngx_event_t));
@@ -89,6 +102,7 @@ void ngx_pre_thread(ngx_array_t *ls, ngx_pool_t *pool, ngx_log_t *log)
ngx_palloc(pool, sizeof(ngx_log_t)), /* void */ ; );
ngx_memcpy(ngx_read_events[fd].log, ngx_connections[fd].log,
sizeof(ngx_log_t));
+ c->read = ev;
ngx_read_events[fd].data = &ngx_connections[fd];
ngx_read_events[fd].event_handler = &ngx_event_accept;
ngx_read_events[fd].listening = 1;
diff --git a/src/event/ngx_event.h b/src/event/ngx_event.h
index 6aa01660b..4575b0350 100644
--- a/src/event/ngx_event.h
+++ b/src/event/ngx_event.h
@@ -22,7 +22,7 @@ struct ngx_event_s {
void *context;
char *action;
- int index;
+ unsigned int index;
ngx_event_t *prev; /* queue in mutex(), aio_read(), aio_write() */
ngx_event_t *next; /* */
@@ -120,6 +120,14 @@ NGX_CLOSE_EVENT kqueue: kqueue deletes events for file that closed
#define NGX_CLEAR_EVENT EV_CLEAR
#endif
+#elif (HAVE_POLL)
+
+#define NGX_READ_EVENT POLLIN
+#define NGX_WRITE_EVENT POLLOUT
+
+#define NGX_LEVEL_EVENT 0
+#define NGX_ONESHOT_EVENT 1
+
#else
#define NGX_READ_EVENT 0
generated by cgit (git 2.34.1) at 2026-01-01 17:28:50 +0000