From e9f8b257760860e8a7207c0b1ec52d41750be4d9 Mon Sep 17 00:00:00 2001 From: Roman Khimov Date: Fri, 1 Nov 2019 13:29:54 +0300 Subject: [PATCH] network: add default MinPeers If there is nothing specified in the configuration, set it to some reasonable value. --- pkg/network/server.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/pkg/network/server.go b/pkg/network/server.go index 23d1c37ea..e24f479ab 100644 --- a/pkg/network/server.go +++ b/pkg/network/server.go @@ -18,10 +18,11 @@ import ( const ( // peer numbers are arbitrary at the moment. - maxPeers = 20 - maxBlockBatch = 200 - maxAddrsToSend = 200 - minPoolCount = 30 + defaultMinPeers = 5 + maxPeers = 20 + maxBlockBatch = 200 + maxAddrsToSend = 200 + minPoolCount = 30 ) var ( @@ -76,6 +77,14 @@ func NewServer(config ServerConfig, chain core.Blockchainer) *Server { peers: make(map[Peer]bool), } + if s.MinPeers <= 0 { + log.WithFields(log.Fields{ + "MinPeers configured": s.MinPeers, + "MinPeers actual": defaultMinPeers, + }).Info("bad MinPeers configured, using the default value") + s.MinPeers = defaultMinPeers + } + s.transport = NewTCPTransport(s, fmt.Sprintf(":%d", config.ListenTCP)) s.discovery = NewDefaultDiscovery( s.DialTimeout,