Fix errors not propagating properly with libuv.h.

yossigo · yossigo · commit 9ce15c4b3925 · 2018-11-04T10:04:53.000+02:00
diff --git a/adapters/libuv.h b/adapters/libuv.h
@@ -15,15 +15,12 @@ typedef struct redisLibuvEvents {
 
 static void redisLibuvPoll(uv_poll_t* handle, int status, int events) {
   redisLibuvEvents* p = (redisLibuvEvents*)handle->data;
+  int ev = (status ? p->events : events);
 
-  if (status != 0) {
-    return;
-  }
-
-  if (p->context != NULL && (events & UV_READABLE)) {
+  if (p->context != NULL && (ev & UV_READABLE)) {
     redisAsyncHandleRead(p->context);
   }
-  if (p->context != NULL && (events & UV_WRITABLE)) {
+  if (p->context != NULL && (ev & UV_WRITABLE)) {
     redisAsyncHandleWrite(p->context);
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -15,15 +15,12 @@ typedef struct redisLibuvEvents {`
`15`	`15`
`16`	`16`	`static void redisLibuvPoll(uv_poll_t* handle, int status, int events) {`
`17`	`17`	`redisLibuvEvents* p = (redisLibuvEvents*)handle->data;`
	`18`	`+ int ev = (status ? p->events : events);`
`18`	`19`
`19`		`- if (status != 0) {`
`20`		`- return;`
`21`		`- }`
`22`		`-`
`23`		`- if (p->context != NULL && (events & UV_READABLE)) {`
	`20`	`+ if (p->context != NULL && (ev & UV_READABLE)) {`
`24`	`21`	`redisAsyncHandleRead(p->context);`
`25`	`22`	`}`
`26`		`- if (p->context != NULL && (events & UV_WRITABLE)) {`
	`23`	`+ if (p->context != NULL && (ev & UV_WRITABLE)) {`
`27`	`24`	`redisAsyncHandleWrite(p->context);`
`28`	`25`	`}`
`29`	`26`	`}`