From 68ccdfd4089291057bbb6606e1df7bfee01ddd99 Mon Sep 17 00:00:00 2001 From: Dmitry Krylov Date: Tue, 4 Jan 2022 17:58:34 +0300 Subject: [PATCH] Removed extra check --- worker/agent.go | 4 ---- 1 file changed, 4 deletions(-) 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