Removed extra check

2022-01-04 17:58:34 +03:00 · 2022-01-04 17:58:34 +03:00 · 68ccdfd408
commit 68ccdfd408
parent 3b13a9f51d
1 changed files with 0 additions and 4 deletions
--- 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