SingleProducerSequencer: update next(n) to not block forever when n >…

… bufferSize. Fixes GitHub issue Abc-Arbitrage#10
arnoud67 · Aug 11, 2020 · 4194602 · 4194602
1 parent 29d8069
commit 4194602
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Disruptor/SingleProducerSequencer.h b/Disruptor/SingleProducerSequencer.h
@@ -86,9 +86,9 @@ namespace Disruptor
  */ 
  std::int64_t next(std::int32_t n) override
  {
- if (n < 1)
+ if (n < 1 || n > this->m_bufferSize)
  {
- DISRUPTOR_THROW_ARGUMENT_EXCEPTION("n must be > 0");
+ DISRUPTOR_THROW_ARGUMENT_EXCEPTION("n must be > 0 and < bufferSize");
  }
 
  auto nextValue = m_fields.nextValue;