| 55 | } |
| 56 | |
| 57 | std::shared_ptr< IEventProcessor > DisruptorFixture::EventProcessorFactory::createEventProcessor(const std::shared_ptr< RingBuffer< TestEvent > >& ringBuffer, |
| 58 | const std::vector< std::shared_ptr< ISequence > >& barrierSequences) |
| 59 | { |
| 60 | BOOST_CHECK_MESSAGE((size_t)m_sequenceLength == barrierSequences.size(), "Should not have had any barrier sequences"); |
| 61 | return std::make_shared< BatchEventProcessor< TestEvent > >(m_disruptor->ringBuffer(), ringBuffer->newBarrier(barrierSequences), m_eventHandler); |
| 62 | } |
| 63 | |
| 64 | std::shared_ptr< TestWorkHandler > DisruptorFixture::createTestWorkHandler() |
| 65 | { |
no test coverage detected