diff --git a/src/connector.c b/src/connector.c index 7c9e28b1..083e6b9e 100644 --- a/src/connector.c +++ b/src/connector.c @@ -286,6 +286,11 @@ retry: ck_rlock(&ci->lock); HASH_ITER(fdhh, fdclients, client, tmp) { + if (unlikely(client->fd == -1)) { + LOGWARNING("Client id %d is still in fdclients hashtable with invalidated fd!", + client->id); + continue; + } fds[nfds].fd = client->fd; fds[nfds].events = POLLIN; fds[nfds].revents = 0;