From 5307bc10ac488261e84ac76b2dede6039ea3fe96 Mon Sep 17 00:00:00 2001
From: telsoa01 <telmo.soares@arm.com>
Date: Fri, 9 Mar 2018 13:51:08 +0000
Subject: Release 18.02

Change-Id: I41a89c149534a7c354a58e2c66a32cba572fc0c1
---
 RequestThread.cpp | 116 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 116 insertions(+)
 create mode 100644 RequestThread.cpp

(limited to 'RequestThread.cpp')

diff --git a/RequestThread.cpp b/RequestThread.cpp
new file mode 100644
index 00000000..708a46c8
--- /dev/null
+++ b/RequestThread.cpp
@@ -0,0 +1,116 @@
+//
+// Copyright © 2017 Arm Ltd. All rights reserved.
+// See LICENSE file in the project root for full license information.
+//
+
+#define LOG_TAG "ArmnnDriver"
+
+#include "RequestThread.hpp"
+#include "ArmnnPreparedModel.hpp"
+
+#include <log/log.h>
+
+#include <boost/assert.hpp>
+
+using namespace android;
+
+namespace armnn_driver
+{
+
+RequestThread::RequestThread()
+{
+    ALOGV("RequestThread::RequestThread()");
+    m_Thread = std::make_unique<std::thread>(&RequestThread::Process, this);
+}
+
+RequestThread::~RequestThread()
+{
+    ALOGV("RequestThread::~RequestThread()");
+    // post an EXIT message to the thread
+    std::shared_ptr<AsyncExecuteData> nulldata(nullptr);
+    auto pMsg = std::make_shared<ThreadMsg>(ThreadMsgType::EXIT, nulldata);
+    PostMsg(pMsg);
+    // Wait for the thread to terminate, it is deleted automatically
+    m_Thread->join();
+}
+
+void RequestThread::PostMsg(ArmnnPreparedModel* model,
+                            std::shared_ptr<std::vector<::android::nn::RunTimePoolInfo>>& memPools,
+                            std::shared_ptr<armnn::InputTensors>& inputTensors,
+                            std::shared_ptr<armnn::OutputTensors>& outputTensors,
+                            const ::android::sp<IExecutionCallback>& callback)
+{
+    ALOGV("RequestThread::PostMsg(...)");
+    auto data = std::make_shared<AsyncExecuteData>(model,
+                                                   memPools,
+                                                   inputTensors,
+                                                   outputTensors,
+                                                   callback);
+    auto pMsg = std::make_shared<ThreadMsg>(ThreadMsgType::REQUEST, data);
+    PostMsg(pMsg);
+}
+
+void RequestThread::PostMsg(std::shared_ptr<ThreadMsg>& pMsg)
+{
+    ALOGV("RequestThread::PostMsg(pMsg)");
+    // Add a message to the queue and notify the request thread
+    std::unique_lock<std::mutex> lock(m_Mutex);
+    m_Queue.push(pMsg);
+    m_Cv.notify_one();
+}
+
+void RequestThread::Process()
+{
+    ALOGV("RequestThread::Process()");
+    while (true)
+    {
+        std::shared_ptr<ThreadMsg> pMsg(nullptr);
+        {
+            // Wait for a message to be added to the queue
+            // This is in a separate scope to minimise the lifetime of the lock
+            std::unique_lock<std::mutex> lock(m_Mutex);
+            while (m_Queue.empty())
+            {
+                m_Cv.wait(lock);
+            }
+            // get the message to process from the front of the queue
+            pMsg = m_Queue.front();
+            m_Queue.pop();
+        }
+
+        switch (pMsg->type)
+        {
+            case ThreadMsgType::REQUEST:
+            {
+                ALOGV("RequestThread::Process() - request");
+                // invoke the asynchronous execution method
+                ArmnnPreparedModel* model = pMsg->data->m_Model;
+                model->ExecuteGraph(pMsg->data->m_MemPools,
+                                    pMsg->data->m_InputTensors,
+                                    pMsg->data->m_OutputTensors,
+                                    pMsg->data->m_callback);
+                break;
+            }
+
+            case ThreadMsgType::EXIT:
+            {
+                ALOGV("RequestThread::Process() - exit");
+                // delete all remaining messages (there should not be any)
+                std::unique_lock<std::mutex> lock(m_Mutex);
+                while (!m_Queue.empty())
+                {
+                    m_Queue.pop();
+                }
+                return;
+            }
+
+            default:
+                // this should be unreachable
+                ALOGE("RequestThread::Process() - invalid message type");
+                BOOST_ASSERT_MSG(false, "ArmNN: RequestThread: invalid message type");
+        }
+    }
+}
+
+} // namespace armnn_driver
+
-- 
cgit v1.2.1