diff options
author | Wolfy-J <[email protected]> | 2018-01-06 20:28:14 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-01-06 20:28:14 +0300 |
commit | fc7b4269e32cb2a92c706c93a2ef496a333729fd (patch) | |
tree | 2611cd9a3af5376e55236e6cf66ad700c683db68 /balancer.go | |
parent | fa4bd78d9f7c5f74e8445374370927c742fc4e78 (diff) |
more tests
Diffstat (limited to 'balancer.go')
-rw-r--r-- | balancer.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/balancer.go b/balancer.go index 29fcd8d5..52479632 100644 --- a/balancer.go +++ b/balancer.go @@ -35,14 +35,14 @@ func (b *Balancer) Spawn(cmd func() *exec.Cmd, factory Factory, cfg Config) erro return nil } -// Execute one task with given payload and context, returns result and context or error. Must not be used once pool is -// being destroyed. -func (b *Balancer) Execute(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) { +// Exec one task with given payload and context, returns result and context +// or error. Must not be used once pool is being destroyed. +func (b *Balancer) Exec(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) { b.mu.Lock() pool := b.pool b.mu.Unlock() - return pool.Execute(payload, ctx) + return pool.Exec(payload, ctx) } // Workers return list of active workers. |