Improved opportunistic delivery performance

This commit is contained in:
Mark Qvist 2024-09-30 19:27:40 +02:00
parent 05f144ae50
commit ac2c9c3a9b

View File

@ -15,7 +15,7 @@ class LXMFDeliveryAnnounceHandler:
def received_announce(self, destination_hash, announced_identity, app_data): def received_announce(self, destination_hash, announced_identity, app_data):
for lxmessage in self.lxmrouter.pending_outbound: for lxmessage in self.lxmrouter.pending_outbound:
if destination_hash == lxmessage.destination_hash: if destination_hash == lxmessage.destination_hash:
if lxmessage.method == LXMessage.DIRECT: if lxmessage.method == LXMessage.DIRECT or lxmessage.method == LXMessage.OPPORTUNISTIC:
lxmessage.next_delivery_attempt = time.time() lxmessage.next_delivery_attempt = time.time()
while self.lxmrouter.processing_outbound: while self.lxmrouter.processing_outbound: