diff options
author | Matteo Martincigh <matteo.martincigh@arm.com> | 2019-11-05 11:47:40 +0000 |
---|---|---|
committer | Jim Flynn Arm <jim.flynn@arm.com> | 2019-11-05 14:27:39 +0000 |
commit | 2ffcc4179648bbd6fb08342969391a2bcd027221 (patch) | |
tree | f5d06780073bf8354a6b0195dca9961dc1f03ed5 /src/profiling/BufferManager.cpp | |
parent | b67f95796b03c1a5d3b3fa6a40f6baf85bdd09cb (diff) | |
download | armnn-2ffcc4179648bbd6fb08342969391a2bcd027221.tar.gz |
IVGCVSW-4065 Refactor the IPacketBuffer smart pointers
* Added convenience "using" statement for the unique pointers to
IPacketBuffer
* Replaced all the occurrencies in the code
Signed-off-by: Matteo Martincigh <matteo.martincigh@arm.com>
Change-Id: Iffec3a425ffbc1ecb23012971563a48139eb32eb
Diffstat (limited to 'src/profiling/BufferManager.cpp')
-rw-r--r-- | src/profiling/BufferManager.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/profiling/BufferManager.cpp b/src/profiling/BufferManager.cpp index 6ac3ee17d1..6481c5e9cb 100644 --- a/src/profiling/BufferManager.cpp +++ b/src/profiling/BufferManager.cpp @@ -21,13 +21,13 @@ BufferManager::BufferManager(unsigned int numberOfBuffers, unsigned int maxPacke m_AvailableList.reserve(numberOfBuffers); for (unsigned int i = 0; i < numberOfBuffers; ++i) { - std::unique_ptr<IPacketBuffer> buffer = std::make_unique<PacketBuffer>(maxPacketSize); + IPacketBufferPtr buffer = std::make_unique<PacketBuffer>(maxPacketSize); m_AvailableList.emplace_back(std::move(buffer)); } m_ReadableList.reserve(numberOfBuffers); } -std::unique_ptr<IPacketBuffer> BufferManager::Reserve(unsigned int requestedSize, unsigned int& reservedSize) +IPacketBufferPtr BufferManager::Reserve(unsigned int requestedSize, unsigned int& reservedSize) { reservedSize = 0; std::unique_lock<std::mutex> availableListLock(m_AvailableMutex, std::defer_lock); @@ -41,14 +41,14 @@ std::unique_ptr<IPacketBuffer> BufferManager::Reserve(unsigned int requestedSize availableListLock.unlock(); return nullptr; } - std::unique_ptr<IPacketBuffer> buffer = std::move(m_AvailableList.back()); + IPacketBufferPtr buffer = std::move(m_AvailableList.back()); m_AvailableList.pop_back(); availableListLock.unlock(); reservedSize = requestedSize; return buffer; } -void BufferManager::Commit(std::unique_ptr<IPacketBuffer>& packetBuffer, unsigned int size) +void BufferManager::Commit(IPacketBufferPtr& packetBuffer, unsigned int size) { std::unique_lock<std::mutex> readableListLock(m_ReadableMutex, std::defer_lock); packetBuffer->Commit(size); @@ -58,7 +58,7 @@ void BufferManager::Commit(std::unique_ptr<IPacketBuffer>& packetBuffer, unsigne m_ReadDataAvailable.notify_one(); } -void BufferManager::Release(std::unique_ptr<IPacketBuffer>& packetBuffer) +void BufferManager::Release(IPacketBufferPtr& packetBuffer) { std::unique_lock<std::mutex> availableListLock(m_AvailableMutex, std::defer_lock); packetBuffer->Release(); @@ -67,12 +67,12 @@ void BufferManager::Release(std::unique_ptr<IPacketBuffer>& packetBuffer) availableListLock.unlock(); } -std::unique_ptr<IPacketBuffer> BufferManager::GetReadableBuffer() +IPacketBufferPtr BufferManager::GetReadableBuffer() { std::unique_lock<std::mutex> readableListLock(m_ReadableMutex); if (!m_ReadableList.empty()) { - std::unique_ptr<IPacketBuffer> buffer = std::move(m_ReadableList.back()); + IPacketBufferPtr buffer = std::move(m_ReadableList.back()); m_ReadableList.pop_back(); readableListLock.unlock(); return buffer; @@ -80,7 +80,7 @@ std::unique_ptr<IPacketBuffer> BufferManager::GetReadableBuffer() return nullptr; } -void BufferManager::MarkRead(std::unique_ptr<IPacketBuffer>& packetBuffer) +void BufferManager::MarkRead(IPacketBufferPtr& packetBuffer) { std::unique_lock<std::mutex> availableListLock(m_AvailableMutex, std::defer_lock); packetBuffer->MarkRead(); |