]> Cypherpunks.ru repositories - nncp.git/commitdiff
Deleted hasher must send checker task too
authorSergey Matveev <stargrave@stargrave.org>
Fri, 9 Jul 2021 11:02:25 +0000 (14:02 +0300)
committerSergey Matveev <stargrave@stargrave.org>
Fri, 9 Jul 2021 12:18:38 +0000 (15:18 +0300)
src/sp.go

index 269f6ba4a34101296670555a2078c1da0e47aa52..a8b5f0bbaa9385694e0110bec5ddd07de6e4b95a 100644 (file)
--- 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"})