diff options
author | Valery Piashchynski <[email protected]> | 2020-12-21 10:27:10 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-12-21 10:27:10 +0300 |
commit | 2f71f79ac704ed95dad961677b6e602e38641b5d (patch) | |
tree | 7452bbedd1444079757a848ad07089bc6093561f /pkg/worker/sync_worker.go | |
parent | 3d4c75aadd9ffd0d46728f48f685de2e1bfc44bb (diff) |
Remove unused contex from interfaces. Update pool allocator.
Diffstat (limited to 'pkg/worker/sync_worker.go')
-rwxr-xr-x | pkg/worker/sync_worker.go | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/pkg/worker/sync_worker.go b/pkg/worker/sync_worker.go index eacb8a8a..11992f22 100755 --- a/pkg/worker/sync_worker.go +++ b/pkg/worker/sync_worker.go @@ -63,9 +63,10 @@ type wexec struct { } // Exec payload without TTL timeout. -func (tw *syncWorker) ExecWithContext(ctx context.Context, p payload.Payload) (payload.Payload, error) { - const op = errors.Op("ExecWithContext") +func (tw *syncWorker) ExecWithTimeout(ctx context.Context, p payload.Payload) (payload.Payload, error) { + const op = errors.Op("ExecWithTimeout") c := make(chan wexec, 1) + go func() { if len(p.Body) == 0 && len(p.Context) == 0 { c <- wexec{ @@ -211,8 +212,8 @@ func (tw *syncWorker) Wait() error { return tw.w.Wait() } -func (tw *syncWorker) Stop(ctx context.Context) error { - return tw.w.Stop(ctx) +func (tw *syncWorker) Stop() error { + return tw.w.Stop() } func (tw *syncWorker) Kill() error { |