Fix memory leaks
This commit is contained in:
parent
58222c26f4
commit
847a20122f
@ -48,10 +48,10 @@ static void redisLibeventHandler(int fd, short event, void *arg) {
|
|||||||
if (event & EV_TIMEOUT) {
|
if (event & EV_TIMEOUT) {
|
||||||
redisAsyncHandleTimeout(e->context);
|
redisAsyncHandleTimeout(e->context);
|
||||||
}
|
}
|
||||||
if (e->context && (event & EV_READ)) {
|
if ((event & EV_READ) && e->context) {
|
||||||
redisAsyncHandleRead(e->context);
|
redisAsyncHandleRead(e->context);
|
||||||
}
|
}
|
||||||
if (e->context && (event & EV_WRITE)) {
|
if ((event & EV_WRITE) && e->context) {
|
||||||
redisAsyncHandleWrite(e->context);
|
redisAsyncHandleWrite(e->context);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -107,7 +107,6 @@ static void redisLibeventSetTimeout(void *privdata, struct timeval tv) {
|
|||||||
short flags = e->flags;
|
short flags = e->flags;
|
||||||
e->flags = 0;
|
e->flags = 0;
|
||||||
e->tv = tv;
|
e->tv = tv;
|
||||||
event_del(e->ev);
|
|
||||||
redisLibeventUpdate(e, flags, 0);
|
redisLibeventUpdate(e, flags, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user