forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

add metrics to upload and sync test

Browse source
This commit is contained in:
Elad Nachmias 2018-12-04 14:57:03 +05:30
parent ad3aef7302
commit ea987e48c1
2 changed files with 14 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
cmd/swarm/swarm-smoke/main.go
View file

@ -44,6 +44,12 @@ var (
verbosity int verbosity int
timeout int timeout int
) )
var (
smokeUploadAndSyncCount = gethmetrics.NewRegisteredCounter("swarm-smoke.upload-and-sync.count", nil)
smokeUploadAndSyncFailCount = gethmetrics.NewRegisteredCounter("swarm-smoke.upload-and-sync.fail.count", nil)
smokeUploadAndSyncRunTime = gethmetrics.NewRegisteredCounter("swarm-smoke.upload-and-sync.time", nil)
smokeUploadAndSyncTimeout = gethmetrics.NewRegisteredCounter("swarm-smoke.upload-and-sync.timeout", nil)
)
func main() { func main() {

9
cmd/swarm/swarm-smoke/upload_and_sync.go
View file

@ -55,6 +55,7 @@ func generateEndpoints(scheme string, cluster string, app string, from int, to i
} }
func cliUploadAndSync(c *cli.Context) error { func cliUploadAndSync(c *cli.Context) error {
smokeUploadAndSyncCount.Inc(1)
log.PrintOrigins(true) log.PrintOrigins(true)
log.Root().SetHandler(log.LvlFilterHandler(log.Lvl(verbosity), log.StreamHandler(os.Stdout, log.TerminalFormat(true)))) log.Root().SetHandler(log.LvlFilterHandler(log.Lvl(verbosity), log.StreamHandler(os.Stdout, log.TerminalFormat(true))))
@ -65,15 +66,21 @@ func cliUploadAndSync(c *cli.Context) error {
select { select {
case err := <-errc: case err := <-errc:
if err != nil {
smokeUploadAndSyncFailCount.Inc(1)
}
return err return err
case <-time.After(time.Duration(timeout) * time.Second): case <-time.After(time.Duration(timeout) * time.Second):
smokeUploadAndSyncTimeout.Inc(1)
return fmt.Errorf("timeout after %v sec", timeout) return fmt.Errorf("timeout after %v sec", timeout)
} }
} }
func uploadAndSync(c *cli.Context) error { func uploadAndSync(c *cli.Context) error {
defer func(now time.Time) { log.Info("total time", "time", time.Since(now), "kb", filesize) }(time.Now()) defer func(now time.Time) {
log.Info("total time", "time", time.Since(now), "kb", filesize)
}(time.Now())
generateEndpoints(scheme, cluster, appName, from, to) generateEndpoints(scheme, cluster, appName, from, to)