X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fsp.go;h=a1f51ebf80276b143675159248c97514ba621494;hb=e1158505e1142cd38564e3f2b3c3d240dee1ea6a;hp=7e74823e93fdb8bb4094f227ff82134fa094d55d;hpb=aedcfb28a36dd95e47ec093e2c3048146baf163e;p=nncp.git diff --git a/src/sp.go b/src/sp.go index 7e74823..a1f51eb 100644 --- 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