BenchmarkSessionListener Class Reference

Public Member Functions
	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 ()
virtual void	resetBenchmark () noexcept
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
virtual void	onReceivedAllMessages ()

Detailed Description

Definition at line 182 of file BenchmarkSessionListener.h.

Constructor & Destructor Documentation

BenchmarkSessionListener()

BenchmarkSessionListener ( size_t numberOfMessages )

inlineexplicit

Definition at line 185 of file BenchmarkSessionListener.h.

        : allocator_()
        , active_(false)
        , packetGroupingDetected_()
        , numberOfMessages_(numberOfMessages)
        , receiveMarks_(allocator_.allocate<BenchmarkData::ReceiveMarks>(numberOfMessages))
        , receiveCounter_(0)
        , sendMarks_(allocator_.allocate<BenchmarkData::SendMarks>(numberOfMessages))
        , sendCounter_(0)
    {
        for(size_t i = 0; i < numberOfMessages; ++i)
            new (sendMarks_ + i) BenchmarkData::SendMarks();
 
        for(size_t i = 0; i < numberOfMessages; ++i)
            new (receiveMarks_ + i) BenchmarkData::ReceiveMarks();
    }

~BenchmarkSessionListener()

~BenchmarkSessionListener ( )

overridedefault

Member Function Documentation

active()

bool active ( ) const

inlinenoexcept

Definition at line 204 of file BenchmarkSessionListener.h.

    {
        return active_;
    }

afterSending()

ONIXS_ICEBOE_HOTPATH ONIXS_ICEBOE_FORCEINLINE void afterSending ( )

inlinenoexcept

Definition at line 308 of file BenchmarkSessionListener.h.

    {
        assert(sendCounter_ < numberOfMessages_);
        PerformanceCounter::current(&sendMarks_[sendCounter_++].overallSendFinish);
 
        ONIXS_ICEBOE_PREFETCH(&sendMarks_[sendCounter_]);
    }

beforeSending()

ONIXS_ICEBOE_HOTPATH ONIXS_ICEBOE_FORCEINLINE void beforeSending ( )

inlinenoexcept

Definition at line 301 of file BenchmarkSessionListener.h.

    {
        assert(sendCounter_ < numberOfMessages_);
        PerformanceCounter::current(&sendMarks_[sendCounter_].sendStart);
    }

measureOverhead()

void measureOverhead ( )

inline

Definition at line 229 of file BenchmarkSessionListener.h.

    {
        Threading::ThisThread::spinWait(100000);
 
        ReceivedDataTimestamp dummy;
        resetBenchmark();
 
        const size_t iterations = numberOfMessages_ - 1;
 
        for(size_t i = 0; i < iterations; i++)
        {
            beforeSending();
            onMessageSending(nullptr, 0, nullptr);
            afterSending();
            onReceivedBytes(nullptr, 0, dummy, nullptr);
            onReceivedApplicationMessage();
        }
 
        const size_t median = iterations / 2;
 
        std::vector<PerformanceCounter::Span> data;
        data.reserve(iterations);
 
        for(size_t i = 0; i < iterations; i++)
            data.push_back(receiveMarks_[i].recvSpanNano());
 
        std::sort(data.begin(), data.end());
        overhead_.receive = data[median];
 
        data.clear();
        for(size_t i = 0; i < iterations; i++)
            data.push_back(sendMarks_[i].sendSpanNano());
 
        std::sort(data.begin(), data.end());
        overhead_.send = data[median];
 
        data.clear();
        for(size_t i = 0; i < iterations; i++)
            data.push_back(sendMarks_[i].overallSendSpanNano());
 
        std::sort(data.begin(), data.end());
        overhead_.overallSend = data[median];
 
        data.clear();
        for(size_t i = 0; i < iterations; i++)
            data.push_back(BenchmarkData::oneWaySpanNano(sendMarks_[i], receiveMarks_[i]));
 
        std::sort(data.begin(), data.end());
        overhead_.oneWay = data[median];
 
        resetBenchmark();
        active_ = false;
    }

onError()

void onError ( SessionErrorReason::Enum , const std::string & description, Session * , Messaging::SbeMessage  )

inlineoverride

Definition at line 381 of file BenchmarkSessionListener.h.

    {
        std::cerr << "\nSession-level error: " << description << std::endl;
        active_ = false;
    }

onExecutionReport_Cancel()

ONIXS_ICEBOE_HOTPATH void onExecutionReport_Cancel ( const Messaging::ExecutionReport_Cancel , Session *  )

inlineoverride

