MockProfilingConnection Class Reference

#include <ProfilingMocks.hpp>

Inheritance diagram for MockProfilingConnection:

Public Types
enum	PacketType {   StreamMetaData, ConnectionAcknowledge, CounterDirectory, ReqCounterDirectory,   PeriodicCounterSelection, PerJobCounterSelection, TimelineMessageDirectory, PeriodicCounterCapture,   ActivateTimelineReporting, DeactivateTimelineReporting, Unknown }

Public Member Functions
	MockProfilingConnection ()
bool	IsOpen () const override
void	Close () override
bool	WritePacket (const unsigned char *buffer, uint32_t length) override
long	CheckForPacket (const std::pair< PacketType, uint32_t > packetInfo)
bool	WritePacket (arm::pipe::Packet &&packet)
arm::pipe::Packet	ReadPacket (uint32_t timeout) override
unsigned long	GetWrittenDataSize ()
void	Clear ()

Detailed Description

Definition at line 39 of file ProfilingMocks.hpp.

Member Enumeration Documentation

PacketType

enum PacketType

strong

Enumerator
StreamMetaData
ConnectionAcknowledge
CounterDirectory
ReqCounterDirectory
PeriodicCounterSelection
PerJobCounterSelection
TimelineMessageDirectory
PeriodicCounterCapture
ActivateTimelineReporting
DeactivateTimelineReporting
Unknown

Definition at line 48 of file ProfilingMocks.hpp.

    {
        StreamMetaData,
        ConnectionAcknowledge,
        CounterDirectory,
        ReqCounterDirectory,
        PeriodicCounterSelection,
        PerJobCounterSelection,
        TimelineMessageDirectory,
        PeriodicCounterCapture,
        ActivateTimelineReporting,
        DeactivateTimelineReporting,
        Unknown
    };

Constructor & Destructor Documentation

MockProfilingConnection()

MockProfilingConnection ( )

inline

Definition at line 42 of file ProfilingMocks.hpp.

        : m_IsOpen(true)
        , m_WrittenData()
        , m_Packet()
    {}

Member Function Documentation

CheckForPacket()

long CheckForPacket ( const std::pair< PacketType, uint32_t >  packetInfo )

inline

Definition at line 112 of file ProfilingMocks.hpp.

Referenced by SwapProfilingConnectionFactoryHelper::WaitForPacketsSent().

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        if(packetInfo.second != 0)
        {
            return static_cast<long>(std::count(m_WrittenData.begin(), m_WrittenData.end(), packetInfo));
        }
        else
        {
            return static_cast<long>(std::count_if(m_WrittenData.begin(), m_WrittenData.end(),
            [&packetInfo](const std::pair<PacketType, uint32_t> pair) { return packetInfo.first == pair.first; }));
        }
    }

Clear()

void Clear ( )

inline

Definition at line 152 of file ProfilingMocks.hpp.

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        m_WrittenData.clear();
    }

Close()

void Close ( )

inlineoverride

Definition at line 70 of file ProfilingMocks.hpp.

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        m_IsOpen = false;
    }

GetWrittenDataSize()

unsigned long GetWrittenDataSize ( )

inline

Definition at line 145 of file ProfilingMocks.hpp.

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        return static_cast<unsigned long>(m_WrittenData.size());
    }

IsOpen()

bool IsOpen ( ) const

inlineoverride

Definition at line 63 of file ProfilingMocks.hpp.

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        return m_IsOpen;
    }

ReadPacket()

arm::pipe::Packet ReadPacket ( uint32_t  timeout )

inlineoverride

Definition at line 135 of file ProfilingMocks.hpp.

References armnn::IgnoreUnused().

    {
        arm::pipe::IgnoreUnused(timeout);

        // Simulate a delay in the reading process. The default timeout is way too long.
        std::this_thread::sleep_for(std::chrono::milliseconds(5));
        std::lock_guard<std::mutex> lock(m_Mutex);
        return std::move(m_Packet);
    }

WritePacket() [1/2]

bool WritePacket ( const unsigned char *  buffer, uint32_t  length  )

inlineoverride

Definition at line 77 of file ProfilingMocks.hpp.

References MockProfilingConnection::PeriodicCounterCapture, MockProfilingConnection::TimelineMessageDirectory, and MockProfilingConnection::Unknown.

    {
        if (buffer == nullptr || length == 0)
        {
            return false;
        }

        uint32_t header = ReadUint32(buffer, 0);

        uint32_t packetFamily = (header >> 26);
        uint32_t packetId = ((header >> 16) & 1023);

        PacketType packetType;

        switch (packetFamily)
        {
            case 0:
                packetType = packetId < 8 ? PacketType(packetId) : PacketType::Unknown;
                break;
            case 1:
                packetType = packetId == 0 ? PacketType::TimelineMessageDirectory : PacketType::Unknown;
                break;
            case 3:
                packetType = packetId == 0 ? PacketType::PeriodicCounterCapture : PacketType::Unknown;
                break;
            default:
                packetType = PacketType::Unknown;
        }

        std::lock_guard<std::mutex> lock(m_Mutex);

        m_WrittenData.push_back({ packetType, length });
        return true;
    }

WritePacket() [2/2]

bool WritePacket ( arm::pipe::Packet &&  packet )

inline

Definition at line 127 of file ProfilingMocks.hpp.

    {
        std::lock_guard<std::mutex> lock(m_Mutex);

        m_Packet = std::move(packet);
        return true;
    }

---

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

• src/profiling/test/ProfilingMocks.hpp