diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/events/pool_events.go | 1 | ||||
| -rwxr-xr-x | pkg/pool/static_pool.go | 1 | ||||
| -rwxr-xr-x | pkg/transport/pipe/pipe_factory.go | 4 |
3 files changed, 0 insertions, 6 deletions
diff --git a/pkg/events/pool_events.go b/pkg/events/pool_events.go index c569a5a8..e7b451e0 100644 --- a/pkg/events/pool_events.go +++ b/pkg/events/pool_events.go @@ -1,6 +1,5 @@ package events -// TODO event numbers const ( // EventWorkerConstruct thrown when new worker is spawned. EventWorkerConstruct P = iota + 10000 diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go index 129c6f7d..06005d98 100755 --- a/pkg/pool/static_pool.go +++ b/pkg/pool/static_pool.go @@ -153,7 +153,6 @@ func (sp *StaticPool) Exec(p payload.Payload) (payload.Payload, error) { } // worker want's to be terminated - // TODO careful with toString(rsp.Context) if len(rsp.Body) == 0 && toString(rsp.Context) == StopRequest { sp.stopWorker(w) return sp.Exec(p) diff --git a/pkg/transport/pipe/pipe_factory.go b/pkg/transport/pipe/pipe_factory.go index 0709413f..19f4f92d 100755 --- a/pkg/transport/pipe/pipe_factory.go +++ b/pkg/transport/pipe/pipe_factory.go @@ -42,7 +42,6 @@ func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, lis return } - // TODO why out is in? in, err := cmd.StdoutPipe() if err != nil { c <- SpawnResult{ @@ -52,7 +51,6 @@ func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, lis return } - // TODO why in is out? out, err := cmd.StdinPipe() if err != nil { c <- SpawnResult{ @@ -119,13 +117,11 @@ func (f *Factory) SpawnWorker(cmd *exec.Cmd, listeners ...events.Listener) (*wor return nil, errors.E(op, err) } - // TODO why out is in? in, err := cmd.StdoutPipe() if err != nil { return nil, errors.E(op, err) } - // TODO why in is out? out, err := cmd.StdinPipe() if err != nil { return nil, errors.E(op, err) |