increase queue size

OdyseeTeam · Oct 26, 2020 · 56e22f4 · 56e22f4
1 parent dbd19af
commit 56e22f4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/daemon/jobs/claimtriesync.go b/daemon/jobs/claimtriesync.go
@@ -164,7 +164,7 @@ func SetControllingClaimForNames(claims model.ClaimSlice, atHeight uint64) error
 		names[claim.Name] = claim.Name
 	}
 	printDebug("ClaimTrieSync: Finished making name map...[", len(names), "]")
-	setControllingQueue := make(chan string, 100)
+	setControllingQueue := make(chan string, 1000)
 	initControllingWorkers(runtime.NumCPU()-1, setControllingQueue, &controlwg, atHeight)
 	for _, name := range names {
 		setControllingQueue <- name
@@ -211,7 +211,7 @@ func SyncClaims(claims model.ClaimSlice) error {
 
 	printDebug("ClaimTrieSync: claim  update started... ")
 	syncwg := sync.WaitGroup{}
-	processingQueue := make(chan lbrycrd.Claim, 100)
+	processingQueue := make(chan lbrycrd.Claim, 1000)
 	initSyncWorkers(runtime.NumCPU()-1, processingQueue, &syncwg)
 	for i, claim := range claims {
 		if i%1000 == 0 {