if [ $ngx_found = yes ]; then
have=HAVE_EPOLL . auto/have
+ have=HAVE_CLEAR_EVENT . auto/have
CORE_SRCS="$CORE_SRCS $EPOLL_SRCS"
EVENT_MODULES="$EVENT_MODULES $EPOLL_MODULE"
EVENT_FOUND=YES
ngx_epoll_del_event, /* delete an event */
ngx_epoll_add_event, /* enable an event */
ngx_epoll_del_event, /* disable an event */
- ngx_epoll_add_connection, /* add an connection */
- ngx_epoll_del_connection, /* delete an connection */
+ NULL, /* add an connection */
+ NULL, /* delete an connection */
ngx_epoll_process_events, /* process the events */
ngx_epoll_init, /* init the events */
ngx_epoll_done, /* done the events */
ngx_event_actions = ngx_epoll_module_ctx.actions;
- ngx_event_flags = NGX_USE_EDGE_EVENT;
+#if (HAVE_CLEAR_EVENT)
+ ngx_event_flags = NGX_USE_CLEAR_EVENT;
+#else
+ ngx_event_flags = NGX_USE_LEVEL_EVENT;
+#endif
return NGX_OK;
}
static int ngx_epoll_add_event(ngx_event_t *ev, int event, u_int flags)
{
- struct epoll_event ee;
+ int op, prev;
+ ngx_event_t *e;
ngx_connection_t *c;
+ struct epoll_event ee;
c = ev->data;
-#if (NGX_READ_EVENT != EPOLLIN) || (NGX_WRITE_EVENT != EPOLLOUT)
if (event == NGX_READ_EVENT) {
+ e = c->write;
+ prev = EPOLLOUT;
+#if (NGX_READ_EVENT != EPOLLIN)
event = EPOLLIN;
+#endif
} else {
+ e = c->read;
+ prev = EPOLLIN;
+#if (NGX_WRITE_EVENT != EPOLLOUT)
event = EPOLLOUT;
- }
#endif
+ }
- ee.events = event|EPOLLET;
- ee.data.ptr = (void *) ((uintptr_t) c | c->read->instance);
+ if (e->active) {
+ op = EPOLL_CTL_MOD;
+ event |= prev;
- ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
- "epoll add event: fd:%d ev:%08X", c->fd, ee.events);
+ } else {
+ op = EPOLL_CTL_ADD;
+ }
- if (epoll_ctl(ep, EPOLL_CTL_ADD, c->fd, &ee) == -1) {
- ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno,
- "epoll_ctl(EPOLL_CTL_MOD, %d) failed", c->fd);
+ ee.events = event | flags;
+ ee.data.ptr = (void *) ((uintptr_t) c | ev->instance);
+
+ ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0,
+ "epoll add event: fd:%d op:%d ev:%08X",
+ c->fd, op, ee.events);
+
+ if (epoll_ctl(ep, op, c->fd, &ee) == -1) {
+ ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
+ "epoll_ctl(%d, %d) failed", op, c->fd);
return NGX_ERROR;
}
ev->active = 1;
+#if 0
+ ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1 : 0;
+#endif
return NGX_OK;
}
static int ngx_epoll_del_event(ngx_event_t *ev, int event, u_int flags)
{
- struct epoll_event ee;
+ int op, prev;
+ ngx_event_t *e;
ngx_connection_t *c;
+ struct epoll_event ee;
+
+ /*
+ * when the file descriptor is closed the epoll automatically deletes
+ * it from its queue so we do not need to delete explicity the event
+ * before the closing the file descriptor.
+ */
+
+ if (flags & NGX_CLOSE_EVENT) {
+ ev->active = 0;
+ return NGX_OK;
+ }
c = ev->data;
- ee.events = 0;
- ee.data.ptr = NULL;
+ if (event == NGX_READ_EVENT) {
+ e = c->write;
+ prev = EPOLLOUT;
- ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
- "epoll del event: fd:%d", c->fd);
+ } else {
+ e = c->read;
+ prev = EPOLLIN;
+ }
- if (epoll_ctl(ep, EPOLL_CTL_DEL, c->fd, &ee) == -1) {
- ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno,
- "epoll_ctl(EPOLL_CTL_MOD, %d) failed", c->fd);
+ if (e->active) {
+ op = EPOLL_CTL_MOD;
+ ee.events = prev | flags;
+ ee.data.ptr = (void *) ((uintptr_t) c | ev->instance);
+
+ } else {
+ op = EPOLL_CTL_DEL;
+ ee.events = 0;
+ ee.data.ptr = NULL;
+ }
+
+ ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0,
+ "epoll del event: fd:%d op:%d ev:%08X",
+ c->fd, op, ee.events);
+
+ if (epoll_ctl(ep, op, c->fd, &ee) == -1) {
+ ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
+ "epoll_ctl(%d, %d) failed", op, c->fd);
return NGX_ERROR;
}
}
+#if 0
static int ngx_epoll_add_connection(ngx_connection_t *c)
{
struct epoll_event ee;
return NGX_OK;
}
+#endif
int ngx_epoll_process_events(ngx_log_t *log)
}
/*
- * when the file descriptor is closed a kqueue automatically deletes
+ * when the file descriptor is closed the kqueue automatically deletes
* its filters so we do not need to delete explicity the event
* before the closing the file descriptor.
*/
} else {
ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0,
- "poll index: %d", e->index);
+ "poll add index: %d", e->index);
event_list[e->index].events |= event;
ev->index = e->index;
nevents--;
if (ev->index < (u_int) nevents) {
+
+ ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
+ "index: copy event %d to %d", nevents, ev->index);
+
event_list[ev->index] = event_list[nevents];
c = &ngx_cycle->connections[event_list[nevents].fd];
} else {
if (c->read->index == (u_int) nevents) {
c->read->index = ev->index;
+ }
- } else if (c->write->index == (u_int) nevents) {
+ if (c->write->index == (u_int) nevents) {
c->write->index = ev->index;
-
- } else {
- ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
- "unexpected last event index");
}
}
}
} else {
ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ev->log, 0,
- "poll index: %d", e->index);
+ "poll del index: %d", e->index);
event_list[e->index].events &= ~event;
}
/*
* The event filter requires to read/write the whole data -
- * select, poll, /dev/poll, kqueue.
+ * select, poll, /dev/poll, kqueue, epoll.
*/
#define NGX_USE_LEVEL_EVENT 0x00000001
/*
* The event filter is deleted after a notification without an additional
- * syscall - select, poll, kqueue.
+ * syscall - select, poll, kqueue, epoll.
*/
#define NGX_USE_ONESHOT_EVENT 0x00000002
/*
- * The event filter notifies only the changes and an initial level - kqueue.
+ * The event filter notifies only the changes and an initial level -
+ * kqueue, epoll.
*/
#define NGX_USE_CLEAR_EVENT 0x00000004
/*
* The event filter notifies only the changes (the edges)
- * but not an initial level - epoll.
+ * but not an initial level - early epoll patches.
*/
#define NGX_USE_EDGE_EVENT 0x00000020
#define NGX_DISABLE_EVENT EV_DISABLE
-#elif (HAVE_POLL)
+#elif (HAVE_DEVPOLL)
#define NGX_READ_EVENT POLLIN
#define NGX_WRITE_EVENT POLLOUT
#define NGX_LEVEL_EVENT 0
-#define NGX_ONESHOT_EVENT 1
-#elif (HAVE_DEVPOLL)
+#elif (HAVE_EPOLL)
+
+#define NGX_READ_EVENT EPOLLIN
+#define NGX_WRITE_EVENT EPOLLOUT
+
+#define NGX_LEVEL_EVENT 0
+#define NGX_CLEAR_EVENT EPOLLET
+#define NGX_ONESHOT_EVENT 0x70000000
+#if 0
+#define NGX_ONESHOT_EVENT EPOLLONESHOT
+#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 /* select */
return;
}
- /* set a blocking mode for aio and non-blocking mode for others */
+ /* set a blocking mode for aio and non-blocking mode for the others */
if (ngx_inherited_nonblocking) {
if ((ngx_event_flags & NGX_USE_AIO_EVENT)) {
rev = c->read;
rev->event_handler = ngx_http_init_request;
- /* STUB: epoll */ c->write->event_handler = ngx_http_empty_handler;
+ /* STUB: epoll edge */ c->write->event_handler = ngx_http_empty_handler;
if (rev->ready) {
- /* deferred accept, aio, iocp, epoll */
+ /* deferred accept, aio, iocp */
ngx_http_init_request(rev);
return;
}
}
h = c->buffer;
+ wev = c->write;
+ wev->event_handler = ngx_http_empty_handler;
if (h->pos < h->last) {
h->pos = h->last = h->start;
rev->event_handler = ngx_http_keepalive_handler;
- wev = c->write;
- wev->event_handler = ngx_http_empty_handler;
if (wev->active) {
if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) {
projects / nginx.git / commitdiff