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 )