routing: use debugerror
Juan Batiz-Benet committed
Jan 2, 2015 at 08:36 UTC
ef182f11edd7bde103cf738cb5098689a1e060d1
1 file changed
+5
-4
routing/dht/routing.go
+5
-4
@@ -12,6 +12,7 @@ import (
12
pb "github.com/jbenet/go-ipfs/routing/dht/pb"
13
kb "github.com/jbenet/go-ipfs/routing/kbucket"
14
u "github.com/jbenet/go-ipfs/util"
15
+ errors "github.com/jbenet/go-ipfs/util/debugerror"
16
pset "github.com/jbenet/go-ipfs/util/peerset"
17
)
18
@@ -77,7 +78,7 @@ func (dht *IpfsDHT) GetValue(ctx context.Context, key u.Key) ([]byte, error) {
78
closest := dht.routingTable.NearestPeers(kb.ConvertKey(key), PoolSize)
79
if closest == nil || len(closest) == 0 {
80
log.Warning("Got no peers back from routing table!")
80
- return nil, kb.ErrLookupFailure
81
+ return nil, errors.Wrap(kb.ErrLookupFailure)
82
}
83
84
// setup the Query
@@ -154,7 +155,7 @@ func (dht *IpfsDHT) FindProviders(ctx context.Context, key u.Key) ([]peer.PeerIn
155
func (dht *IpfsDHT) getClosestPeers(ctx context.Context, key u.Key) (<-chan peer.ID, error) {
156
tablepeers := dht.routingTable.NearestPeers(kb.ConvertKey(key), AlphaValue)
157
if len(tablepeers) == 0 {
157
- return nil, kb.ErrLookupFailure
158
+ return nil, errors.Wrap(kb.ErrLookupFailure)
159
}
160
161
out := make(chan peer.ID, KValue)
@@ -299,7 +300,7 @@ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (peer.PeerInfo, er
300
301
closest := dht.routingTable.NearestPeers(kb.ConvertPeerID(id), AlphaValue)
302
if closest == nil || len(closest) == 0 {
302
- return peer.PeerInfo{}, kb.ErrLookupFailure
303
+ return peer.PeerInfo{}, errors.Wrap(kb.ErrLookupFailure)
304
}
305
306
// Sanity...
@@ -356,7 +357,7 @@ func (dht *IpfsDHT) FindPeersConnectedToPeer(ctx context.Context, id peer.ID) (<
357
358
closest := dht.routingTable.NearestPeers(kb.ConvertPeerID(id), AlphaValue)
359
if closest == nil || len(closest) == 0 {
359
- return nil, kb.ErrLookupFailure
360
+ return nil, errors.Wrap(kb.ErrLookupFailure)
361
}
362
363
// setup the Query