diff --git a/worker/agent.go b/worker/agent.go index 9befa9c..7385211 100644 --- a/worker/agent.go +++ b/worker/agent.go @@ -66,6 +66,7 @@ func (a *agent) work() { } else if( err == io.EOF ){ a.disconnect_error(err) + break } a.worker.err(err) // If it is unexpected error and the connection wasn't