William/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2024-11-22 21:50:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix exceptions on Channel shutdown

Browse Source
This commit is contained in:
Aaron Heise 2023-02-28 08:38:23 -06:00
parent 72300cc821
commit 9963cf37b8
No known key found for this signature in database
GPG Key ID: 6BA54088C41DE8BF
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
RNS/Channel.py
View File

@ -507,12 +507,14 @@ class LinkChannelOutlet(ChannelOutletBase):
def inner(receipt: RNS.PacketReceipt): def inner(receipt: RNS.PacketReceipt):
callback(packet) callback(packet)
if packet and packet.receipt:
packet.receipt.set_timeout_callback(inner if callback else None) packet.receipt.set_timeout_callback(inner if callback else None)
def set_packet_delivered_callback(self, packet: RNS.Packet, callback: Callable[[RNS.Packet], None] | None): def set_packet_delivered_callback(self, packet: RNS.Packet, callback: Callable[[RNS.Packet], None] | None):
def inner(receipt: RNS.PacketReceipt): def inner(receipt: RNS.PacketReceipt):
callback(packet) callback(packet)
if packet and packet.receipt:
packet.receipt.set_delivery_callback(inner if callback else None) packet.receipt.set_delivery_callback(inner if callback else None)
def get_packet_id(self, packet: RNS.Packet) -> any: def get_packet_id(self, packet: RNS.Packet) -> any: