diff --git a/src/connector.c b/src/connector.c index b0f7040c..bdd60bbe 100644 --- a/src/connector.c +++ b/src/connector.c @@ -173,18 +173,17 @@ reparse: void *receiver(void *arg) { conn_instance_t *ci = (conn_instance_t *)arg; - client_instance_t *client, *tmp, *tmpa; + client_instance_t *client; struct pollfd fds[65536]; int ret, nfds, i; rename_proc("receiver"); retry: - memset(fds, 0, sizeof(fds)); nfds = 0; ck_rlock(&ci->lock); - HASH_ITER(hh, clients, client, tmp) { + for (client = clients; client != NULL; client = client->hh.next) { /* Invalid client */ if (client->fd == -1) continue; @@ -198,10 +197,11 @@ retry: cksleep_ms(100); goto retry; } +repoll: ret = poll(fds, nfds, 1000); if (ret < 0) { if (interrupted()) - goto retry; + goto repoll; LOGERR("Failed to poll in receiver"); goto out; } @@ -215,11 +215,9 @@ retry: client = NULL; ck_rlock(&ci->lock); - HASH_ITER(hh, clients, tmp, tmpa) { - if (tmp->fd == fds[i].fd) { - client = tmp; + for (client = clients; client != NULL; client = client->hh.next) { + if (client->fd == fds[i].fd) break; - } } ck_runlock(&ci->lock);