aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorPaul Kulchenko <paul@kulchenko.com>2023-11-09 03:00:09 -0800
committerGitHub <noreply@github.com>2023-11-09 14:00:09 +0300
commit22b8202d703cc43674d5d0ca2dff7a286406c592 (patch)
tree8b67f9e48cb7b0dcd3520d4f47ec6558d8ff0627 /src
parentbef62aeb503422d70ccb04fd65d26e6cb9bc2cb1 (diff)
downloadluasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.tar.gz
luasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.tar.bz2
luasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.zip
fix(wsocket): Properly report CONNRESET (#81)
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 }