diff --git a/dkron/agent.go b/dkron/agent.go index 310141648..6cb4e81d8 100644 --- a/dkron/agent.go +++ b/dkron/agent.go @@ -412,7 +412,7 @@ func (a *Agent) setupSerf() (*serf.Serf, error) { serfConfig.UserQuiescentPeriod = time.Second // Create a channel to listen for events from Serf - a.eventCh = make(chan serf.Event, 64) + a.eventCh = make(chan serf.Event, 2048) serfConfig.EventCh = a.eventCh // Start Serf diff --git a/go.sum b/go.sum index 52f8509e5..2a9942d1d 100644 --- a/go.sum +++ b/go.sum @@ -534,6 +534,7 @@ google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLY google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM= google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE= +google.golang.org/protobuf v1.21.0 h1:qdOKuR/EIArgaWNjetjgTzgVTAZ+S/WXVrq9HW9zimw= google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo= gopkg.in/airbrake/gobrake.v2 v2.0.9/go.mod h1:/h5ZAUhDkGaJfjzjKLSjv6zCL6O0LLBxU4K+aSYdM/U= gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=