luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

consul: Update buffer sizes

This commit is contained in:
Armon Dadgar 2018-08-08 10:26:58 -07:00
parent 8dd1d92283
commit a343392f63
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
agent/consul/server.go
View File

@ -73,6 +73,15 @@ const (
// raftRemoveGracePeriod is how long we wait to allow a RemovePeer // raftRemoveGracePeriod is how long we wait to allow a RemovePeer
// to replicate to gracefully leave the cluster. // to replicate to gracefully leave the cluster.
raftRemoveGracePeriod = 5 * time.Second raftRemoveGracePeriod = 5 * time.Second
// serfEventChSize is the size of the buffered channel to get Serf
// events. If this is exhausted we will block Serf and Memberlist.
serfEventChSize = 2048
// reconcileChSize is the size of the buffered channel reconcile updates
// from Serf with the Catalog. If this is exhausted we will drop updates,
// and wait for a periodic reconcile.
reconcileChSize = 256
) )
var ( var (
@ -301,11 +310,11 @@ func NewServerLogger(config *Config, logger *log.Logger, tokens *token.Store) (*
config: config, config: config,
tokens: tokens, tokens: tokens,
connPool: connPool, connPool: connPool,
eventChLAN: make(chan serf.Event, 256), eventChLAN: make(chan serf.Event, serfEventChSize),
eventChWAN: make(chan serf.Event, 256), eventChWAN: make(chan serf.Event, serfEventChSize),
logger: logger, logger: logger,
leaveCh: make(chan struct{}), leaveCh: make(chan struct{}),
reconcileCh: make(chan serf.Member, 32), reconcileCh: make(chan serf.Member, reconcileChSize),
router: router.NewRouter(logger, config.Datacenter), router: router.NewRouter(logger, config.Datacenter),
rpcServer: rpc.NewServer(), rpcServer: rpc.NewServer(),
rpcTLS: incomingTLS, rpcTLS: incomingTLS,