xbmc/interfaces/generic/LanguageInvokerThread.cpp

   1 /*
   2  *  Copyright (C) 2013-2018 Team Kodi
   3  *  This file is part of Kodi - https://kodi.tv
   4  *
   5  *  SPDX-License-Identifier: GPL-2.0-or-later
   6  *  See LICENSES/README.md for more information.
   7  */
   8
   9 #include "LanguageInvokerThread.h"
  10
  11 #include "ScriptInvocationManager.h"
  12
  13 #include <utility>
  14
  15 CLanguageInvokerThread::CLanguageInvokerThread(LanguageInvokerPtr invoker,
  16                                                CScriptInvocationManager* invocationManager,
  17                                                bool reuseable)
  18   : ILanguageInvoker(NULL),
  19     CThread("LanguageInvoker"),
  20     m_invoker(std::move(invoker)),
  21     m_invocationManager(invocationManager),
  22     m_reusable(reuseable)
  23 { }
  24
  25 CLanguageInvokerThread::~CLanguageInvokerThread()
  26 {
  27   Stop(true);
  28 }
  29
  30 InvokerState CLanguageInvokerThread::GetState() const
  31 {
  32   if (m_invoker == NULL)
  33     return InvokerStateFailed;
  34
  35   return m_invoker->GetState();
  36 }
  37
  38 void CLanguageInvokerThread::Release()
  39 {
  40   m_bStop = true;
  41   m_condition.notify_one();
  42 }
  43
  44 bool CLanguageInvokerThread::execute(const std::string &script, const std::vector<std::string> &arguments)
  45 {
  46   if (m_invoker == NULL || script.empty())
  47     return false;
  48
  49   m_script = script;
  50   m_args = arguments;
  51
  52   if (CThread::IsRunning())
  53   {
  54     std::unique_lock<std::mutex> lck(m_mutex);
  55     m_restart = true;
  56     m_condition.notify_one();
  57   }
  58   else
  59     Create();
  60
  61   //Todo wait until running
  62
  63   return true;
  64 }
  65
  66 bool CLanguageInvokerThread::stop(bool wait)
  67 {
  68   if (m_invoker == NULL)
  69     return false;
  70
  71   if (!CThread::IsRunning())
  72     return false;
  73
  74   Release();
  75
  76   bool result = true;
  77   if (m_invoker->GetState() < InvokerStateExecutionDone)
  78   {
  79     // stop the language-specific invoker
  80     result = m_invoker->Stop(wait);
  81   }
  82   // stop the thread
  83   CThread::StopThread(wait);
  84
  85   return result;
  86 }
  87
  88 void CLanguageInvokerThread::OnStartup()
  89 {
  90   if (m_invoker == NULL)
  91     return;
  92
  93   m_invoker->SetId(GetId());
  94   if (m_addon != NULL)
  95     m_invoker->SetAddon(m_addon);
  96 }
  97
  98 void CLanguageInvokerThread::Process()
  99 {
 100   if (m_invoker == NULL)
 101     return;
 102
 103   std::unique_lock<std::mutex> lckdl(m_mutex);
 104   do
 105   {
 106     m_restart = false;
 107     m_invoker->Execute(m_script, m_args);
 108
 109     if (m_invoker->GetState() != InvokerStateScriptDone)
 110       m_reusable = false;
 111
 112     m_condition.wait(lckdl, [this] { return m_bStop || m_restart || !m_reusable; });
 113
 114   } while (m_reusable && !m_bStop);
 115 }
 116
 117 void CLanguageInvokerThread::OnExit()
 118 {
 119   if (m_invoker == NULL)
 120     return;
 121
 122   m_invoker->onExecutionDone();
 123   m_invocationManager->OnExecutionDone(GetId());
 124 }
 125
 126 void CLanguageInvokerThread::OnException()
 127 {
 128   if (m_invoker == NULL)
 129     return;
 130
 131   m_invoker->onExecutionFailed();
 132   m_invocationManager->OnExecutionDone(GetId());
 133 }