electrum

commit f0ac81419c155ad555370a3b426ab223fab049b0
parent 5eab60621db69d9adc237dccab0eefe91b620f0c
Author: ThomasV <thomasv@electrum.org>
Date:   Tue, 19 Mar 2019 13:24:47 +0100

increase timeout in open_channel

Diffstat:
M
electrum/lnpeer.py
 | 
2
+-
M
electrum/lnworker.py
 | 
4
+++-

2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py
@@ -337,7 +337,7 @@ class Peer(PrintError):
             channel_reserve_satoshis=local_config.reserve_sat,
             htlc_minimum_msat=1,
         )
-        payload = await asyncio.wait_for(self.channel_accepted[temp_channel_id].get(), 1)
+        payload = await asyncio.wait_for(self.channel_accepted[temp_channel_id].get(), 20)
         if payload.get('error'):
             raise Exception('Remote Lightning peer reported error: ' + repr(payload.get('error')))
         remote_per_commitment_point = payload['first_per_commitment_point']
diff --git a/electrum/lnworker.py b/electrum/lnworker.py
@@ -429,7 +429,7 @@ class LNWorker(PrintError):
         choice = random.choice(addr_list)
         return choice.host, choice.port
 
-    def open_channel(self, connect_contents, local_amt_sat, push_amt_sat, password=None, timeout=5):
+    def open_channel(self, connect_contents, local_amt_sat, push_amt_sat, password=None, timeout=20):
         node_id, rest = extract_nodeid(connect_contents)
         peer = self.peers.get(node_id)
         if not peer:
@@ -787,6 +787,8 @@ class LNWorker(PrintError):
             channels = list(self.channels.values())
         now = time.time()
         for chan in channels:
+            if chan.is_closed():
+                continue
             if constants.net is not constants.BitcoinRegtest:
                 ratio = chan.constraints.feerate / self.current_feerate_per_kw()
                 if ratio < 0.5: