summaryrefslogtreecommitdiff
path: root/static_pool.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2019-05-03 13:38:20 +0300
committerWolfy-J <[email protected]>2019-05-03 13:38:20 +0300
commite9d42947a6922ce2f0aa9f9bcab4ead167735bc9 (patch)
tree38f84e1b1c26d15f4815f1e4509c0fc9031e6f87 /static_pool.go
parente52c29d081a14f0ec4efb01da11c69215ea40a6a (diff)
better status
Diffstat (limited to 'static_pool.go')
-rw-r--r--static_pool.go4
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)
}