]> Cypherpunks.ru repositories - nncp.git/commitdiff
Check existing .nock when call initiated
authorSergey Matveev <stargrave@stargrave.org>
Sat, 3 Jul 2021 18:53:37 +0000 (21:53 +0300)
committerSergey Matveev <stargrave@stargrave.org>
Sun, 4 Jul 2021 17:11:24 +0000 (20:11 +0300)
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