From dd4a64b049f21cacc6fdb8988f8e515a136a31cd Mon Sep 17 00:00:00 2001 From: Abilio Marques Date: Mon, 22 Mar 2021 08:15:47 +0100 Subject: [PATCH] fully empty socketpairR on interruptible_sleep Signed-off-by: Abilio Marques --- lib/loop.c | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/lib/loop.c b/lib/loop.c index 046dde0bca..57252f3346 100644 --- a/lib/loop.c +++ b/lib/loop.c @@ -204,10 +204,9 @@ static int interruptible_sleep(struct mosquitto *mosq, time_t reconnect_delay) int maxfd = 0; #ifndef WIN32 - if(read(mosq->sockpairR, &pairbuf, 1) == 0){ - } + while(read(mosq->sockpairR, &pairbuf, 1) > 0); #else - recv(mosq->sockpairR, &pairbuf, 1, 0); + while(recv(mosq->sockpairR, &pairbuf, 1, 0) > 0); #endif local_timeout.tv_sec = reconnect_delay;