luxolus/open-nomad
2
0
Fork 0
Code Issues 1 Pull requests Packages Releases Wiki Activity

Increase Alloc channel buffers

Browse source
This commit is contained in:
Alex Dadgar 2016-02-18 20:43:48 -08:00
parent 09be6c32e9
commit 96fd272422
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
client/alloc_runner.go
View file

@ -77,7 +77,7 @@ func NewAllocRunner(logger *log.Logger, config *config.Config, updater AllocStat
tasks: make(map[string]*TaskRunner),
taskStates: copyTaskStates(alloc.TaskStates),
restored: make(map[string]struct{}),
updateCh: make(chan *structs.Allocation, 8),
updateCh: make(chan *structs.Allocation, 64),
destroyCh: make(chan struct{}),
waitCh: make(chan struct{}),
}

2
client/client.go
View file

@ -691,7 +691,7 @@ func (c *Client) run() {
go c.watchNodeUpdates()
// Watch for changes in allocations
allocUpdates := make(chan *allocUpdates, 1)
allocUpdates := make(chan *allocUpdates, 8)
go c.watchAllocations(allocUpdates)
for {