reduce concurrency (#181)

Author: mateeullahmalik

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 := 48
+	maxStore := 16
 	if ln := len(nodes); ln < maxStore {
 		maxStore = ln
 	}

p2p/kademlia/network.go

@@ -627,7 +627,7 @@ func (s *Network) Call(ctx context.Context, request *Message, isLong bool) (*Mes
 // ---- retryable RPC helpers -------------------------------------------------
 
 func (s *Network) rpcOnceWrapper(ctx context.Context, cw *connWrapper, remoteAddr string, data []byte, timeout time.Duration, msgType int) (*Message, error) {
-	writeDL := calcWriteDeadline(timeout, len(data), 2.0) // target ~2 MB/s
+	writeDL := calcWriteDeadline(timeout, len(data), 1.0) // target ~2 MB/s
 
 	retried := false
 	for {

supernode/services/cascade/adaptors/p2p.go

@@ -20,7 +20,7 @@ import (
 )
 
 const (
-	loadSymbolsBatchSize = 3000
+	loadSymbolsBatchSize = 2500
 	// Minimum first-pass coverage to store before returning from Register (percent)
 	storeSymbolsPercent = 18