|
|
@ -100,7 +100,7 @@ func (s *sendResult) accumulate(request value, response maybe) {
|
|
|
|
if options.verbose {
|
|
|
|
if options.verbose {
|
|
|
|
fmt.Fprintf(os.Stderr, "%q -> %q\n", request, response.val())
|
|
|
|
fmt.Fprintf(os.Stderr, "%q -> %q\n", request, response.val())
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
fmt.Fprintln(os.Stderr, r)
|
|
|
|
fmt.Fprintf(os.Stderr, "%q\n", r)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
s.errors++
|
|
|
|
s.errors++
|
|
|
|
default:
|
|
|
|
default:
|
|
|
@ -221,7 +221,7 @@ func main() {
|
|
|
|
stats.log()
|
|
|
|
stats.log()
|
|
|
|
errors += stats.errors
|
|
|
|
errors += stats.errors
|
|
|
|
replies += stats.replies
|
|
|
|
replies += stats.replies
|
|
|
|
time.Sleep(stats.elapsed / 4)
|
|
|
|
time.Sleep(time.Duration(float64(stats.elapsed) * 0.1))
|
|
|
|
id++
|
|
|
|
id++
|
|
|
|
requests = &chunk{id: id, vals: make([]value, 0, stats.nextSize())}
|
|
|
|
requests = &chunk{id: id, vals: make([]value, 0, stats.nextSize())}
|
|
|
|
}
|
|
|
|
}
|
|
|
|