Add name to gossip agent when started from server

BBVA · Mar 7, 2019 · 436be7e · 436be7e
1 parent b7f8aa4
commit 436be7e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -127,6 +127,7 @@ func NewServer(conf *Config) (*Server, error) {
 	config := gossip.DefaultConfig()
 	config.BindAddr = conf.GossipAddr
 	config.Role = member.Server
+	config.NodeName = conf.NodeID
 	server.agent, err = gossip.NewAgent(config, nil)
 	if err != nil {
 		return nil, err
@@ -140,7 +141,7 @@ func NewServer(conf *Config) (*Server, error) {
 	}
 
 	// TODO: add queue size to config
-	server.agentsQueue = make(chan *protocol.Snapshot, 100000)
+	server.agentsQueue = make(chan *protocol.Snapshot, 2<<16)
 
 	// Create sender
 	server.sender = sender.NewSender(server.agent, sender.DefaultConfig(), server.signer)