opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-29 01:12:24 +08:00
Code Issues Projects Releases Wiki Activity

network.Find -> network.GetPeer

Browse Source
This commit is contained in:
Juan Batiz-Benet
2014-08-30 00:24:04 -07:00
committed by Brian Tiger Chow
parent 71ec4f91dc
commit 2563e9204c
3 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
routing/dht/dht.go
View File

@ -622,7 +622,7 @@ func (dht *IpfsDHT) addPeerList(key u.Key, peers []*PBDHTMessage_PBPeer) []*peer
continue
}
// Dont add someone who is already on the list
p := dht.network.Find(u.Key(prov.GetId()))
p := dht.network.GetPeer(u.Key(prov.GetId()))
if p == nil {
u.DOut("given provider %s was not in our network already.\n", peer.ID(prov.GetId()).Pretty())
var err error

2
swarm/interface.go
View File

@ -8,7 +8,7 @@ import (
)
type Network interface {
Find(u.Key) *peer.Peer
GetPeer(u.Key) *peer.Peer
Listen() error
ConnectNew(*ma.Multiaddr) (*peer.Peer, error)
GetConnection(id peer.ID, addr *ma.Multiaddr) (*peer.Peer, error)

3
swarm/swarm.go
View File

@ -390,7 +390,8 @@ func (s *Swarm) muxChan(ch *Chan, typ PBWrapper_MessageType) {
}
}
func (s *Swarm) Find(key u.Key) *peer.Peer {
// GetPeer returns the peer in the swarm with given key id.
func (s *Swarm) GetPeer(key u.Key) *peer.Peer {
s.connsLock.RLock()
defer s.connsLock.RUnlock()
conn, found := s.conns[key]