Method Reserve

profiling/client/src/BufferManager.cpp:24–66

}

IPacketBufferPtr BufferManager::Reserve(unsigned int requestedSize, unsigned int& reservedSize)
{
    reservedSize = 0;
#if !defined(ARMNN_DISABLE_THREADS)
    std::unique_lock<std::mutex> availableListLock(m_AvailableMutex, std::defer_lock);
#endif
    if (requestedSize > m_MaxBufferSize)
    {
        return nullptr;
    }
#if !defined(ARMNN_DISABLE_THREADS)
    availableListLock.lock();
#endif
    if (m_AvailableList.empty())
    {
        if (m_CurrentNumberOfBuffers < m_MaxNumberOfBuffers)
        {
            // create a temporary overflow/surge buffer and hand it back
            m_CurrentNumberOfBuffers++;
#if !defined(ARMNN_DISABLE_THREADS)
            availableListLock.unlock();
#endif
            IPacketBufferPtr buffer = std::make_unique<PacketBuffer>(m_MaxBufferSize);
            reservedSize = requestedSize;
            return buffer;
        }
        else
        {
            // we have totally busted the limit. call a halt to new memory allocations.
#if !defined(ARMNN_DISABLE_THREADS)
            availableListLock.unlock();
#endif
            return nullptr;
        }
    }
    IPacketBufferPtr buffer = std::move(m_AvailableList.back());
    m_AvailableList.pop_back();
#if !defined(ARMNN_DISABLE_THREADS)
    availableListLock.unlock();
#endif
    reservedSize = requestedSize;
    return buffer;
}

void BufferManager::Commit(IPacketBufferPtr& packetBuffer, unsigned int size, bool notifyConsumer)
{