fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-06-25 18:51:38 +00:00
Code Issues Projects Releases Wiki Activity

bitswap debug logging

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-03 06:15:50 -08:00
parent f47e5375a4
commit 2b1493b0cd
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dht_net.go
View File

@ -87,15 +87,11 @@ func (dht *IpfsDHT) sendRequest(ctx context.Context, p peer.ID, pmes *pb.Message
start := time.Now() start := time.Now()
log.Debugf("%s writing", dht.self)
if err := w.WriteMsg(pmes); err != nil { if err := w.WriteMsg(pmes); err != nil {
return nil, err return nil, err
} }
log.Event(ctx, "dhtSentMessage", dht.self, p, pmes) log.Event(ctx, "dhtSentMessage", dht.self, p, pmes)
log.Debugf("%s reading", dht.self)
defer log.Debugf("%s done", dht.self)
rpmes := new(pb.Message) rpmes := new(pb.Message)
if err := r.ReadMsg(rpmes); err != nil { if err := r.ReadMsg(rpmes); err != nil {
return nil, err return nil, err
@ -125,12 +121,10 @@ func (dht *IpfsDHT) sendMessage(ctx context.Context, p peer.ID, pmes *pb.Message
cw := ctxutil.NewWriter(ctx, s) // ok to use. we defer close stream in this func cw := ctxutil.NewWriter(ctx, s) // ok to use. we defer close stream in this func
w := ggio.NewDelimitedWriter(cw) w := ggio.NewDelimitedWriter(cw)
log.Debugf("%s writing", dht.self)
if err := w.WriteMsg(pmes); err != nil { if err := w.WriteMsg(pmes); err != nil {
return err return err
} }
log.Event(ctx, "dhtSentMessage", dht.self, p, pmes) log.Event(ctx, "dhtSentMessage", dht.self, p, pmes)
log.Debugf("%s done", dht.self)
return nil return nil
} }