forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

cmd/swarm/swarm-smoke-pss: camelcase errC

Browse source
This commit is contained in:
Rafael Matias 2019-04-09 10:47:25 +02:00
parent 38ec61dd1b
commit c91f253a54
No known key found for this signature in database
GPG key ID: 1BC39532FB4A2DBD
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -60,6 +60,7 @@ func pssAsymCheck(ctx *cli.Context) error {
func pssSymCheck(ctx *cli.Context) error { func pssSymCheck(ctx *cli.Context) error {
return runCheck(pssModeSym, pssMessageCount, pssMessageSize) return runCheck(pssModeSym, pssMessageCount, pssMessageSize)
} }
func pssRawCheck(ctx *cli.Context) error { func pssRawCheck(ctx *cli.Context) error {
return runCheck(pssModeRaw, pssMessageCount, pssMessageSize) return runCheck(pssModeRaw, pssMessageCount, pssMessageSize)
} }
@ -101,7 +102,7 @@ func runCheck(mode pssMode, count int, msgSizeBytes int) error {
jobs := session.genJobs(count, mode, msgSizeBytes) jobs := session.genJobs(count, mode, msgSizeBytes)
errc := make(chan error) errC := make(chan error)
go func() { go func() {
var failCount, successCount int64 var failCount, successCount int64
t := time.Now() t := time.Now()
@ -121,14 +122,14 @@ func runCheck(mode pssMode, count int, msgSizeBytes int) error {
log.Info(fmt.Sprintf("pss.%s test ended", mode), "time", totalTime, "success", successCount, "failures", failCount) log.Info(fmt.Sprintf("pss.%s test ended", mode), "time", totalTime, "success", successCount, "failures", failCount)
if failCount > 0 { if failCount > 0 {
errc <- errors.New("some messages were not delivered") errC <- errors.New("some messages were not delivered")
} else { } else {
errc <- nil errC <- nil
} }
}() }()
select { select {
case err := <-errc: case err := <-errC:
if err != nil { if err != nil {
metrics.GetOrRegisterCounter(fmt.Sprintf("pss.%s.fail", mode), nil).Inc(1) metrics.GetOrRegisterCounter(fmt.Sprintf("pss.%s.fail", mode), nil).Inc(1)
} }