tlnpeer: replace asyncio.sleep with events - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 6eba22b5a8b191747875634d734a9b9c150f8cc4
DIR parent 86b33a563781a6f30d8ad4d85b1bcb38e667f773
HTML Author: ThomasV <thomasv@electrum.org>
Date: Mon, 11 Feb 2019 16:55:26 +0100
lnpeer: replace asyncio.sleep with events
Diffstat:
M electrum/lnpeer.py | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
---
DIR diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py
t@@ -78,6 +78,8 @@ class Peer(PrintError):
self.attempted_route = {}
self.orphan_channel_updates = OrderedDict()
self.pending_updates = defaultdict(bool)
+ self._local_changed_events = defaultdict(asyncio.Event)
+ self._remote_changed_events = defaultdict(asyncio.Event)
def send_message(self, message_name: str, **kwargs):
assert type(message_name) is str
t@@ -828,11 +830,11 @@ class Peer(PrintError):
async def await_remote(self, chan: Channel, ctn: int):
self.maybe_send_commitment(chan)
while chan.get_current_ctn(REMOTE) <= ctn:
- await asyncio.sleep(0.1)
+ await self._remote_changed_events[chan.channel_id].wait()
async def await_local(self, chan: Channel, ctn: int):
while chan.get_current_ctn(LOCAL) <= ctn:
- await asyncio.sleep(0.1)
+ await self._local_changed_events[chan.channel_id].wait()
async def pay(self, route: List['RouteEdge'], chan: Channel, amount_msat: int,
payment_hash: bytes, min_final_cltv_expiry: int):
t@@ -877,6 +879,8 @@ class Peer(PrintError):
data = payload["htlc_signature"]
htlc_sigs = [data[i:i+64] for i in range(0, len(data), 64)]
chan.receive_new_commitment(payload["signature"], htlc_sigs)
+ self._local_changed_events[chan.channel_id].set()
+ self._local_changed_events[chan.channel_id].clear()
self.send_revoke_and_ack(chan)
def on_update_fulfill_htlc(self, update_fulfill_htlc_msg):
t@@ -1025,6 +1029,8 @@ class Peer(PrintError):
channel_id = payload["channel_id"]
chan = self.channels[channel_id]
chan.receive_revocation(RevokeAndAck(payload["per_commitment_secret"], payload["next_per_commitment_point"]))
+ self._remote_changed_events[chan.channel_id].set()
+ self._remote_changed_events[chan.channel_id].clear()
self.lnworker.save_channel(chan)
def on_update_fee(self, payload):