wip

wavesplatform · Sep 11, 2024 · 6a188e3 · 6a188e3
1 parent ae5fac0
commit 6a188e3
Showing 1 changed file with 7 additions and 10 deletions.
diff --git a/node/src/main/scala/com/wavesplatform/network/PeerDatabaseImpl.scala b/node/src/main/scala/com/wavesplatform/network/PeerDatabaseImpl.scala
@@ -123,16 +123,13 @@ class PeerDatabaseImpl(settings: NetworkSettings) extends PeerDatabase with Scor
       }
     }
 
-    val fromConfig = settings.knownPeers.flatMap(p => inetSocketAddress(p, 6868))
-    val msg = s"Calculate random peer, unverified: [${unverifiedPeers.asScala.mkString(",")}], known: [${knownPeers.mkString(",")}], from config: [${fromConfig.mkString(",")}]"
-
-    val result = nextUnverified() orElse Random
-      .shuffle(
-        (knownPeers.keySet ++ fromConfig).filterNot(excludeAddress)
-      )
-      .headOption
-    log.trace(s"$msg, result=$result")
-    result
+    val knownPeersFromConfig = settings.knownPeers.flatMap(p => inetSocketAddress(p, 6868))
+    val nextCandidateFromConfig = knownPeersFromConfig.filterNot(knownPeers.keySet).headOption
+
+    nextCandidateFromConfig
+      .orElse(nextUnverified())
+      .orElse(Random.shuffle((knownPeers.keySet ++ knownPeersFromConfig).filterNot(excludeAddress)).headOption)
+
   }
 
   def clearBlacklist(): Unit = {