Merge pull request #550 from mreiferson/bench_panic_550

nsqd: benchmark panics
nsqio · May 1, 2015 · a2a5938 · a2a5938
2 parents e417b83 + ed5ce72
commit a2a5938
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nsqd/protocol_v2_test.go b/nsqd/protocol_v2_test.go
@@ -1400,7 +1400,7 @@ func benchmarkProtocolV2Pub(b *testing.B, size int) {
 	opts.MemQueueSize = int64(b.N)
 	tcpAddr, _, nsqd := mustStartNSQD(opts)
 	msg := make([]byte, size)
-	batchSize := 200
+	batchSize := int(opts.MaxBodySize) / size
 	batch := make([][]byte, batchSize)
 	for i := range batch {
 		batch[i] = msg