diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-01-04 22:32:19 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-01-04 22:32:19 -0800 |
| commit | 95ab679e6443bbd23b308b6d7df7d83df020419d (patch) | |
| tree | 4b09f104c48a519ec003a12f6a84fc284d5b82a7 /src | |
| parent | 40da92f0fffc7b69f876ca060d9b4e6682e45a8c (diff) | |
| download | nng-95ab679e6443bbd23b308b6d7df7d83df020419d.tar.gz nng-95ab679e6443bbd23b308b6d7df7d83df020419d.tar.bz2 nng-95ab679e6443bbd23b308b6d7df7d83df020419d.zip | |
Recv returns 0 on EOF.
Diffstat (limited to 'src')
| -rw-r--r-- | src/platform/posix/posix_net.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/platform/posix/posix_net.c b/src/platform/posix/posix_net.c index 151e14f1..c7af7d0c 100644 --- a/src/platform/posix/posix_net.c +++ b/src/platform/posix/posix_net.c @@ -184,6 +184,9 @@ nni_plat_tcp_recv(nni_plat_tcpsock *s, nni_iov *iovs, int cnt) } return (nni_plat_errno(errno)); } + if (rv == 0) { + return (NNG_ECLOSED); + } if (rv > resid) { nni_panic("readv says it read too much!"); } @@ -370,7 +373,7 @@ nni_plat_tcp_accept(nni_plat_tcpsock *s, nni_plat_tcpsock *server) for (;;) { #ifdef NNG_USE_ACCEPT4 fd = accept4(server->fd, NULL, NULL, SOCK_CLOEXEC); - if ((fd < 0) && ((errrno == ENOSYS) || (errno == ENOTSUP))) { + if ((fd < 0) && ((errno == ENOSYS) || (errno == ENOTSUP))) { fd = accept(server->fd, NULL, NULL); } #else |