ReactorBenchmarkListener Class Reference

Public Member Functions
	ReactorBenchmarkListener (size_t numberOfMessages)
bool	receivedAllMessages () const noexcept
void	resetBenchmark () noexcept override
template<typename Stack>
void	collectSessionTimeMarks (Stack &stack, Session &session, MessageHolder< NewOrderRequest > &order, size_t numberOfMessages, size_t sendPeriod, size_t warmupPeriod)
template<typename Stack>
ONIXS_ICEBOE_HOTPATH void	collectSessionTimeMarks (Stack &stack, Session &session, MessageHolder< NewOrderRequest > &order, size_t numberOfMessages, size_t sendPeriod, size_t warmupPeriod)
Public Member Functions inherited from BenchmarkSessionListener
	BenchmarkSessionListener (size_t numberOfMessages)
	~BenchmarkSessionListener () override=default
bool	active () const noexcept
bool	packetGroupingDetected () const noexcept
const BenchmarkData::SendMarks *	sendMarks () const noexcept
const BenchmarkData::ReceiveMarks *	receiveMarks () const noexcept
const BenchmarkData::Overhead &	overhead () const noexcept
void	measureOverhead ()
ONIXS_ICEBOE_HOTPATH ONIXS_ICEBOE_FORCEINLINE void	beforeSending () noexcept
ONIXS_ICEBOE_HOTPATH ONIXS_ICEBOE_FORCEINLINE void	afterSending () noexcept
void	onStateChange (SessionStateId::Enum newState, SessionStateId::Enum, Session *) override
ONIXS_ICEBOE_HOTPATH void	onExecutionReport_New (const Messaging::ExecutionReport_New, Session *) override
ONIXS_ICEBOE_HOTPATH void	onExecutionReport_Modify (const Messaging::ExecutionReport_Modify, Session *) override
ONIXS_ICEBOE_HOTPATH void	onExecutionReport_Cancel (const Messaging::ExecutionReport_Cancel, Session *) override
ONIXS_ICEBOE_HOTPATH void	onExecutionReport_Reject (const Messaging::ExecutionReport_Reject, Session *) override
ONIXS_ICEBOE_HOTPATH void	onReceivedBytes (const char *, size_t, const ReceivedDataTimestamp &, Session *) noexcept override
ONIXS_ICEBOE_HOTPATH void	onMessageSending (char *, size_t, Session *) noexcept override
void	onError (SessionErrorReason::Enum, const std::string &description, Session *, Messaging::SbeMessage) override
void	onWarning (SessionWarningReason::Enum, const std::string &description, Session *, Messaging::SbeMessage) override

Protected Member Functions
void	onReceivedAllMessages () noexcept override

Detailed Description

Definition at line 438 of file BenchmarkSessionListener.h.

Constructor & Destructor Documentation

ReactorBenchmarkListener()

ReactorBenchmarkListener ( size_t numberOfMessages )

inlineexplicit

Definition at line 441 of file BenchmarkSessionListener.h.

        : BenchmarkSessionListener(numberOfMessages)
        , receivedAllMessages_()
    {}

Member Function Documentation

collectSessionTimeMarks() [1/2]

template<typename Stack>

void collectSessionTimeMarks	(	Stack &	stack,
		Session &	session,
		MessageHolder< NewOrderRequest > &	order,
		size_t	numberOfMessages,
		size_t	sendPeriod,
		size_t	warmupPeriod )

collectSessionTimeMarks() [2/2]

template<typename Stack>

ONIXS_ICEBOE_HOTPATH void collectSessionTimeMarks	(	Stack &	stack,
		Session &	session,
		MessageHolder< NewOrderRequest > &	order,
		size_t	numberOfMessages,
		size_t	sendPeriod,
		size_t	warmupPeriod )

Definition at line 476 of file BenchmarkSessionListener.h.

{
    resetBenchmark();
 
    // When the session is used with the OnixS C++ CME Market Data Handler,
    // this value can be taken from the packet receiving time
    Messaging::Timestamp sendingTime = UtcWatch::now();
 
    for(uint64_t messageCounter = 0; messageCounter < numberOfMessages; ++messageCounter)
    {
        order->orderQty(messageCounter + 1);
        order->clOrdId(messageCounter);
 
        beforeSending();
        session.send(order, sendingTime);
        afterSending();
 
        stack.dispatchEvents();
 
        sendingTime = UtcWatch::now();
 
        if(warmupPeriod || sendPeriod)
        {
            const auto start = PerformanceCounter::current();
 
            PerformanceCounter::Span elapsedMicroseconds = 0;
            do
            {
                do
                {
                    stack.dispatchEvents();
                    session.warmUp(order, sendingTime);
                    elapsedMicroseconds = PerformanceCounter::elapsedMicroseconds(start);
                }
                while(elapsedMicroseconds < static_cast<PerformanceCounter::Span>(warmupPeriod));
 
                stack.dispatchEvents();
                elapsedMicroseconds = PerformanceCounter::elapsedMicroseconds(start);
            }
            while(elapsedMicroseconds < static_cast<PerformanceCounter::Span>(sendPeriod));
        }
    }
 
    while(active())
        stack.dispatchEvents();
}

onReceivedAllMessages()

void onReceivedAllMessages ( )

inlineoverrideprotectedvirtualnoexcept

Reimplemented from BenchmarkSessionListener.

Definition at line 463 of file BenchmarkSessionListener.h.

    {
        BenchmarkSessionListener::onReceivedAllMessages();
        receivedAllMessages_ = true;
    }

receivedAllMessages()

bool receivedAllMessages ( ) const

inlinenoexcept

Definition at line 446 of file BenchmarkSessionListener.h.

    {
        return receivedAllMessages_;
    }

resetBenchmark()

void resetBenchmark ( )

inlineoverridevirtualnoexcept

Reimplemented from BenchmarkSessionListener.

Definition at line 451 of file BenchmarkSessionListener.h.

    {
        BenchmarkSessionListener::resetBenchmark();
        receivedAllMessages_ = false;
    }