diff options
Diffstat (limited to 'pool/supervisor_pool.go')
| -rwxr-xr-x | pool/supervisor_pool.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/pool/supervisor_pool.go b/pool/supervisor_pool.go index 5f87c8a4..0502dc9a 100755 --- a/pool/supervisor_pool.go +++ b/pool/supervisor_pool.go @@ -51,6 +51,12 @@ func (sp *supervised) execWithTTL(_ context.Context, _ *payload.Payload) (*paylo panic("used to satisfy pool interface") } +func (sp *supervised) Reset(ctx context.Context) error { + sp.mu.Lock() + defer sp.mu.Unlock() + return sp.pool.Reset(ctx) +} + func (sp *supervised) Exec(rqs *payload.Payload) (*payload.Payload, error) { const op = errors.Op("supervised_exec_with_context") if sp.cfg.ExecTTL == 0 { |