diff --git a/pkg/controlsvc/controlsvc.go b/pkg/controlsvc/controlsvc.go index 7516681ca..77e511c5e 100644 --- a/pkg/controlsvc/controlsvc.go +++ b/pkg/controlsvc/controlsvc.go @@ -140,8 +140,8 @@ func (s *SockControl) ReadFromConn(message string, out io.Writer, io Copier) err if err.Error() != "EOF" { MainInstance.nc.GetLogger().Error("Error reading from %v: %v \n", connectType, err) } + break - } data += response MainInstance.nc.GetLogger().Debug("Response from %v: %v", connectType, response) diff --git a/pkg/workceptor/command.go b/pkg/workceptor/command.go index 6f5872328..a37d7ba29 100644 --- a/pkg/workceptor/command.go +++ b/pkg/workceptor/command.go @@ -130,8 +130,8 @@ func commandRunner(command string, params string, unitdir string) error { if err.Error() != "EOF" { MainInstance.nc.GetLogger().Error("Error reading work unit %v stdin: %v\n", workUnitID, err) } + break - } data += response MainInstance.nc.GetLogger().Debug("Work unit %v stdin: %v", workUnitID, response)