CatapultServer  v0.5.0.1 (Elephant)
catapult::disruptor::DisruptorBarrier Class Reference

Public Member Functions

 DisruptorBarrier (size_t level, PositionType position)
 Creates a barrier given its level and position (barrierEndPosition). More...
 
void advance ()
 Advances the barrier. More...
 
size_t level () const
 Returns level of the barrier. More...
 
PositionType position () const
 Returns position of the barrier. More...
 

Private Attributes

const size_t m_level
 
std::atomic< PositionTypem_position
 

Detailed Description

DisruptorBarrier represents a consumer barrier (possibly shared by multiple consumers) at a given level.

Constructor & Destructor Documentation

◆ DisruptorBarrier()

catapult::disruptor::DisruptorBarrier::DisruptorBarrier ( size_t  level,
PositionType  position 
)
inline

Creates a barrier given its level and position (barrierEndPosition).

Member Function Documentation

◆ advance()

void catapult::disruptor::DisruptorBarrier::advance ( )
inline

Advances the barrier.

◆ level()

size_t catapult::disruptor::DisruptorBarrier::level ( ) const
inline

Returns level of the barrier.

◆ position()

PositionType catapult::disruptor::DisruptorBarrier::position ( ) const
inline

Returns position of the barrier.

Member Data Documentation

◆ m_level

const size_t catapult::disruptor::DisruptorBarrier::m_level
private

◆ m_position

std::atomic<PositionType> catapult::disruptor::DisruptorBarrier::m_position
private

The documentation for this class was generated from the following file: