summaryrefslogtreecommitdiff
path: root/source4/lib/events/events_standard.c
diff options
context:
space:
mode:
authorAndrew Tridgell <tridge@samba.org>2007-05-14 00:57:48 +0000
committerGerald (Jerry) Carter <jerry@samba.org>2007-10-10 14:52:21 -0500
commitecc54f900fa6aaf1b97ef85b1101cf7badf33cec (patch)
tree4985d6817c5b8e052fb4e0a3946a638697b602a0 /source4/lib/events/events_standard.c
parentbc02bba4499b7f6c78dc5db0610fe4f4d238829a (diff)
downloadsamba-ecc54f900fa6aaf1b97ef85b1101cf7badf33cec.tar.gz
samba-ecc54f900fa6aaf1b97ef85b1101cf7badf33cec.tar.bz2
samba-ecc54f900fa6aaf1b97ef85b1101cf7badf33cec.zip
r22830: merged the latest lib/events updates from ctdb to Samba4. This
includes a new EVENT_FD_AUTOCLOSE flag that prevents race conditions where code using fd events might close a fd before releasing the struct fd_event. That causes headaches for epoll. (This used to be commit f1ad216de13b154a1f8747a44b0970dcc47a784a)
Diffstat (limited to 'source4/lib/events/events_standard.c')
-rw-r--r--source4/lib/events/events_standard.c17
1 files changed, 11 insertions, 6 deletions
diff --git a/source4/lib/events/events_standard.c b/source4/lib/events/events_standard.c
index dcf890ac12..799b19813a 100644
--- a/source4/lib/events/events_standard.c
+++ b/source4/lib/events/events_standard.c
@@ -30,7 +30,7 @@
#include "includes.h"
#include "system/filesys.h"
-#include "system/select.h" /* needed for WITH_EPOLL */
+#include "system/select.h" /* needed for HAVE_EVENTS_EPOLL */
#include "lib/util/dlinklist.h"
#include "lib/events/events.h"
#include "lib/events/events_internal.h"
@@ -61,7 +61,7 @@ struct std_event_context {
};
/* use epoll if it is available */
-#if WITH_EPOLL
+#if HAVE_EVENTS_EPOLL
/*
called when a epoll call fails, and we should fallback
to using select
@@ -229,15 +229,15 @@ static int epoll_event_loop(struct std_event_context *std_ev, struct timeval *tv
timeout = ((tvalp->tv_usec+999) / 1000) + (tvalp->tv_sec*1000);
}
- if (epoll_ev->ev->num_signal_handlers &&
- common_event_check_signal(epoll_ev->ev)) {
+ if (std_ev->ev->num_signal_handlers &&
+ common_event_check_signal(std_ev->ev)) {
return 0;
}
ret = epoll_wait(std_ev->epoll_fd, events, MAXEVENTS, timeout);
- if (ret == -1 && errno == EINTR && epoll_ev->ev->num_signal_handlers) {
- if (common_event_check_signal(epoll_ev->ev)) {
+ if (ret == -1 && errno == EINTR && std_ev->ev->num_signal_handlers) {
+ if (common_event_check_signal(std_ev->ev)) {
return 0;
}
}
@@ -353,6 +353,11 @@ static int std_event_fd_destructor(struct fd_event *fde)
epoll_del_event(std_ev, fde);
+ if (fde->flags & EVENT_FD_AUTOCLOSE) {
+ close(fde->fd);
+ fde->fd = -1;
+ }
+
return 0;
}