From 045933f462cd72677f744cd83d42f4abf5f827c7 Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Fri, 9 Jul 2021 14:02:25 +0300 Subject: [PATCH] Deleted hasher must send checker task too --- src/sp.go | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/src/sp.go b/src/sp.go index 269f6ba..a8b5f0b 100644 --- a/src/sp.go +++ b/src/sp.go @@ -1516,16 +1516,17 @@ func (state *SPState) ProcessSP(payload []byte) ([][]byte, error) { state.Lock() delete(state.infosTheir, *file.Hash) state.Unlock() - if hasherAndOffset != nil { - go func() { - spCheckerTasks <- SPCheckerTask{ - nodeId: state.Node.Id, - hsh: file.Hash, - mth: hasherAndOffset.mth, - done: state.payloads, - } - }() - } + go func() { + t := SPCheckerTask{ + nodeId: state.Node.Id, + hsh: file.Hash, + done: state.payloads, + } + if hasherAndOffset != nil { + t.mth = hasherAndOffset.mth + } + spCheckerTasks <- t + }() case SPTypeDone: lesp := append(les, LE{"Type", "done"}) -- 2.44.0