Fixing my bug in 453e045
This commit is contained in:
parent
d0d0b2ec84
commit
f868c1ad11
|
@ -482,8 +482,8 @@ class singleWorker(threading.Thread, StoppableThread):
|
||||||
if Inventory().by_type_and_tag(objectType, tag):
|
if Inventory().by_type_and_tag(objectType, tag):
|
||||||
return # not expired
|
return # not expired
|
||||||
|
|
||||||
payload = pack('>Q', (embeddedTime))
|
payload = pack('>Q', embeddedTime)
|
||||||
payload += str(bytearray([0, 0, 0, objectType]))
|
payload += pack('>I', objectType)
|
||||||
payload += encodeVarint(2 if len(peer.host) == 22 else 3)
|
payload += encodeVarint(2 if len(peer.host) == 22 else 3)
|
||||||
payload += encodeVarint(streamNumber)
|
payload += encodeVarint(streamNumber)
|
||||||
payload += objectPayload
|
payload += objectPayload
|
||||||
|
|
Reference in New Issue
Block a user