diff options
author | Elad <theman@elad.im> | 2019-01-25 00:23:34 +0800 |
---|---|---|
committer | Rafael Matias <rafael@skyle.net> | 2019-02-19 19:56:31 +0800 |
commit | 2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0 (patch) | |
tree | 597df951ae6ea5389bdb26b7199c9a299a155acb /swarm/network/stream/common_test.go | |
parent | e247dcc141a5d1c9129b987a5f164e9df29be951 (diff) | |
download | dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.gz dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.bz2 dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.lz dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.xz dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.zst dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.zip |
p2p/testing, swarm: remove unused testing.T in protocol tester (#18500)
(cherry picked from commit 2abeb35d5425d72c2f7fdfe4209f7a94fac52a8e)
Diffstat (limited to 'swarm/network/stream/common_test.go')
-rw-r--r-- | swarm/network/stream/common_test.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/swarm/network/stream/common_test.go b/swarm/network/stream/common_test.go index 29b917d39..7b2962608 100644 --- a/swarm/network/stream/common_test.go +++ b/swarm/network/stream/common_test.go @@ -27,7 +27,6 @@ import ( "os" "strings" "sync/atomic" - "testing" "time" "github.com/ethereum/go-ethereum/log" @@ -67,7 +66,7 @@ func init() { log.Root().SetHandler(log.LvlFilterHandler(log.Lvl(*loglevel), log.StreamHandler(colorable.NewColorableStderr(), log.TerminalFormat(true)))) } -func newStreamerTester(t *testing.T, registryOptions *RegistryOptions) (*p2ptest.ProtocolTester, *Registry, *storage.LocalStore, func(), error) { +func newStreamerTester(registryOptions *RegistryOptions) (*p2ptest.ProtocolTester, *Registry, *storage.LocalStore, func(), error) { // setup addr := network.RandomAddr() // tested peers peer address to := network.NewKademlia(addr.OAddr, network.NewKadParams()) @@ -102,7 +101,7 @@ func newStreamerTester(t *testing.T, registryOptions *RegistryOptions) (*p2ptest streamer.Close() removeDataDir() } - protocolTester := p2ptest.NewProtocolTester(t, addr.ID(), 1, streamer.runProtocol) + protocolTester := p2ptest.NewProtocolTester(addr.ID(), 1, streamer.runProtocol) err = waitForPeers(streamer, 1*time.Second, 1) if err != nil { |