From d78b76ddb44d5f45a0c0bbfbcc2f014c0f0bac3a Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Fri, 30 Jan 2015 23:06:11 -0800 Subject: [PATCH] log(bitswap) add bitswap loggable --- exchange/bitswap/bitswap.go | 1 + exchange/bitswap/message/message.go | 8 ++++++++ 2 files changed, 9 insertions(+) diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index d3f935cfa..1117d7742 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -409,6 +409,7 @@ func (bs *bitswap) ReceiveError(err error) { // send strives to ensure that accounting is always performed when a message is // sent func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error { + defer log.EventBegin(ctx, "sendMessage", p, m).Done() if err := bs.network.SendMessage(ctx, p, m); err != nil { return errors.Wrap(err) } diff --git a/exchange/bitswap/message/message.go b/exchange/bitswap/message/message.go index 117758d9e..d02d82740 100644 --- a/exchange/bitswap/message/message.go +++ b/exchange/bitswap/message/message.go @@ -39,6 +39,8 @@ type BitSwapMessage interface { AddBlock(*blocks.Block) Exportable + + Loggable() map[string]interface{} } type Exportable interface { @@ -170,3 +172,9 @@ func (m *impl) ToNet(w io.Writer) error { } return nil } + +func (m *impl) Loggable() map[string]interface{} { + return map[string]interface{}{ + "wantlist": m.wantlist, + } +}