diff options
author | Valery Piashchynski <[email protected]> | 2022-01-12 00:28:16 +0300 |
---|---|---|
committer | GitHub <[email protected]> | 2022-01-12 00:28:16 +0300 |
commit | a191eac78092dda89dbcd19c7a3a171f6aafb71a (patch) | |
tree | 48db67c0329dc33f63bd9784fbcf50a410434ebe /pool/static_pool.go | |
parent | e4ee005938a388de4e4bbb9fad097b563989e158 (diff) | |
parent | 657e5969414419180af49e1440e91c0f271985da (diff) |
[#888]: bug(logger): the RR logger wasn't passed from the poolv2.7.0-rc.2
Diffstat (limited to 'pool/static_pool.go')
-rwxr-xr-x | pool/static_pool.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/pool/static_pool.go b/pool/static_pool.go index 019c34b2..dfd9ffd3 100755 --- a/pool/static_pool.go +++ b/pool/static_pool.go @@ -7,8 +7,8 @@ import ( "github.com/spiral/errors" "github.com/spiral/roadrunner/v2/events" + "github.com/spiral/roadrunner/v2/ipc" "github.com/spiral/roadrunner/v2/payload" - "github.com/spiral/roadrunner/v2/transport" "github.com/spiral/roadrunner/v2/utils" "github.com/spiral/roadrunner/v2/worker" workerWatcher "github.com/spiral/roadrunner/v2/worker_watcher" @@ -36,7 +36,7 @@ type StaticPool struct { cmd Command // creates and connects to stack - factory transport.Factory + factory ipc.Factory // manages worker states and TTLs ww Watcher @@ -49,7 +49,7 @@ type StaticPool struct { } // NewStaticPool creates new worker pool and task multiplexer. StaticPool will initiate with one worker. -func NewStaticPool(ctx context.Context, cmd Command, factory transport.Factory, cfg *Config, options ...Options) (Pool, error) { +func NewStaticPool(ctx context.Context, cmd Command, factory ipc.Factory, cfg *Config, options ...Options) (Pool, error) { if factory == nil { return nil, errors.Str("no factory initialized") } @@ -303,7 +303,7 @@ func (sp *StaticPool) takeWorker(ctxGetFree context.Context, op errors.Op) (work return w, nil } -func (sp *StaticPool) newPoolAllocator(ctx context.Context, timeout time.Duration, factory transport.Factory, cmd func() *exec.Cmd) worker.Allocator { +func (sp *StaticPool) newPoolAllocator(ctx context.Context, timeout time.Duration, factory ipc.Factory, cmd func() *exec.Cmd) worker.Allocator { return func() (worker.SyncWorker, error) { ctxT, cancel := context.WithTimeout(ctx, timeout) defer cancel() |