diff options
author | Valery Piashchynski <[email protected]> | 2020-10-26 11:50:12 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-10-26 11:50:12 +0300 |
commit | 9aae9e2009bad07ebdee73e1c6cf56901d07880a (patch) | |
tree | 0ad9537bd438c63719fb83343ab77fc4ab34eb83 /static_pool.go | |
parent | db7695463e85faf3fba6a2767b2dfa6ef916785d (diff) |
Fix linters warnings
Diffstat (limited to 'static_pool.go')
-rwxr-xr-x | static_pool.go | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/static_pool.go b/static_pool.go index 31923134..4ecbdd41 100755 --- a/static_pool.go +++ b/static_pool.go @@ -3,10 +3,11 @@ package roadrunner import ( "context" "fmt" - "github.com/spiral/roadrunner/v2/util" "os/exec" "sync" + "github.com/spiral/roadrunner/v2/util" + "github.com/pkg/errors" ) @@ -35,7 +36,7 @@ type StaticPool struct { ww *workerWatcher // supervises memory and TTL of workers - sp *supervisedPool + // sp *supervisedPool } // NewPool creates new worker pool and task multiplexer. StaticPool will initiate with one worker. @@ -74,8 +75,8 @@ func NewPool(ctx context.Context, cmd func() *exec.Cmd, factory Factory, cfg Con } // todo: implement - //p.sp = newPoolWatcher(p, p.events, p.cfg.Supervisor) - //p.sp.Start() + // p.sp = newPoolWatcher(p, p.events, p.cfg.Supervisor) + // p.sp.Start() return p, nil } @@ -167,7 +168,7 @@ func (p *StaticPool) Exec(rqs Payload) (Payload, error) { } // Exec one task with given payload and context, returns result or error. -//func (p *StaticPool) ExecWithContext(ctx context.Context, rqs Payload) (Payload, error) { +// func (p *StaticPool) ExecWithContext(ctx context.Context, rqs Payload) (Payload, error) { // // todo: why TODO passed here? // getWorkerCtx, cancel := context.WithTimeout(context.TODO(), p.cfg.AllocateTimeout) // defer cancel() @@ -235,7 +236,7 @@ func (p *StaticPool) Exec(rqs Payload) (Payload, error) { // } // // return rsp, nil -//} +// } // Destroy all underlying stack (but let them to complete the task). func (p *StaticPool) Destroy(ctx context.Context) { |