From bab86af44121d8148fa1145c7c071a38bb5ba59f Mon Sep 17 00:00:00 2001
From: Con Kolivas <kernel@kolivas.org>
Date: Tue, 29 Apr 2014 21:12:22 +1000
Subject: [PATCH] Optimise receiver loop

---
 src/connector.c | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

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);