TestTimelinePacketHandler Class Reference

#include <TestTimelinePacketHandler.hpp>

Inheritance diagram for TestTimelinePacketHandler:

Public Member Functions
	TestTimelinePacketHandler ()
virtual std::vector< uint32_t >	GetHeadersAccepted () override
virtual void	HandlePacket (const arm::pipe::Packet &packet) override
void	Stop ()
void	WaitOnInferenceCompletion (unsigned int timeout)
void	SetInferenceComplete ()
const TimelineModel &	GetTimelineModel () const
virtual void	SetConnection (IInternalProfilingConnection *profilingConnection) override

Detailed Description

Definition at line 48 of file TestTimelinePacketHandler.hpp.

Constructor & Destructor Documentation

TestTimelinePacketHandler()

TestTimelinePacketHandler ( )

inline

Definition at line 51 of file TestTimelinePacketHandler.hpp.

                                :
        m_Connection(nullptr),
        m_InferenceCompleted(false),
        m_DirectoryHeader(CreateTimelinePacketHeader(1, 0, 0, 0, 0, 0).first),
        m_MessageHeader(CreateTimelinePacketHeader(1, 0, 1, 0, 0, 0).first),
        m_MessageDecoder(m_TimelineModel),
        m_Decoder(1, 1, 0, m_MessageDecoder),
        m_DirectoryDecoder(1, 0, 0, m_Decoder, true)
    { m_MessageDecoder.SetPacketHandler(this); }

Member Function Documentation

GetHeadersAccepted()

std::vector< uint32_t > GetHeadersAccepted ( )

overridevirtual

Definition at line 21 of file TestTimelinePacketHandler.cpp.

{
    std::vector<uint32_t> headers;
    headers.push_back(m_DirectoryHeader); // message directory
    headers.push_back(m_MessageHeader); // message
    return headers;
}

GetTimelineModel()

const TimelineModel& GetTimelineModel ( ) const

inline

Definition at line 70 of file TestTimelinePacketHandler.hpp.

{return m_TimelineModel;}

HandlePacket()

void HandlePacket ( const arm::pipe::Packet &  packet )

overridevirtual

Definition at line 29 of file TestTimelinePacketHandler.cpp.

{
    if (packet.GetHeader() == m_DirectoryHeader)
    {
        ProcessDirectoryPacket(packet);
    }
    else if (packet.GetHeader() == m_MessageHeader)
    {
        ProcessMessagePacket(packet);
    }
    else
    {
        std::stringstream ss;
        ss << "Received a packet with unknown header [" << packet.GetHeader() << "]";
        throw arm::pipe::ProfilingException(ss.str());
    }
}

SetConnection()

virtual void SetConnection ( IInternalProfilingConnection *  profilingConnection )

inlineoverridevirtual

Definition at line 72 of file TestTimelinePacketHandler.hpp.

    {
        m_Connection = profilingConnection;
    }

SetInferenceComplete()

void SetInferenceComplete

(

)

Definition at line 72 of file TestTimelinePacketHandler.cpp.

{
    {   // only lock when we are updating the inference completed variable
        std::unique_lock<std::mutex> lck(m_InferenceCompletedMutex);
        m_InferenceCompleted = true;
    }
    m_InferenceCompletedConditionVariable.notify_one();
}

Stop()

void Stop

(

)

Definition at line 47 of file TestTimelinePacketHandler.cpp.

{
    m_Connection->Close();
}

WaitOnInferenceCompletion()

void WaitOnInferenceCompletion

(

unsigned int

timeout

)

Definition at line 52 of file TestTimelinePacketHandler.cpp.

{
    std::unique_lock<std::mutex> lck(m_InferenceCompletedMutex);

    auto start = std::chrono::high_resolution_clock::now();
    // Here we we will go back to sleep after a spurious wake up if
    // m_InferenceCompleted is not yet true.
    if (!m_InferenceCompletedConditionVariable.wait_for(lck,
                                                        std::chrono::milliseconds(timeout),
                                                        [&]{return m_InferenceCompleted == true;}))
    {
        auto finish = std::chrono::high_resolution_clock::now();
        std::chrono::duration<double, std::milli> elapsed = finish - start;
        std::stringstream ss;
        ss << "Timed out waiting on inference completion for " << elapsed.count() << " ms";
        throw arm::pipe::TimeoutException(ss.str());
    }
    return;
}

---

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

• src/profiling/test/TestTimelinePacketHandler.hpp
• src/profiling/test/TestTimelinePacketHandler.cpp