@@ -275,7 +275,7 @@ def connect(self, clean_session=True):
275
275
while True :
276
276
op = self ._wait_for_msg ()
277
277
if op == 32 :
278
- rc = self ._sock .read (3 )
278
+ rc = self ._sock .recv (3 )
279
279
assert rc [0 ] == 0x02
280
280
if rc [2 ] != 0x00 :
281
281
raise MMQTTException (CONNACK_ERRORS [rc [2 ]])
@@ -313,7 +313,7 @@ def ping(self):
313
313
while True :
314
314
op = self ._wait_for_msg (0.5 )
315
315
if op == 208 :
316
- ping_resp = self ._sock .read (2 )
316
+ ping_resp = self ._sock .recv (2 )
317
317
if ping_resp [0 ] != 0x00 :
318
318
raise MMQTTException ('PINGRESP not returned from broker.' )
319
319
return
@@ -394,9 +394,9 @@ def publish(self, topic, msg, retain=False, qos=0):
394
394
while True :
395
395
op = self ._wait_for_msg ()
396
396
if op == 0x40 :
397
- sz = self ._sock .read (1 )
397
+ sz = self ._sock .recv (1 )
398
398
assert sz == b"\x02 "
399
- rcv_pid = self ._sock .read (2 )
399
+ rcv_pid = self ._sock .recv (2 )
400
400
rcv_pid = rcv_pid [0 ] << 0x08 | rcv_pid [1 ]
401
401
if pid == rcv_pid :
402
402
if self .on_publish is not None :
@@ -472,7 +472,7 @@ def subscribe(self, topic, qos=0):
472
472
while True :
473
473
op = self ._wait_for_msg ()
474
474
if op == 0x90 :
475
- rc = self ._sock .read (4 )
475
+ rc = self ._sock .recv (4 )
476
476
assert rc [1 ] == packet [2 ] and rc [2 ] == packet [3 ]
477
477
if rc [3 ] == 0x80 :
478
478
raise MMQTTException ('SUBACK Failure!' )
@@ -529,7 +529,7 @@ def unsubscribe(self, topic):
529
529
while True :
530
530
op = self ._wait_for_msg ()
531
531
if op == 176 :
532
- return_code = self ._sock .read (3 )
532
+ return_code = self ._sock .recv (3 )
533
533
assert return_code [0 ] == 0x02
534
534
# [MQTT-3.32]
535
535
assert return_code [1 ] == packet_id_bytes [0 ] and return_code [2 ] == packet_id_bytes [1 ]
@@ -640,27 +640,27 @@ def _wait_for_msg(self, timeout=30):
640
640
"""Reads and processes network events.
641
641
Returns response code if successful.
642
642
"""
643
- res = self ._sock .read (1 )
643
+ res = self ._sock .recv (1 )
644
644
self ._sock .settimeout (timeout )
645
645
if res in [None , b"" ]:
646
646
return None
647
647
if res == MQTT_PINGRESP :
648
- sz = self ._sock .read (1 )[0 ]
648
+ sz = self ._sock .recv (1 )[0 ]
649
649
assert sz == 0
650
650
return None
651
651
if res [0 ] & 0xf0 != 0x30 :
652
652
return res [0 ]
653
653
sz = self ._recv_len ()
654
- topic_len = self ._sock .read (2 )
654
+ topic_len = self ._sock .recv (2 )
655
655
topic_len = (topic_len [0 ] << 8 ) | topic_len [1 ]
656
- topic = self ._sock .read (topic_len )
656
+ topic = self ._sock .recv (topic_len )
657
657
topic = str (topic , 'utf-8' )
658
658
sz -= topic_len + 2
659
659
if res [0 ] & 0x06 :
660
- pid = self ._sock .read (2 )
660
+ pid = self ._sock .recv (2 )
661
661
pid = pid [0 ] << 0x08 | pid [1 ]
662
662
sz -= 0x02
663
- msg = self ._sock .read (sz )
663
+ msg = self ._sock .recv (sz )
664
664
if self .on_message is not None :
665
665
self .on_message (self , topic , str (msg , 'utf-8' ))
666
666
if res [0 ] & 0x06 == 0x02 :
@@ -675,7 +675,7 @@ def _recv_len(self):
675
675
n = 0
676
676
sh = 0
677
677
while True :
678
- b = self ._sock .read (1 )[0 ]
678
+ b = self ._sock .recv (1 )[0 ]
679
679
n |= (b & 0x7f ) << sh
680
680
if not b & 0x80 :
681
681
return n
0 commit comments