diff options
author | Matteo Martincigh <matteo.martincigh@arm.com> | 2019-10-03 11:21:18 +0100 |
---|---|---|
committer | Matteo Martincigh <matteo.martincigh@arm.com> | 2019-10-03 11:53:34 +0100 |
commit | 61d6f7305b02e025ee10aa07e5499993a0e77cc1 (patch) | |
tree | 896078c3400939c6eb85fdd6e8d35eb6e66d3fab /src/profiling/SendCounterPacket.cpp | |
parent | 342a8ba08a67fcbc6f179c32118ca2035002698d (diff) | |
download | armnn-61d6f7305b02e025ee10aa07e5499993a0e77cc1.tar.gz |
IVGCVSW-3440 Fix intermittently failing send thread test
* Simplified the implementation of the MockStreamCounterBuffer
* Minor refactoring
Signed-off-by: Matteo Martincigh <matteo.martincigh@arm.com>
Change-Id: I3aed97daee0ac32d384e1f830e8cc57aae84950b
Diffstat (limited to 'src/profiling/SendCounterPacket.cpp')
-rw-r--r-- | src/profiling/SendCounterPacket.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/profiling/SendCounterPacket.cpp b/src/profiling/SendCounterPacket.cpp index 33eaeabc3e..0a2f08b095 100644 --- a/src/profiling/SendCounterPacket.cpp +++ b/src/profiling/SendCounterPacket.cpp @@ -977,17 +977,17 @@ void SendCounterPacket::Send() } // Wait condition lock scope - End - - + // Get the buffer to read from std::unique_ptr<IPacketBuffer> packetBuffer = m_BufferManager.GetReadableBuffer(); if (packetBuffer == nullptr) { + // Nothing to read from, ignore and continue continue; } - const unsigned char* readBuffer = packetBuffer->GetReadableData(); + // Get the data to send from the buffer + const unsigned char* readBuffer = packetBuffer->GetReadableData(); unsigned int readBufferSize = packetBuffer->GetSize(); - if (readBuffer == nullptr || readBufferSize == 0) { // Nothing to send, ignore and continue @@ -1001,6 +1001,7 @@ void SendCounterPacket::Send() m_ProfilingConnection.WritePacket(readBuffer, boost::numeric_cast<uint32_t>(readBufferSize)); } + // Mark the packet buffer as read m_BufferManager.MarkRead(packetBuffer); } |