Definition at line 347 of file BenchmarkSessionListener.h.

    {
        onReceivedApplicationMessage();
    }

onExecutionReport_Modify()

ONIXS_ICEBOE_HOTPATH void onExecutionReport_Modify ( const Messaging::ExecutionReport_Modify , Session *  )

inlineoverride

Definition at line 341 of file BenchmarkSessionListener.h.

    {
        onReceivedApplicationMessage();
    }

onExecutionReport_New()

ONIXS_ICEBOE_HOTPATH void onExecutionReport_New ( const Messaging::ExecutionReport_New , Session *  )

inlineoverride

Definition at line 335 of file BenchmarkSessionListener.h.

    {
        onReceivedApplicationMessage();
    }

onExecutionReport_Reject()

ONIXS_ICEBOE_HOTPATH void onExecutionReport_Reject ( const Messaging::ExecutionReport_Reject , Session *  )

inlineoverride

Definition at line 353 of file BenchmarkSessionListener.h.

    {
        onReceivedApplicationMessage();
    }

onMessageSending()

ONIXS_ICEBOE_HOTPATH void onMessageSending ( char * , size_t , Session *  )

inlineoverridenoexcept

Definition at line 370 of file BenchmarkSessionListener.h.

    {
        if ONIXS_ICEBOE_UNLIKELY(!active_)
            return;
 
        assert(sendCounter_ < numberOfMessages_);
        PerformanceCounter::current(&sendMarks_[sendCounter_].sendFinish);
    }

onReceivedAllMessages()

virtual void onReceivedAllMessages ( )

inlineprotectedvirtual

Reimplemented in ReactorBenchmarkListener.

Definition at line 395 of file BenchmarkSessionListener.h.

    {
        active_ = false;
    }

onReceivedBytes()

ONIXS_ICEBOE_HOTPATH void onReceivedBytes ( const char * , size_t , const ReceivedDataTimestamp & , Session *  )

inlineoverridenoexcept

Definition at line 359 of file BenchmarkSessionListener.h.

    {
        if ONIXS_ICEBOE_UNLIKELY(!active_)
            return;
 
        // More than one SBE message could be received in one IP packet.
        assert(receiveCounter_ < numberOfMessages_);
        PerformanceCounter::current(&receiveMarks_[receiveCounter_].recvStart);
    }

onStateChange()

void onStateChange ( SessionStateId::Enum newState, SessionStateId::Enum , Session *  )

inlineoverride

Definition at line 316 of file BenchmarkSessionListener.h.

    {
        switch(newState)
        {
            case SessionStateId::Established:
                active_ = true;
                ONIXS_ICEBOE_PREFETCH(&receiveMarks_[receiveCounter_]);
                break;
 
            case SessionStateId::Disconnected:
                active_ = false;
                break;
 
            default:
                break;
        }
    }

onWarning()

void onWarning ( SessionWarningReason::Enum , const std::string & description, Session * , Messaging::SbeMessage  )

inlineoverride

Definition at line 388 of file BenchmarkSessionListener.h.

    {
        std::cerr << "\nSession-level warning: " << description << std::endl;
    }

overhead()

const BenchmarkData::Overhead & overhead ( ) const

inlinenoexcept

Definition at line 224 of file BenchmarkSessionListener.h.

    {
        return overhead_;
    }

packetGroupingDetected()

bool packetGroupingDetected ( ) const

inlinenoexcept

Definition at line 209 of file BenchmarkSessionListener.h.

    {
        return packetGroupingDetected_;
    }

receiveMarks()

const BenchmarkData::ReceiveMarks * receiveMarks ( ) const

inlinenoexcept

Definition at line 219 of file BenchmarkSessionListener.h.

    {
        return receiveMarks_;
    }

resetBenchmark()

virtual void resetBenchmark ( )

inlinevirtualnoexcept

Reimplemented in ReactorBenchmarkListener.

Definition at line 284 of file BenchmarkSessionListener.h.

    {
        for(size_t i = 0; i < numberOfMessages_; ++i)
        {
            sendMarks_[i] = BenchmarkData::SendMarks();
            receiveMarks_[i] = BenchmarkData::ReceiveMarks();
        }
 
        sendCounter_ = 0;
        receiveCounter_ = 0;
        packetGroupingDetected_ = false;
        active_ = true;
 
        ONIXS_ICEBOE_PREFETCH(&sendMarks_[sendCounter_]);
    }

sendMarks()

const BenchmarkData::SendMarks * sendMarks ( ) const

inlinenoexcept

Definition at line 214 of file BenchmarkSessionListener.h.

    {
        return sendMarks_;
    }