diff options
| -rw-r--r-- | src/platform/posix/posix_poll.c | 1 | ||||
| -rw-r--r-- | src/platform/posix/posix_socket.c | 6 |
2 files changed, 7 insertions, 0 deletions
diff --git a/src/platform/posix/posix_poll.c b/src/platform/posix/posix_poll.c index 4d9a4d0b..e5a2dadf 100644 --- a/src/platform/posix/posix_poll.c +++ b/src/platform/posix/posix_poll.c @@ -889,6 +889,7 @@ nni_posix_pollq_init(nni_posix_pollq *pq) int rv; NNI_LIST_INIT(&pq->pds, nni_posix_pipedesc, node); + NNI_LIST_INIT(&pq->eds, nni_posix_epdesc, node); pq->wakewfd = -1; pq->wakerfd = -1; pq->close = 0; diff --git a/src/platform/posix/posix_socket.c b/src/platform/posix/posix_socket.c index 8eed097e..32530388 100644 --- a/src/platform/posix/posix_socket.c +++ b/src/platform/posix/posix_socket.c @@ -311,7 +311,13 @@ nni_posix_sock_listen(nni_posix_sock *s, const nni_sockaddr *saddr) return (rv); } + if ((rv = nni_posix_epdesc_init(&s->ed, fd)) != 0) { + (void) close(fd); + return (rv); + } + s->fd = fd; + return (0); } |