Handle connection error in mqttsimple client

wolfSSL · Nov 11, 2024 · 7af0188 · 7af0188
1 parent 6db6c74
commit 7af0188
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/mqttsimple/mqttsimple.c b/examples/mqttsimple/mqttsimple.c
@@ -229,7 +229,7 @@ static int mqtt_net_read(void *context, byte* buf, int buf_len, int timeout_ms)
     /* Loop until buf_len has been read, error or timeout */
     while (bytes < buf_len) {
         rc = (int)recv(*pSockFd, &buf[bytes], buf_len - bytes, 0);
-        if (rc < 0) {
+        if (rc <= 0) {
             rc = socket_get_error(*pSockFd);
             if (rc == 0)
                 break; /* timeout */