summaryrefslogtreecommitdiff
path: root/adapters/libevent.h
diff options
context:
space:
mode:
Diffstat (limited to 'adapters/libevent.h')
-rw-r--r--adapters/libevent.h5
1 files changed, 2 insertions, 3 deletions
diff --git a/adapters/libevent.h b/adapters/libevent.h
index 9843696..5959e89 100644
--- a/adapters/libevent.h
+++ b/adapters/libevent.h
@@ -48,10 +48,10 @@ static void redisLibeventHandler(int fd, short event, void *arg) {
if (event & EV_TIMEOUT) {
redisAsyncHandleTimeout(e->context);
}
- if (e->context && (event & EV_READ)) {
+ if ((event & EV_READ) && e->context) {
redisAsyncHandleRead(e->context);
}
- if (e->context && (event & EV_WRITE)) {
+ if ((event & EV_WRITE) && e->context) {
redisAsyncHandleWrite(e->context);
}
}
@@ -107,7 +107,6 @@ static void redisLibeventSetTimeout(void *privdata, struct timeval tv) {
short flags = e->flags;
e->flags = 0;
e->tv = tv;
- event_del(e->ev);
redisLibeventUpdate(e, flags, 0);
}