aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/network/stream/delivery_test.go
diff options
context:
space:
mode:
authorFerenc Szabo <frncmx@gmail.com>2019-01-06 18:58:57 +0800
committerViktor TrĂ³n <viktor.tron@gmail.com>2019-01-06 18:58:57 +0800
commitfe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4 (patch)
treea23d6d5014d1b81d60e741b15e4616d4f18116a7 /swarm/network/stream/delivery_test.go
parent072c95fb74ac108e93207a8052e641cfaf863105 (diff)
downloadgo-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar.gz
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar.bz2
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar.lz
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar.xz
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.tar.zst
go-tangerine-fe03b76ffe9f9d48b09f4d93f18fae1e5ad4c1f4.zip
A few minor code inspection fixes (#18393)
* swarm/network: fix code inspection problems - typos - redundant import alias * p2p/simulations: fix code inspection problems - typos - unused function parameters - redundant import alias - code style issue: snake case * swarm/network: fix unused method parameters inspections
Diffstat (limited to 'swarm/network/stream/delivery_test.go')
-rw-r--r--swarm/network/stream/delivery_test.go24
1 files changed, 12 insertions, 12 deletions
diff --git a/swarm/network/stream/delivery_test.go b/swarm/network/stream/delivery_test.go
index 5c1f8c251..04a4bb077 100644
--- a/swarm/network/stream/delivery_test.go
+++ b/swarm/network/stream/delivery_test.go
@@ -442,17 +442,17 @@ func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) {
}
func TestDeliveryFromNodes(t *testing.T) {
- testDeliveryFromNodes(t, 2, 1, dataChunkCount, true)
- testDeliveryFromNodes(t, 2, 1, dataChunkCount, false)
- testDeliveryFromNodes(t, 4, 1, dataChunkCount, true)
- testDeliveryFromNodes(t, 4, 1, dataChunkCount, false)
- testDeliveryFromNodes(t, 8, 1, dataChunkCount, true)
- testDeliveryFromNodes(t, 8, 1, dataChunkCount, false)
- testDeliveryFromNodes(t, 16, 1, dataChunkCount, true)
- testDeliveryFromNodes(t, 16, 1, dataChunkCount, false)
+ testDeliveryFromNodes(t, 2, dataChunkCount, true)
+ testDeliveryFromNodes(t, 2, dataChunkCount, false)
+ testDeliveryFromNodes(t, 4, dataChunkCount, true)
+ testDeliveryFromNodes(t, 4, dataChunkCount, false)
+ testDeliveryFromNodes(t, 8, dataChunkCount, true)
+ testDeliveryFromNodes(t, 8, dataChunkCount, false)
+ testDeliveryFromNodes(t, 16, dataChunkCount, true)
+ testDeliveryFromNodes(t, 16, dataChunkCount, false)
}
-func testDeliveryFromNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck bool) {
+func testDeliveryFromNodes(t *testing.T, nodes, chunkCount int, skipCheck bool) {
sim := simulation.New(map[string]simulation.ServiceFunc{
"streamer": func(ctx *adapters.ServiceContext, bucket *sync.Map) (s node.Service, cleanup func(), err error) {
node := ctx.Config.Node()
@@ -609,7 +609,7 @@ func BenchmarkDeliveryFromNodesWithoutCheck(b *testing.B) {
b.Run(
fmt.Sprintf("nodes=%v,chunks=%v", i, chunks),
func(b *testing.B) {
- benchmarkDeliveryFromNodes(b, i, 1, chunks, true)
+ benchmarkDeliveryFromNodes(b, i, chunks, true)
},
)
}
@@ -622,14 +622,14 @@ func BenchmarkDeliveryFromNodesWithCheck(b *testing.B) {
b.Run(
fmt.Sprintf("nodes=%v,chunks=%v", i, chunks),
func(b *testing.B) {
- benchmarkDeliveryFromNodes(b, i, 1, chunks, false)
+ benchmarkDeliveryFromNodes(b, i, chunks, false)
},
)
}
}
}
-func benchmarkDeliveryFromNodes(b *testing.B, nodes, conns, chunkCount int, skipCheck bool) {
+func benchmarkDeliveryFromNodes(b *testing.B, nodes, chunkCount int, skipCheck bool) {
sim := simulation.New(map[string]simulation.ServiceFunc{
"streamer": func(ctx *adapters.ServiceContext, bucket *sync.Map) (s node.Service, cleanup func(), err error) {
node := ctx.Config.Node()