Skip to content

Commit 8f51710

Browse files
committed
use MMQTTException instead of assert for the negative read length
1 parent c0a902a commit 8f51710

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

adafruit_minimqtt/adafruit_minimqtt.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -965,7 +965,11 @@ def _sock_exact_recv(self, bufsize):
965965
mv = memoryview(rc)
966966
recv_len = self._sock.recv_into(rc, bufsize)
967967
to_read = bufsize - recv_len
968-
assert to_read >= 0
968+
if to_read < 0:
969+
raise MMQTTException(
970+
f"negative number of bytes to read: "
971+
f"{to_read} = {bufsize} - {recv_len}"
972+
)
969973
read_timeout = self.keep_alive
970974
mv = mv[recv_len:]
971975
while to_read > 0:

0 commit comments

Comments
 (0)