Add explicit rejection of incoming peer's connections.

status-im · Jul 27, 2020 · 62ef619 · 62ef619
1 parent 6face7a
commit 62ef619
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/beacon_chain/eth2_network.nim b/beacon_chain/eth2_network.nim
@@ -670,12 +670,15 @@ proc handleIncomingPeer*(peer: Peer): Future[bool] {.async.} =
     debug "Peer (incoming) lost", peer
     nbc_peers.set int64(len(network.peerPool))
 
-  let res = await network.peerPool.addIncomingPeer(peer)
+  let res = network.peerPool.addIncomingPeerNoWait(peer)
   if res:
     peer.updateScore(NewPeerScore)
     debug "Peer (incoming) has been added to PeerPool", peer
     peer.getFuture().addCallback(onPeerClosed)
     result = true
+  else:
+    debug "Too many incoming connections in PeerPool, disconnecting", peer
+    result = false
 
   nbc_peers.set int64(len(network.peerPool))