tlnbase: mark_open on startup - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 2b9be294a0666387a1165e67494350992ad6ba51
DIR parent f1d067f4464f29426f57d47bc9fe550448b31fac
HTML Author: ThomasV <thomasv@electrum.org>
Date: Thu, 7 Jun 2018 08:55:18 +0200
lnbase: mark_open on startup
Diffstat:
M lib/lnbase.py | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
---
DIR diff --git a/lib/lnbase.py b/lib/lnbase.py
t@@ -686,7 +686,7 @@ class Peer(PrintError):
def process_message(self, message):
message_type, payload = decode_msg(message)
- self.print_error("Received '%s'" % message_type.upper())
+ #self.print_error("Received '%s'" % message_type.upper())
try:
f = getattr(self, 'on_' + message_type)
except AttributeError:
t@@ -941,6 +941,7 @@ class Peer(PrintError):
def on_channel_reestablish(self, payload):
chan_id = payload["channel_id"]
+ self.print_error("Received channel_reestablish", bh2u(chan_id))
chan = self.channels.get(chan_id)
if not chan:
print("Warning: received unknown channel_reestablish", bh2u(chan_id))
t@@ -954,7 +955,9 @@ class Peer(PrintError):
raise Exception("expected local ctn {}, got {}".format(chan.local_state.ctn, local_ctn))
if channel_reestablish_msg["my_current_per_commitment_point"] != chan.remote_state.last_per_commitment_point:
raise Exception("Remote PCP mismatch")
- self.channel_state[chan_id] = 'OPENING' #if chan.local_state.funding_locked_received else 'OPENING'
+ self.channel_state[chan_id] = 'OPENING'
+ if chan.local_state.funding_locked_received:
+ self.mark_open(chan)
self.network.trigger_callback('channel', chan)
def funding_locked(self, chan):