From 02f6b66e8b592fb44d0b1a2e22a4e023d7dc95e4 Mon Sep 17 00:00:00 2001 From: zelig Date: Fri, 19 May 2017 16:56:44 -0700 Subject: [PATCH] swarm/network/simulations: overlay --- swarm/network/simulations/overlay.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/swarm/network/simulations/overlay.go b/swarm/network/simulations/overlay.go index c1ada22405..f14901ef83 100644 --- a/swarm/network/simulations/overlay.go +++ b/swarm/network/simulations/overlay.go @@ -46,13 +46,15 @@ func (s *Simulation) NewService(id *adapters.NodeId, snapshot []byte) []node.Ser kp := network.NewKadParams() kp.MinProxBinSize = 2 - kp.MaxBinSize = 8 - kp.MinBinSize = 2 + kp.MaxBinSize = 4 + kp.MinBinSize = 1 kp.MaxRetries = 1000 kp.RetryExponent = 2 kp.RetryInterval = 1000 + kp.PruneInterval = 2000 kad := network.NewKademlia(addr.Over(), kp) - + ticker := time.NewTicker(time.Duration(kad.PruneInterval) * time.Millisecond) + kad.Prune(ticker.C) hp := network.NewHiveParams() hp.KeepAliveInterval = 3 * time.Second @@ -94,7 +96,7 @@ func setupMocker(net *simulations.Network) []*adapters.NodeId { conf := net.Config() conf.DefaultService = "overlay" - nodeCount := 50 + nodeCount := 60 ids := make([]*adapters.NodeId, nodeCount) for i := 0; i < nodeCount; i++ { node, err := net.NewNode()