opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-03 13:00:37 +08:00
Code Issues Projects Releases Wiki Activity

fix: don't check routingbackend for value

Browse Source
This commit is contained in:
Brian Tiger Chow
2015-02-02 02:05:40 -08:00
parent ca268b789e
commit d1df4095ea
1 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
routing/grandcentral/server.go
View File

@ -168,17 +168,6 @@ func getRoutingProviders(local peer.ID, ds datastore.Datastore, k util.Key) ([]*
e := log.EventBegin(context.Background(), "getProviders", &k) e := log.EventBegin(context.Background(), "getProviders", &k)
defer e.Done() defer e.Done()
var providers []*dhtpb.Message_Peer var providers []*dhtpb.Message_Peer
exists, err := ds.Has(k.DsKey()) // TODO store values in a local datastore?
if err == nil && exists {
pri := []dhtpb.PeerRoutingInfo{
dhtpb.PeerRoutingInfo{
// Connectedness: TODO how is connectedness defined for the local node
PeerInfo: peer.PeerInfo{ID: local},
},
}
providers = append(providers, dhtpb.PeerRoutingInfosToPBPeers(pri)...)
}
pkey := datastore.KeyWithNamespaces([]string{"routing", "providers", k.String()}) // TODO key fmt pkey := datastore.KeyWithNamespaces([]string{"routing", "providers", k.String()}) // TODO key fmt
if v, err := ds.Get(pkey); err == nil { if v, err := ds.Get(pkey); err == nil {
if data, ok := v.([]byte); ok { if data, ok := v.([]byte); ok {