@@ -626,13 +626,8 @@ def _connect(
626
626
var_header [6 ] |= 0x4 | (self ._lw_qos & 0x1 ) << 3 | (self ._lw_qos & 0x2 ) << 3
627
627
var_header [6 ] |= self ._lw_retain << 5
628
628
629
- large_rel_length = self .encode_remaining_length (fixed_header , remaining_length )
630
- if large_rel_length :
631
- fixed_header .append (0x00 )
632
- else :
633
- fixed_header .append (remaining_length )
634
- fixed_header .append (0x00 )
635
-
629
+ self .encode_remaining_length (fixed_header , remaining_length )
630
+ fixed_header .append (0x00 )
636
631
self .logger .debug ("Sending CONNECT to broker..." )
637
632
self .logger .debug (f"Fixed Header: { fixed_header } " )
638
633
self .logger .debug (f"Variable Header: { var_header } " )
@@ -670,23 +665,21 @@ def _connect(
670
665
)
671
666
672
667
# pylint: disable=no-self-use
673
- def encode_remaining_length (self , fixed_header , remaining_length ):
668
+ def encode_remaining_length (self , fixed_header : bytearray , remaining_length : int ):
674
669
"""
675
670
Encode Remaining Length [2.2.3]
676
671
"""
677
672
# Remaining length calculation
678
- large_rel_length = False
679
673
if remaining_length > 0x7F :
680
- large_rel_length = True
681
674
while remaining_length > 0 :
682
675
encoded_byte = remaining_length % 0x80
683
676
remaining_length = remaining_length // 0x80
684
677
# if there is more data to encode, set the top bit of the byte
685
678
if remaining_length > 0 :
686
679
encoded_byte |= 0x80
687
680
fixed_header .append (encoded_byte )
688
-
689
- return large_rel_length
681
+ else :
682
+ fixed_header . append ( remaining_length )
690
683
691
684
def disconnect (self ) -> None :
692
685
"""Disconnects the MiniMQTT client from the MQTT broker."""
0 commit comments