summaryrefslogtreecommitdiff
path: root/source4/lib/events/events_epoll.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_epoll.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_epoll.c')
-rw-r--r--source4/lib/events/events_epoll.c11
1 files changed, 9 insertions, 2 deletions
diff --git a/source4/lib/events/events_epoll.c b/source4/lib/events/events_epoll.c
index 2f879cc410..b553b6fd49 100644
--- a/source4/lib/events/events_epoll.c
+++ b/source4/lib/events/events_epoll.c
@@ -136,7 +136,9 @@ static void epoll_del_event(struct epoll_event_context *epoll_ev, struct fd_even
ZERO_STRUCT(event);
event.events = epoll_map_flags(fde->flags);
event.data.ptr = fde;
- epoll_ctl(epoll_ev->epoll_fd, EPOLL_CTL_DEL, fde->fd, &event);
+ if (epoll_ctl(epoll_ev->epoll_fd, EPOLL_CTL_DEL, fde->fd, &event) != 0) {
+ DEBUG(0,("epoll_del_event failed! probable early close bug (%s)\n", strerror(errno)));
+ }
fde->additional_flags &= ~EPOLL_ADDITIONAL_FD_FLAG_HAS_EVENT;
}
@@ -202,7 +204,7 @@ static void epoll_change_event(struct epoll_event_context *epoll_ev, struct fd_e
static int epoll_event_loop(struct epoll_event_context *epoll_ev, struct timeval *tvalp)
{
int ret, i;
-#define MAXEVENTS 8
+#define MAXEVENTS 32
struct epoll_event events[MAXEVENTS];
uint32_t destruction_count = ++epoll_ev->destruction_count;
int timeout = -1;
@@ -306,6 +308,11 @@ static int epoll_event_fd_destructor(struct fd_event *fde)
epoll_del_event(epoll_ev, fde);
+ if (fde->flags & EVENT_FD_AUTOCLOSE) {
+ close(fde->fd);
+ fde->fd = -1;
+ }
+
return 0;
}