Skip to content

Commit 2da6833

Browse files
committed
Fix schedule in discovery manager
1 parent d6253cc commit 2da6833

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

src/main/scala/io/iohk/ethereum/network/discovery/PeerDiscoveryManager.scala

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,10 +34,7 @@ class PeerDiscoveryManager(
3434

3535
if (discoveryConfig.discoveryEnabled) {
3636
discoveryListener ! DiscoveryListener.Subscribe
37-
38-
context.system.scheduler.schedule(discoveryConfig.scanInitialDelay, discoveryConfig.scanInterval) {
39-
scan()
40-
}
37+
context.system.scheduler.schedule(discoveryConfig.scanInitialDelay, discoveryConfig.scanInterval, self, Scan)
4138
}
4239

4340
def scan(): Unit = {
@@ -78,6 +75,8 @@ class PeerDiscoveryManager(
7875

7976
case GetDiscoveredNodes =>
8077
sender() ! DiscoveredNodes(nodes.values.toSet)
78+
79+
case Scan => scan()
8180
}
8281

8382
private def sendPing(toNodeId: ByteString, toAddr: InetSocketAddress): Unit = {
@@ -130,4 +129,6 @@ object PeerDiscoveryManager {
130129

131130
case object GetDiscoveredNodes
132131
case class DiscoveredNodes(nodes: Set[Node])
132+
133+
private case object Scan
133134
}

0 commit comments

Comments
 (0)