diff options
author | Wolfy-J <[email protected]> | 2019-05-03 13:38:20 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2019-05-03 13:38:20 +0300 |
commit | e9d42947a6922ce2f0aa9f9bcab4ead167735bc9 (patch) | |
tree | 38f84e1b1c26d15f4815f1e4509c0fc9031e6f87 /static_pool.go | |
parent | e52c29d081a14f0ec4efb01da11c69215ea40a6a (diff) |
better status
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) } |