diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/static_pool.go b/static_pool.go index fa4ac027..5f60099a 100644 --- a/static_pool.go +++ b/static_pool.go @@ -173,7 +173,7 @@ func (p *StaticPool) Destroy() { var wg sync.WaitGroup for _, w := range p.Workers() { wg.Add(1) - w.markDisabled() + w.markInvalid() go func(w *Worker) { defer wg.Done() p.destroyWorker(w, nil) @@ -283,7 +283,7 @@ func (p *StaticPool) createWorker() (*Worker, error) { // gentry remove worker func (p *StaticPool) discardWorker(w *Worker, caused interface{}) { - w.markDisabled() + w.markInvalid() go p.destroyWorker(w, caused) } |