]> Cypherpunks.ru repositories - nncp.git/blobdiff - src/sp.go
Check existing .nock when call initiated
[nncp.git] / src / sp.go
index 7e74823e93fdb8bb4094f227ff82134fa094d55d..a1f51ebf80276b143675159248c97514ba621494 100644 (file)
--- a/src/sp.go
+++ b/src/sp.go
@@ -658,6 +658,17 @@ func (state *SPState) StartWorkers(
        }
        if !state.NoCK {
                spCheckerOnce.Do(func() { go SPChecker(state.Ctx) })
+               go func() {
+                       for job := range state.Ctx.JobsNoCK(state.Node.Id) {
+                               if job.PktEnc.Nice <= state.Nice {
+                                       spCheckerTasks <- SPCheckerTask{
+                                               nodeId: state.Node.Id,
+                                               hsh:    job.HshValue,
+                                               done:   state.payloads,
+                                       }
+                               }
+                       }
+               }()
        }
 
        // Remaining handshake payload sending