diff options
| author | Paul Kulchenko <paul@kulchenko.com> | 2023-11-09 03:00:09 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-11-09 14:00:09 +0300 |
| commit | 22b8202d703cc43674d5d0ca2dff7a286406c592 (patch) | |
| tree | 8b67f9e48cb7b0dcd3520d4f47ec6558d8ff0627 | |
| parent | bef62aeb503422d70ccb04fd65d26e6cb9bc2cb1 (diff) | |
| download | luasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.tar.gz luasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.tar.bz2 luasocket-22b8202d703cc43674d5d0ca2dff7a286406c592.zip | |
fix(wsocket): Properly report CONNRESET (#81)
| -rwxr-xr-x | src/wsocket.c | 2 |
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 | } |