From: Sergey Matveev <stargrave@stargrave.org>
Date: Fri, 9 Jul 2021 11:02:25 +0000 (+0300)
Subject: Deleted hasher must send checker task too
X-Git-Tag: v7.2.1^2~5
X-Git-Url: http://www.git.cypherpunks.su/?a=commitdiff_plain;h=045933f462cd72677f744cd83d42f4abf5f827c7;p=nncp.git

Deleted hasher must send checker task too
---

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"})