status-im
/
nimbus-eth2
mirror of https://github.com/status-im/nimbus-eth2.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

decreate amount of concurent dials (#1460)

This commit is contained in:
Dmitriy Ryajov 2020-08-06 13:21:12 -06:00 committed by GitHub
parent 9861eb1152
commit c5077af4bc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
beacon_chain/eth2_network.nim
View File

@ -211,12 +211,12 @@ const
PeerScoreHighLimit* = 1000 PeerScoreHighLimit* = 1000
## Max value of peer's score ## Max value of peer's score
ConcurrentConnections* = 10 ConcurrentConnections* = 4
## Maximum number of active concurrent connection requests. ## Maximum number of active concurrent connection requests.
SeenTableTimeTimeout* = 1.minutes SeenTableTimeTimeout* = 5.minutes
## Seen period of time for timeout connections ## Seen period of time for timeout connections
SeenTableTimeDeadPeer* = 1.minutes SeenTableTimeDeadPeer* = 5.minutes
## Period of time for dead peers. ## Period of time for dead peers.
SeenTableTimeIrrelevantNetwork* = 24.hours SeenTableTimeIrrelevantNetwork* = 24.hours
## Period of time for `IrrelevantNetwork` error reason. ## Period of time for `IrrelevantNetwork` error reason.
@ -858,7 +858,7 @@ proc init*(T: type Eth2Node, conf: BeaconNodeConf, enrForkId: ENRForkID,
result.wantedPeers = conf.maxPeers result.wantedPeers = conf.maxPeers
result.peerPool = newPeerPool[Peer, PeerID](maxPeers = conf.maxPeers) result.peerPool = newPeerPool[Peer, PeerID](maxPeers = conf.maxPeers)
result.connectTimeout = 1.minutes result.connectTimeout = 1.minutes
result.seenThreshold = 1.minutes result.seenThreshold = 5.minutes
result.seenTable = initTable[PeerID, SeenItem]() result.seenTable = initTable[PeerID, SeenItem]()
result.connTable = initHashSet[PeerID]() result.connTable = initHashSet[PeerID]()
result.connQueue = newAsyncQueue[PeerAddr](ConcurrentConnections) result.connQueue = newAsyncQueue[PeerAddr](ConcurrentConnections)