diff options
| -rwxr-xr-x | pkg/pool/static_pool_test.go | 2 | ||||
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 4 | ||||
| -rwxr-xr-x | rr | bin | 32768 -> 0 bytes |
3 files changed, 5 insertions, 1 deletions
diff --git a/pkg/pool/static_pool_test.go b/pkg/pool/static_pool_test.go index 65e10119..6ffb05b3 100755 --- a/pkg/pool/static_pool_test.go +++ b/pkg/pool/static_pool_test.go @@ -454,7 +454,7 @@ func Test_Static_Pool_Handle_Dead(t *testing.T) { pipe.NewPipeFactory(), Config{ NumWorkers: 5, - AllocateTimeout: time.Second, + AllocateTimeout: time.Second * 100, DestroyTimeout: time.Second, }, ) diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 1e229d9d..d065bae5 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -54,6 +54,10 @@ func (ww *workerWatcher) Get(ctx context.Context) (worker.SyncWorker, error) { } // ========================================================= // SLOW PATH + // Put worker back (no matter it's state, it will be killed next) + if w != nil { + ww.stack.Push(w) + } // no free workers in the stack // try to continuously get free one for { Binary files differ |