diff --git a/discovery/gossiper.go b/discovery/gossiper.go index 6bbdce30..97f4808a 100644 --- a/discovery/gossiper.go +++ b/discovery/gossiper.go @@ -4,7 +4,6 @@ import ( "bytes" "errors" "fmt" - "runtime" "sync" "time" @@ -904,9 +903,7 @@ func (d *AuthenticatedGossiper) networkHandler() { // We'll use this validation to ensure that we process jobs in their // dependency order during parallel validation. - validationBarrier := routing.NewValidationBarrier( - runtime.NumCPU()*4, d.quit, - ) + validationBarrier := routing.NewValidationBarrier(1000, d.quit) for { select {