From 971cbf747ae3d85d2e9ec9f291e6907807c49822 Mon Sep 17 00:00:00 2001 From: Will Scott Date: Tue, 14 Apr 2020 16:01:25 -0700 Subject: [PATCH] test passes --- test/integration/wan_lan_dht_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/test/integration/wan_lan_dht_test.go b/test/integration/wan_lan_dht_test.go index 2ecee82b2..17714e6c5 100644 --- a/test/integration/wan_lan_dht_test.go +++ b/test/integration/wan_lan_dht_test.go @@ -7,13 +7,13 @@ import ( "math" "math/rand" "net" - "os" "testing" "time" "github.com/ipfs/go-cid" "github.com/ipfs/go-ipfs/core" mock "github.com/ipfs/go-ipfs/core/mock" + libp2p2 "github.com/ipfs/go-ipfs/core/node/libp2p" corenet "github.com/libp2p/go-libp2p-core/network" "github.com/libp2p/go-libp2p-core/peerstore" @@ -93,8 +93,9 @@ func RunDHTConnectivity(conf testutil.LatencyConfig, numPeers int) error { defer connCtxCancel() for i := 0; i < numPeers; i++ { wanPeer, err := core.NewNode(ctx, &core.BuildCfg{ - Online: true, - Host: mock.MockHostOption(mn), + Online: true, + Routing: libp2p2.DHTServerOption, + Host: mock.MockHostOption(mn), }) if err != nil { return err @@ -190,7 +191,6 @@ StartupWait: return fmt.Errorf("Unexpected lan peer provided record") } - fmt.Fprintf(os.Stderr, "moving on to WAN.\n") // Now, connect with a wan peer. for _, p := range wanPeers { if _, err := mn.LinkPeers(testPeer.Identity, p.Identity); err != nil { @@ -203,7 +203,7 @@ StartupWait: return err } - startupCtx, startupCancel = context.WithTimeout(ctx, time.Second*60*5) + startupCtx, startupCancel = context.WithTimeout(ctx, time.Second*60) WanStartupWait: for { select {