ArmNN
NotReleased
|
#include <SendThread.hpp>
Public Member Functions | |
SendThread (ProfilingStateMachine &profilingStateMachine, IBufferManager &buffer, ISendCounterPacket &sendCounterPacket, int timeout=1000) | |
~SendThread () | |
void | Start (IProfilingConnection &profilingConnection) override |
Start the thread. More... | |
void | Stop (bool rethrowSendThreadExceptions=true) override |
Stop the thread. More... | |
void | SetReadyToRead () override |
Set a "ready to read" flag in the buffer to notify the reading thread to start reading it. More... | |
bool | IsRunning () |
bool | WaitForPacketSent (uint32_t timeout) |
Public Member Functions inherited from ISendThread | |
virtual | ~ISendThread () |
Public Member Functions inherited from IConsumer | |
virtual | ~IConsumer () |
Definition at line 29 of file SendThread.hpp.
SendThread | ( | ProfilingStateMachine & | profilingStateMachine, |
IBufferManager & | buffer, | ||
ISendCounterPacket & | sendCounterPacket, | ||
int | timeout = 1000 |
||
) |
Definition at line 28 of file SendThread.cpp.
References IBufferManager::SetConsumer().
|
inline |
Definition at line 34 of file SendThread.hpp.
References SendThread::SetReadyToRead(), SendThread::Start(), and SendThread::Stop().
|
inline |
Definition at line 45 of file SendThread.hpp.
References SendThread::WaitForPacketSent().
Referenced by BOOST_AUTO_TEST_CASE().
|
overridevirtual |
Set a "ready to read" flag in the buffer to notify the reading thread to start reading it.
Implements IConsumer.
Definition at line 41 of file SendThread.cpp.
Referenced by BOOST_AUTO_TEST_CASE(), SendThread::Stop(), and SendThread::~SendThread().
|
overridevirtual |
Start the thread.
Implements ISendThread.
Definition at line 52 of file SendThread.cpp.
Referenced by BOOST_AUTO_TEST_CASE(), ProfilingService::Update(), and SendThread::~SendThread().
|
overridevirtual |
Stop the thread.
Implements ISendThread.
Definition at line 82 of file SendThread.cpp.
References armnn::profiling::Active, ProfilingStateMachine::GetCurrentState(), IBufferManager::GetReadableBuffer(), IProfilingConnection::IsOpen(), IBufferManager::MarkRead(), armnn::profiling::NotConnected, ISendCounterPacket::SendStreamMetaDataPacket(), SendThread::SetReadyToRead(), armnn::profiling::Uninitialised, armnn::profiling::WaitingForAck, and IProfilingConnection::WritePacket().
Referenced by BOOST_AUTO_TEST_CASE(), ProfilingService::GetSendTimelinePacket(), ProfilingService::Update(), and SendThread::~SendThread().
bool WaitForPacketSent | ( | uint32_t | timeout = 1000 | ) |
Definition at line 263 of file SendThread.cpp.
Referenced by SendThread::IsRunning(), and ProfilingService::WaitForPacketSent().