Fix connection failure logic in AsyncQueue, return if not reconnected
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user