From 1ac674099da47a5073dab35e06c80652d39c2f37 Mon Sep 17 00:00:00 2001 From: Douglas Clowes Date: Fri, 14 Jun 2013 13:33:08 +1000 Subject: [PATCH] Fix connection failure logic in AsyncQueue, return if not reconnected --- asyncqueue.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/asyncqueue.c b/asyncqueue.c index fedc9c84..232d96b5 100644 --- a/asyncqueue.c +++ b/asyncqueue.c @@ -300,8 +300,7 @@ static int StartCommand(pAsyncQueue self) iRet = NETRead(sock, reply, 128, 0); if (iRet < 0) { /* EOF */ iRet = AQ_Reconnect(self); - if (iRet == 0) - return 0; + return 0; } else if (iRet > 0) { struct timeval tv; gettimeofday(&tv, NULL);