aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rwxr-xr-xsrc/wsocket.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/wsocket.c b/src/wsocket.c
index 6cb1e41..d3af9d4 100755
--- a/src/wsocket.c
+++ b/src/wsocket.c
@@ -262,6 +262,7 @@ int socket_recv(p_socket ps, char *data, size_t count, size_t *got,
262 if (err != WSAEWOULDBLOCK) { 262 if (err != WSAEWOULDBLOCK) {
263 if (err != WSAECONNRESET || prev == WSAECONNRESET) return err; 263 if (err != WSAECONNRESET || prev == WSAECONNRESET) return err;
264 prev = err; 264 prev = err;
265 continue;
265 } 266 }
266 if ((err = socket_waitfd(ps, WAITFD_R, tm)) != IO_DONE) return err; 267 if ((err = socket_waitfd(ps, WAITFD_R, tm)) != IO_DONE) return err;
267 } 268 }
@@ -291,6 +292,7 @@ int socket_recvfrom(p_socket ps, char *data, size_t count, size_t *got,
291 if (err != WSAEWOULDBLOCK) { 292 if (err != WSAEWOULDBLOCK) {
292 if (err != WSAECONNRESET || prev == WSAECONNRESET) return err; 293 if (err != WSAECONNRESET || prev == WSAECONNRESET) return err;
293 prev = err; 294 prev = err;
295 continue;
294 } 296 }
295 if ((err = socket_waitfd(ps, WAITFD_R, tm)) != IO_DONE) return err; 297 if ((err = socket_waitfd(ps, WAITFD_R, tm)) != IO_DONE) return err;
296 } 298 }