P2Pool/consensus
P2Pool/consensus
1
1
Fork 0
Code Issues 3 Pull requests Releases Activity

Allow 0/0 peers setting for debugging, check outgoing connections in monerod reconnect loop

Browse source
This commit is contained in:
DataHoarder 2023-06-05 23:46:16 +02:00
parent 29751ec74d
commit 4ed83d58f5
Signed by: DataHoarder
SSH key fingerprint: SHA256:OLTRf6Fl87G52SiR7sWLGNzlJt4WOX+tfI2yxo0z7xk
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
p2pool/p2p/server.go
View file

@ -126,8 +126,8 @@ func NewServer(p2pool P2PoolInterface, listenAddress string, externalListenPort
listenAddress: addrPort,
externalListenPort: externalListenPort,
peerId: binary.LittleEndian.Uint64(peerId),
MaxOutgoingPeers: utils.Min(utils.Max(maxOutgoingPeers, 10), 450),
MaxIncomingPeers: utils.Min(utils.Max(maxIncomingPeers, 10), 450),
MaxOutgoingPeers: utils.Min(maxOutgoingPeers, 450),
MaxIncomingPeers: utils.Min(maxIncomingPeers, 450),
cachedBlocks: make(map[types.Hash]*sidechain.PoolBlock, p2pool.Consensus().ChainWindowSize*3),
versionInformation: p2pooltypes.PeerVersionInformation{
SoftwareId: p2pooltypes.CurrentSoftwareId,
@ -383,6 +383,10 @@ func (s *Server) UpdateClientConnections() {
attempts++
go func() {
defer wg.Done()
if s.NumOutgoingConnections.Load() >= int32(s.MaxOutgoingPeers) {
return
}
if err := s.Connect(peer.AddressPort); err != nil {
log.Printf("[P2PServer] Connection to %s rejected (%s)", peer.AddressPort.String(), err.Error())
}