Merge branch 'beta' into stable

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)