From 9b70f75aa9797b817ecd17bca25301aaefe7721e Mon Sep 17 00:00:00 2001 From: Justin Santa Barbara Date: Sat, 21 Jul 2018 16:22:51 -0400 Subject: [PATCH] Remove gossip connection limit entirely This simply turns off gossip connection limits, so we shouldn't ever have to manually configure them. Follow on to #5077 --- protokube/pkg/gossip/mesh/gossip.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/protokube/pkg/gossip/mesh/gossip.go b/protokube/pkg/gossip/mesh/gossip.go index 336a560239..da2d9385f1 100644 --- a/protokube/pkg/gossip/mesh/gossip.go +++ b/protokube/pkg/gossip/mesh/gossip.go @@ -41,14 +41,16 @@ type MeshGossiper struct { func NewMeshGossiper(listen string, channelName string, nodeName string, password []byte, seeds gossip.SeedProvider) (*MeshGossiper, error) { - connLimit := 64 + connLimit := 0 // 0 means no limit gossipDnsConnLimit := os.Getenv("GOSSIP_DNS_CONN_LIMIT") if gossipDnsConnLimit != "" { limit, err := strconv.Atoi(gossipDnsConnLimit) if err != nil { - return nil, fmt.Errorf("cannot parse env GOSSIP_DNS_CONN_LIMIT value: %v, err:%v", gossipDnsConnLimit, err) + // Continue with the default value + glog.Warningf("cannot parse env GOSSIP_DNS_CONN_LIMIT value %q", gossipDnsConnLimit) + } else { + connLimit = limit } - connLimit = limit } glog.Infof("gossip dns connection limit is:%d", connLimit)