diff --git a/worker/agent.go b/worker/agent.go
index fc53399..fddaccf 100644
--- a/worker/agent.go
+++ b/worker/agent.go
@@ -95,10 +95,6 @@ func (a *agent) work() {
 			continue
 		}
 		for {
-			if a.worker.stopped {
-				return
-			}
-
 			if inpack, l, err = decodeInPack(data); err != nil {
 				a.worker.err(err)
 				leftdata = data