File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -963,15 +963,15 @@ def _sock_exact_recv(self, bufsize):
963
963
# CPython/Socketpool Impl.
964
964
rc = bytearray (bufsize )
965
965
mv = memoryview (rc )
966
- recv = self ._sock .recv_into (rc , bufsize )
967
- to_read = bufsize - recv
966
+ recv_len = self ._sock .recv_into (rc , bufsize )
967
+ to_read = bufsize - recv_len
968
968
assert to_read >= 0
969
969
read_timeout = self .keep_alive
970
- mv = mv [recv :]
970
+ mv = mv [recv_len :]
971
971
while to_read > 0 :
972
- recv = self ._sock .recv_into (mv , to_read )
973
- to_read -= recv
974
- mv = mv [recv :]
972
+ recv_len = self ._sock .recv_into (mv , to_read )
973
+ to_read -= recv_len
974
+ mv = mv [recv_len :]
975
975
if time .monotonic () - stamp > read_timeout :
976
976
raise MMQTTException (
977
977
"Unable to receive {} bytes within {} seconds." .format (
You can’t perform that action at this time.
0 commit comments