From e9d42947a6922ce2f0aa9f9bcab4ead167735bc9 Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Fri, 3 May 2019 13:38:20 +0300 Subject: better status --- static_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'static_pool.go') 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) } -- cgit v1.2.3