Fixed test. #2
diff --git a/benchmark-disruptor/shared_writer_contended_write_test.go b/benchmark-disruptor/shared_writer_contended_write_test.go
index 8a48b60..721c042 100644
--- a/benchmark-disruptor/shared_writer_contended_write_test.go
+++ b/benchmark-disruptor/shared_writer_contended_write_test.go
@@ -66,22 +66,22 @@
for current < iterations {
current = writer.Reserve(ReserveMany)
- for i := previous + 1; i <= current; i++ {
+ for i := current - ReserveMany; i <= current; i++ {
ringBuffer[i&RingBufferMask] = i
}
- writer.Commit(previous+1, current)
+ writer.Commit(current-ReserveMany, current)
}
}()
current := disruptor.InitialSequenceValue
for current < iterations {
current = writer.Reserve(ReserveMany)
- for i := previous + 1; i <= current; i++ {
+ for i := current - ReserveMany; i <= current; i++ {
ringBuffer[i&RingBufferMask] = i
}
- writer.Commit(previous+1, current)
+ writer.Commit(current-ReserveMany, current)
}
b.StopTimer()
