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