mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2025-03-13 19:37:35 +01:00
Code Issues Projects Releases Wiki Activity

Peer: use a minimum reconnection delay of 200 ms (#1285)

Browse source 
If our initial random deconnnection delay is 0 (unlikely but possible) then all "exponential backoff" reconnection delays will be 0 too, so we set a minimum value of 200 milliseconds.

(cherry picked from commit a0ae5ef13f)
This commit is contained in:
Fabrice Drouin 2020-01-21 17:16:50 +01:00 • committed by dpad85
parent 1a8f225d76
commit e3f6f08631
No known key found for this signature in database
GPG key ID: 574C8C6A1673E987
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
eclair-core/src/main/scala/fr/acinq/eclair/io/Peer.scala
View file

@ -719,7 +719,7 @@ object Peer {
/**
* This helps preventing peers reconnection loops due to synchronization of reconnection attempts.
*/
def randomizeDelay(initialRandomReconnectDelay: FiniteDuration): FiniteDuration = Random.nextInt(initialRandomReconnectDelay.toMillis.toInt).millis
def randomizeDelay(initialRandomReconnectDelay: FiniteDuration): FiniteDuration = Random.nextInt(initialRandomReconnectDelay.toMillis.toInt).millis.max(200 milliseconds)
/**
* Exponential backoff retry with a finite max

1
eclair-core/src/test/scala/fr/acinq/eclair/io/PeerSpec.scala
View file

@ -199,6 +199,7 @@ class PeerSpec extends TestkitBaseClass with StateTestsHelperMethods {
probe.send(transport.ref, PoisonPill)
awaitCond(peer.stateName === DISCONNECTED)
val initialReconnectDelay = peer.stateData.asInstanceOf[DisconnectedData].nextReconnectionDelay
assert(initialReconnectDelay >= (200 milliseconds))
assert(initialReconnectDelay <= (10 seconds))
probe.send(peer, Reconnect)
assert(peer.stateData.asInstanceOf[DisconnectedData].nextReconnectionDelay === (initialReconnectDelay * 2))