mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2024-11-19 18:10:42 +01:00
Code Issues Projects Releases Wiki Activity

send INPUT_RECONNECTED right away when restoring a channel and peer is already connected

Browse Source
This commit is contained in:
pm47 2017-04-28 18:40:07 +02:00
parent 80281bbf78
commit c7b5953b64
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
eclair-node/src/main/scala/fr/acinq/eclair/io/Peer.scala
View File

@ -156,9 +156,10 @@ class Peer(nodeParams: NodeParams, remoteNodeId: PublicKey, address_opt: Option[
log.debug(s"received pong with ${data.length} bytes")
stay
case Event(state: HasCommitments, d@ConnectedData(_, _, channels)) =>
case Event(state: HasCommitments, d@ConnectedData(transport, _, channels)) =>
val channel = spawnChannel(nodeParams, context.system.deadLetters)
channel ! INPUT_RESTORED(state)
channel ! INPUT_RECONNECTED(transport)
stay using d.copy(channels = channels + (state.channelId -> channel))
case Event(err@Error(channelId, reason), ConnectedData(transport, _, channels)) if channelId == CHANNELID_ZERO =>