We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 54c8c33 commit 9be47e5Copy full SHA for 9be47e5
perfTest/cmd/silent.go
@@ -94,12 +94,12 @@ func printStats() {
94
for {
95
select {
96
case _ = <-tickerReset.C:
97
- logInfo("Resetting counters...")
98
- atomic.SwapInt32(&publisherMessageCount, 0)
+ logInfo("***********Resetting counters***********")
99
atomic.SwapInt32(&consumerMessageCount, 0)
100
- atomic.SwapInt64(&totalLatency, 0)
101
- atomic.SwapInt32(&confirmedMessageCount, 0)
102
atomic.SwapInt32(¬ConfirmedMessageCount, 0)
+ atomic.SwapInt32(&confirmedMessageCount, 0)
+ atomic.SwapInt32(&publisherMessageCount, 0)
+ atomic.SwapInt64(&totalLatency, 0)
103
start = time.Now()
104
}
105
0 commit comments