log(bitswap) add bitswap loggable
Brian Tiger Chow committed
Jan 30, 2015 at 23:06 UTC
d78b76ddb44d5f45a0c0bbfbcc2f014c0f0bac3a
2 files changed
+9
exchange/bitswap/bitswap.go
+1
@@ -409,6 +409,7 @@ func (bs *bitswap) ReceiveError(err error) {
409
// send strives to ensure that accounting is always performed when a message is
410
// sent
411
func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error {
412
+ defer log.EventBegin(ctx, "sendMessage", p, m).Done()
413
if err := bs.network.SendMessage(ctx, p, m); err != nil {
414
return errors.Wrap(err)
415
}
exchange/bitswap/message/message.go
+8
@@ -39,6 +39,8 @@ type BitSwapMessage interface {
39
40
AddBlock(*blocks.Block)
41
Exportable
42
+
43
+ Loggable() map[string]interface{}
44
}
45
46
type Exportable interface {
@@ -170,3 +172,9 @@ func (m *impl) ToNet(w io.Writer) error {
172
}
173
return nil
174
}
175
+
176
+func (m *impl) Loggable() map[string]interface{} {
177
+ return map[string]interface{}{
178
+ "wantlist": m.wantlist,
179
+ }
180
+}