opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-09-09 23:42:20 +08:00
Code Issues Projects Releases Wiki Activity

add peer info after FindPeer RPC

Browse Source 
fix ping test
This commit is contained in:
Jeromy
2015-01-09 22:37:13 +00:00
parent 566a86f5d4
commit 50c8561bdd
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
core/commands/ping.go
View File

@ -110,6 +110,7 @@ send pings, wait for pongs, and print out round-trip latency information.
}
ctx, _ := context.WithTimeout(context.Background(), kPingTimeout)
p, err := n.Routing.FindPeer(ctx, peerID)
n.Peerstore.AddPeerInfo(p)
if err != nil {
outChan <- &PingResult{Text: "Peer lookup error!"}
outChan <- &PingResult{Text: err.Error()}

4
routing/dht/dht_test.go
View File

@ -116,12 +116,12 @@ func TestPing(t *testing.T) {
//Test that we can ping the node
ctxT, _ := context.WithTimeout(ctx, 100*time.Millisecond)
if err := dhtA.Ping(ctxT, peerB); err != nil {
if _, err := dhtA.Ping(ctxT, peerB); err != nil {
t.Fatal(err)
}
ctxT, _ = context.WithTimeout(ctx, 100*time.Millisecond)
if err := dhtB.Ping(ctxT, peerA); err != nil {
if _, err := dhtB.Ping(ctxT, peerA); err != nil {
t.Fatal(err)
}
}