RanchiMall/flo-electrum
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lnbase: mark_open on startup

Browse Source
This commit is contained in:
ThomasV 2018-06-07 08:55:18 +02:00 committed by Janus
parent a9b2fe3f1a
commit 6a73e04e29
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/lnbase.py
View File

@ -686,7 +686,7 @@ class Peer(PrintError):
def process_message(self, message): def process_message(self, message):
message_type, payload = decode_msg(message) message_type, payload = decode_msg(message)
self.print_error("Received '%s'" % message_type.upper()) #self.print_error("Received '%s'" % message_type.upper())
try: try:
f = getattr(self, 'on_' + message_type) f = getattr(self, 'on_' + message_type)
except AttributeError: except AttributeError:
@ -941,6 +941,7 @@ class Peer(PrintError):
def on_channel_reestablish(self, payload): def on_channel_reestablish(self, payload):
chan_id = payload["channel_id"] chan_id = payload["channel_id"]
self.print_error("Received channel_reestablish", bh2u(chan_id))
chan = self.channels.get(chan_id) chan = self.channels.get(chan_id)
if not chan: if not chan:
print("Warning: received unknown channel_reestablish", bh2u(chan_id)) print("Warning: received unknown channel_reestablish", bh2u(chan_id))
@ -954,7 +955,9 @@ class Peer(PrintError):
raise Exception("expected local ctn {}, got {}".format(chan.local_state.ctn, local_ctn)) 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: if channel_reestablish_msg["my_current_per_commitment_point"] != chan.remote_state.last_per_commitment_point:
raise Exception("Remote PCP mismatch") 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) self.network.trigger_callback('channel', chan)
def funding_locked(self, chan): def funding_locked(self, chan):