@@ -266,13 +266,16 @@ def connect(self, clean_session=True):
266
266
remaining_length += 2 + len (self ._lw_topic ) + 2 + len (self ._lw_msg )
267
267
var_header [6 ] |= 0x4 | (self ._lw_qos & 0x1 ) << 3 | (self ._lw_qos & 0x2 ) << 3
268
268
var_header [6 ] |= self ._lw_retain << 5
269
+
269
270
270
271
# Remaining length
271
272
i = 1
273
+ test_byte = 0
272
274
if remaining_length > 0x7f :
273
275
# Calculate Remaining Length [2.2.3]
274
276
remaining_bytes = bytearray ()
275
277
while remaining_length > 0 :
278
+ test_byte = 1
276
279
encoded_byte = remaining_length % 0x80
277
280
remaining_length = remaining_length // 0x80
278
281
# if there is more data to encode, set the top bit of the byte
@@ -285,22 +288,29 @@ def connect(self, clean_session=True):
285
288
print ('prl, rel.length: ' , remaining_length )
286
289
print ('prl, byte: ' , encoded_byte )
287
290
i += 1
288
- #fixed_header[i] = 0x00
289
- fixed_header .append (0x00 )
291
+ if test_byte :
292
+ fixed_header .append (0x00 )
293
+ else :
294
+ print (fixed_header )
295
+ print (remaining_length )
296
+ fixed_header .append (remaining_length )
297
+ fixed_header .append (0x00 )
298
+
290
299
291
300
"""
292
301
# Old, non-working MMQT/UMQTT IMPL
293
302
i = 1
303
+ print(remaining_length)
294
304
while remaining_length > 0x7f:
305
+ print("with variable header...")
295
306
fixed_header[i] = (remaining_length & 0x7f) | 0x80
296
307
remaining_length >>= 7
297
308
i += 1
298
- fixed_header[i] = remaining_length
299
309
print("i: ", i)
310
+ fixed_header[i] = remaining_length
300
311
print(fixed_header)
301
312
print(remaining_length)
302
313
"""
303
-
304
314
305
315
if self ._logger is not None :
306
316
self ._logger .debug ('Sending CONNECT packet to broker' )
0 commit comments