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

log(dht) add eventlog.Update event

Browse Source 
License: MIT
Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
This commit is contained in:
Brian Tiger Chow
2014-11-22 20:02:45 -08:00
parent 247fd676a3
commit b8c96b2505
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
routing/dht/dht.go
View File

@ -121,7 +121,7 @@ func (dht *IpfsDHT) Connect(ctx context.Context, npeer peer.Peer) (peer.Peer, er
return nil, fmt.Errorf("failed to ping newly connected peer: %s\n", err) return nil, fmt.Errorf("failed to ping newly connected peer: %s\n", err)
} }
dht.Update(npeer) dht.Update(ctx, npeer)
return npeer, nil return npeer, nil
} }
@ -150,7 +150,7 @@ func (dht *IpfsDHT) HandleMessage(ctx context.Context, mes msg.NetMessage) msg.N
} }
// update the peer (on valid msgs only) // update the peer (on valid msgs only)
dht.Update(mPeer) dht.Update(ctx, mPeer)
log.Event(ctx, "foo", dht.self, mPeer, pmes) log.Event(ctx, "foo", dht.self, mPeer, pmes)
@ -397,8 +397,8 @@ func (dht *IpfsDHT) putLocal(key u.Key, value []byte) error {
// Update signals to all routingTables to Update their last-seen status // Update signals to all routingTables to Update their last-seen status
// on the given peer. // on the given peer.
func (dht *IpfsDHT) Update(p peer.Peer) { func (dht *IpfsDHT) Update(ctx context.Context, p peer.Peer) {
log.Debugf("updating peer: %s latency = %f\n", p, p.GetLatency().Seconds()) log.Event(ctx, "updatePeer", p)
removedCount := 0 removedCount := 0
for _, route := range dht.routingTables { for _, route := range dht.routingTables {
removed := route.Update(p) removed := route.Update(p)

6
routing/dht/ext_test.go
View File

@ -129,7 +129,7 @@ func TestGetFailures(t *testing.T) {
d := NewDHT(ctx, local, peerstore, fn, fs, ds.NewMapDatastore()) d := NewDHT(ctx, local, peerstore, fn, fs, ds.NewMapDatastore())
other := makePeer(nil) other := makePeer(nil)
d.Update(other) d.Update(ctx, other)
// This one should time out // This one should time out
// u.POut("Timout Test\n") // u.POut("Timout Test\n")
@ -232,7 +232,7 @@ func TestNotFound(t *testing.T) {
var ps []peer.Peer var ps []peer.Peer
for i := 0; i < 5; i++ { for i := 0; i < 5; i++ {
ps = append(ps, _randPeer()) ps = append(ps, _randPeer())
d.Update(ps[i]) d.Update(ctx, ps[i])
} }
// Reply with random peers to every message // Reply with random peers to every message
@ -298,7 +298,7 @@ func TestLessThanKResponses(t *testing.T) {
var ps []peer.Peer var ps []peer.Peer
for i := 0; i < 5; i++ { for i := 0; i < 5; i++ {
ps = append(ps, _randPeer()) ps = append(ps, _randPeer())
d.Update(ps[i]) d.Update(ctx, ps[i])
} }
other := _randPeer() other := _randPeer()