From 2cfd8f0d8ee84e879946171f3c4c645e6877393e Mon Sep 17 00:00:00 2001 From: Anton Evangelatov Date: Mon, 11 Mar 2019 10:23:36 +0100 Subject: [PATCH] swarm/network: add metrics around send.offered.hashes --- cmd/swarm/swarm-smoke/upload_and_sync.go | 2 +- swarm/network/stream/peer.go | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/cmd/swarm/swarm-smoke/upload_and_sync.go b/cmd/swarm/swarm-smoke/upload_and_sync.go index b803e9b2f4..23b7d56884 100644 --- a/cmd/swarm/swarm-smoke/upload_and_sync.go +++ b/cmd/swarm/swarm-smoke/upload_and_sync.go @@ -98,7 +98,7 @@ func trackChunks(testData []byte) error { } count := 0 - for i, info := range hasInfo { + for _, info := range hasInfo { if info.Has { hostChunks = append(hostChunks, "1") } else { diff --git a/swarm/network/stream/peer.go b/swarm/network/stream/peer.go index 0f14727432..5ce8cc50b8 100644 --- a/swarm/network/stream/peer.go +++ b/swarm/network/stream/peer.go @@ -183,6 +183,8 @@ func (p *Peer) SendOfferedHashes(s *server, f, t uint64) error { ) defer sp.Finish() + defer metrics.GetOrRegisterResettingTimer("send.offered.hashes", nil).UpdateSince(time.Now()) + hashes, from, to, proof, err := s.setNextBatch(f, t) if err != nil { return err