From 4f52a24302182cc080c372a9eca907a3bfab256c Mon Sep 17 00:00:00 2001 From: Matee ullah Date: Fri, 12 Sep 2025 19:37:40 +0500 Subject: [PATCH] concurrency params --- p2p/kademlia/dht.go | 2 +- supernode/services/cascade/adaptors/p2p.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/p2p/kademlia/dht.go b/p2p/kademlia/dht.go index 493f90f1..60150ceb 100644 --- a/p2p/kademlia/dht.go +++ b/p2p/kademlia/dht.go @@ -1697,7 +1697,7 @@ func (s *DHT) IterateBatchStore(ctx context.Context, values [][]byte, typ int, i func (s *DHT) batchStoreNetwork(ctx context.Context, values [][]byte, nodes map[string]*Node, storageMap map[string][]int, typ int) chan *MessageWithError { responses := make(chan *MessageWithError, len(nodes)) - maxStore := 16 + maxStore := 48 if ln := len(nodes); ln < maxStore { maxStore = ln } diff --git a/supernode/services/cascade/adaptors/p2p.go b/supernode/services/cascade/adaptors/p2p.go index bc5697e3..75c1bc39 100644 --- a/supernode/services/cascade/adaptors/p2p.go +++ b/supernode/services/cascade/adaptors/p2p.go @@ -20,7 +20,7 @@ import ( ) const ( - loadSymbolsBatchSize = 2500 + loadSymbolsBatchSize = 5000 // Minimum first-pass coverage to store before returning from Register (percent) storeSymbolsPercent = 18 )