X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=libevent%2Fevport.c;h=0d714d8134e29e3852a94241a14d56d7f0bde9a1;hb=321a0107c48da7b3fbf895a2b32244174c1ff39c;hp=4301a39c7f3213ea81664ad97ade568fbb2be725;hpb=f357762920325c7d84ec891e468655fea5b4473e;p=netatalk.git diff --git a/libevent/evport.c b/libevent/evport.c index 4301a39c..0d714d81 100644 --- a/libevent/evport.c +++ b/libevent/evport.c @@ -1,6 +1,9 @@ /* * Submitted by David Pacheco (dp.spambait@gmail.com) * + * Copyright 2006-2007 Niels Provos + * Copyright 2007-2012 Niels Provos and Nick Mathewson + * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: @@ -336,10 +339,20 @@ evport_dispatch(struct event_base *base, struct timeval *tv) * (because we have to pass this to the callback) */ res = 0; - if (pevt->portev_events & POLLIN) - res |= EV_READ; - if (pevt->portev_events & POLLOUT) - res |= EV_WRITE; + if (pevt->portev_events & (POLLERR|POLLHUP)) { + res = EV_READ | EV_WRITE; + } else { + if (pevt->portev_events & POLLIN) + res |= EV_READ; + if (pevt->portev_events & POLLOUT) + res |= EV_WRITE; + } + + /* + * Check for the error situations or a hangup situation + */ + if (pevt->portev_events & (POLLERR|POLLHUP|POLLNVAL)) + res |= EV_READ|EV_WRITE; EVUTIL_ASSERT(epdp->ed_nevents > fd); fdi = &(epdp->ed_fds[fd]);