From a43801c63640f982a90e9f0cde8d57ae86edc565 Mon Sep 17 00:00:00 2001 From: holisticode Date: Fri, 7 Dec 2018 08:03:06 -0500 Subject: [PATCH] cmd/swarm/swarm-smoke: metrics for each run (#1049) --- cmd/swarm/swarm-smoke/upload_and_sync.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/cmd/swarm/swarm-smoke/upload_and_sync.go b/cmd/swarm/swarm-smoke/upload_and_sync.go index db74f569aa..d605f79a3a 100644 --- a/cmd/swarm/swarm-smoke/upload_and_sync.go +++ b/cmd/swarm/swarm-smoke/upload_and_sync.go @@ -123,11 +123,14 @@ func uploadAndSync(c *cli.Context) error { wg.Add(1) go func(endpoint string, ruid string) { for { + start := time.Now() err := fetch(hash, endpoint, fhash, ruid) + fetchTime := time.Since(start) if err != nil { continue } + metrics.GetOrRegisterMeter("upload-and-sync.single.fetch-time", nil).Mark(int64(fetchTime)) wg.Done() return } @@ -138,11 +141,14 @@ func uploadAndSync(c *cli.Context) error { wg.Add(1) go func(endpoint string, ruid string) { for { + start := time.Now() err := fetch(hash, endpoint, fhash, ruid) + fetchTime := time.Since(start) if err != nil { continue } + metrics.GetOrRegisterMeter("upload-and-sync.each.fetch-time", nil).Mark(int64(fetchTime)) wg.Done() return }