Skip to content

Commit

Permalink
Add forgotten update cursor
Browse files Browse the repository at this point in the history
  • Loading branch information
anokl committed Jul 5, 2018
1 parent 39c7ed1 commit 273580b
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion Disruptor/SingleProducerSequencer.h
Original file line number Diff line number Diff line change
Expand Up @@ -99,9 +99,10 @@ namespace Disruptor

if (wrapPoint > cachedGatingSequence || cachedGatingSequence > nextValue)
{
std::int64_t minSequence;
this->m_cursor->setValueVolatile(nextValue);

SpinWait spinWait;
std::int64_t minSequence;
while (wrapPoint > (minSequence = Util::getMinimumSequence(this->m_gatingSequences, nextValue)))
{
this->m_waitStrategyRef.signalAllWhenBlocking();
Expand Down

0 comments on commit 273580b

Please sign in to comment.