Skip to content

Commit ec195a5

Browse files
author
Stephen Asbury
committed
Added printout sometimes during replication
1 parent affd710 commit ec195a5

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

performance/stan_stan_bench/main.go

+8
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,7 @@ func main() {
278278
// Start trying to capture the replicator ack activity
279279
repwg.Add(1)
280280
go func() {
281+
lastRepInterval := int64(0)
281282
repTicker := time.NewTicker(100 * time.Millisecond)
282283
loop:
283284
for {
@@ -291,6 +292,13 @@ func main() {
291292
endRep = t
292293
break loop
293294
}
295+
296+
curInterval := reqcount / int64(interval)
297+
298+
if curInterval > lastRepInterval {
299+
lastRepInterval = curInterval
300+
log.Printf("replicated count = %d", reqcount)
301+
}
294302
case <-repTimeout:
295303
break loop
296304
}

0 commit comments

Comments
 (0)