Skip to content

Commit 80ee4cd

Browse files
committed
fix: address review feedback
1 parent 04a93f4 commit 80ee4cd

File tree

4 files changed

+10
-29
lines changed

4 files changed

+10
-29
lines changed

p2p/host/relay/autorelay.go

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -247,15 +247,7 @@ func (ar *AutoRelay) discoverRelays(ctx context.Context) ([]peer.AddrInfo, error
247247

248248
ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
249249
defer cancel()
250-
var ret []peer.AddrInfo
251-
ch, err := ar.discover.FindPeers(ctx, RelayRendezvous, discovery.Limit(1000))
252-
if err != nil {
253-
return nil, err
254-
}
255-
for p := range ch {
256-
ret = append(ret, p)
257-
}
258-
return ret, nil
250+
return discovery.FindPeers(ctx, ar.discover, RelayRendezvous, discovery.Limit(1000))
259251
}
260252

261253
func (ar *AutoRelay) selectRelays(ctx context.Context, pis []peer.AddrInfo) []peer.AddrInfo {

p2p/host/routed/routed.go

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -118,21 +118,17 @@ func (rh *RoutedHost) findPeerAddrs(ctx context.Context, id peer.ID) ([]ma.Multi
118118

119119
if pi.ID != id {
120120
err = fmt.Errorf("routing failure: provided addrs for different peer")
121-
logRoutingErrDifferentPeers(ctx, id, pi.ID, err)
121+
log.Errorw("got wrong peer",
122+
"error", err,
123+
"wantedPeer", id,
124+
"gotPeer", pi.ID,
125+
)
122126
return nil, err
123127
}
124128

125129
return pi.Addrs, nil
126130
}
127131

128-
func logRoutingErrDifferentPeers(ctx context.Context, wanted, got peer.ID, err error) {
129-
lm := make(lgbl.DeferredMap)
130-
lm["error"] = err
131-
lm["wantedPeer"] = func() interface{} { return wanted.Pretty() }
132-
lm["gotPeer"] = func() interface{} { return got.Pretty() }
133-
// log.Event(ctx, "routingError", lm)
134-
}
135-
136132
func (rh *RoutedHost) ID() peer.ID {
137133
return rh.host.ID()
138134
}

p2p/net/mock/mock_test.go

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,6 @@ import (
1919
tnet "github.com/libp2p/go-libp2p-testing/net"
2020
)
2121

22-
// Unused code:
23-
//
24-
// func randPeer(t *testing.T) peer.ID {
25-
// p, err := test.RandPeerID()
26-
// if err != nil {
27-
// t.Fatal(err)
28-
// }
29-
// return p
30-
// }
31-
3222
func TestNetworkSetup(t *testing.T) {
3323
ctx := context.Background()
3424
id1 := tnet.RandIdentityOrFatal(t)

p2p/protocol/identify/id.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,10 @@ func (ids *IDService) identifyConn(c network.Conn, signal chan struct{}) {
373373

374374
// ok give the response to our handler.
375375
if err = msmux.SelectProtoOrFail(ID, s); err != nil {
376-
// log.Event(context.TODO(), "IdentifyOpenFailed", c.RemotePeer(), logging.Metadata{"error": err})
376+
log.Infow("failed negotiate identify protocol with peer",
377+
"peer", c.RemotePeer(),
378+
"error", err,
379+
)
377380
s.Reset()
378381
return
379382
}

0 commit comments

Comments
 (0)