Revert "refactor(kademlia): remove hacky config usage (#3360)"

This reverts commit 9f93ee8.
ethersphere · Oct 20, 2022 · f78d98a · f78d98a
1 parent cc46f71
commit f78d98a
Show file tree

Hide file tree

Showing 5 changed files with 236 additions and 308 deletions.
diff --git a/pkg/topology/kademlia/export_test.go b/pkg/topology/kademlia/export_test.go
@@ -5,16 +5,17 @@
 package kademlia
 
 var (
-	PruneOversaturatedBinsFunc = func(k *Kad) func(uint8) {
+	TimeToRetry                 = &timeToRetry
+	SaturationPeers             = &saturationPeers
+	OverSaturationPeers         = &overSaturationPeers
+	BootnodeOverSaturationPeers = &bootNodeOverSaturationPeers
+	LowWaterMark                = &nnLowWatermark
+	PruneOversaturatedBinsFunc  = func(k *Kad) func(uint8) {
 		return k.pruneOversaturatedBins
 	}
 	GenerateCommonBinPrefixes = generateCommonBinPrefixes
-)
-
-const (
-	DefaultBitSuffixLength     = defaultBitSuffixLength
-	DefaultSaturationPeers     = defaultSaturationPeers
-	DefaultOverSaturationPeers = defaultOverSaturationPeers
+	PeerPingPollTime          = &peerPingPollTime
+	BitSuffixLength           = defaultBitSuffixLength
 )
 
 type PeerFilterFunc = peerFilterFunc
diff --git a/pkg/topology/kademlia/internal/metrics/metrics_test.go b/pkg/topology/kademlia/internal/metrics/metrics_test.go
@@ -30,8 +30,6 @@ func snapshot(t *testing.T, mc *metrics.Collector, sst time.Time, addr swarm.Add
 }
 
 func TestPeerMetricsCollector(t *testing.T) {
-	t.Parallel()
-
 	db, err := shed.NewDB("", nil)
 	if err != nil {
 		t.Fatal(err)

diff --git a/pkg/topology/kademlia/internal/waitnext/waitnext_test.go b/pkg/topology/kademlia/internal/waitnext/waitnext_test.go
@@ -15,7 +15,6 @@ import (
 )
 
 func TestSet(t *testing.T) {
-	t.Parallel()
 
 	waitNext := waitnext.New()