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
	process the packet More...
void	Stop ()
void	WaitOnInferenceCompletion (unsigned int timeout)
void	SetInferenceComplete ()
const TimelineModel &	GetTimelineModel () const
virtual void	SetConnection (IInternalProfilingConnection *profilingConnection) override
	Set a profiling connection on the handler. More...
Public Member Functions inherited from ILocalPacketHandler
virtual	~ILocalPacketHandler ()

Detailed Description

Definition at line 46 of file TestTimelinePacketHandler.hpp.

Constructor & Destructor Documentation

TestTimelinePacketHandler()

TestTimelinePacketHandler ( )

inline

Definition at line 49 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

Returns

lists the headers of the packets that this handler accepts only these packets will get sent to this handler. If this function returns an empty list then ALL packets will be sent to the PacketHandler i.e. a universal handler.

Implements ILocalPacketHandler.

Definition at line 19 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 68 of file TestTimelinePacketHandler.hpp.

{return m_TimelineModel;}

HandlePacket()

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

overridevirtual

process the packet

Implements ILocalPacketHandler.

Definition at line 27 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 armnn::Exception(ss.str());
    }
}

SetConnection()

virtual void SetConnection ( IInternalProfilingConnection *  profilingConnection )

inlineoverridevirtual

Set a profiling connection on the handler.

Only need to implement this function if the handler will be writing data back to the profiled application.

Reimplemented from ILocalPacketHandler.

Definition at line 70 of file TestTimelinePacketHandler.hpp.

    {
        m_Connection = profilingConnection;
    }

SetInferenceComplete()

void SetInferenceComplete

(

)

Definition at line 70 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 45 of file TestTimelinePacketHandler.cpp.

References IInternalProfilingConnection::Close().

{
    m_Connection->Close();
}

WaitOnInferenceCompletion()

void WaitOnInferenceCompletion

(

unsigned int

timeout

)

Definition at line 50 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 armnn::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