Adding upstream version 2:20.4+dfsg.upstream/2%20.4+dfsg

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 109 insertions, 0 deletions

diff --git a/xbmc/threads/Timer.cpp b/xbmc/threads/Timer.cpp
new file mode 100644
index 0000000..d06ba40
--- /dev/null
+++ b/xbmc/threads/Timer.cpp
@@ -0,0 +1,109 @@
+/*
+ *  Copyright (C) 2012-2018 Team Kodi
+ *  This file is part of Kodi - https://kodi.tv
+ *
+ *  SPDX-License-Identifier: GPL-2.0-or-later
+ *  See LICENSES/README.md for more information.
+ */
+
+#include "Timer.h"
+
+#include <algorithm>
+
+using namespace std::chrono_literals;
+
+CTimer::CTimer(std::function<void()> const& callback)
+  : CThread("Timer"), m_callback(callback), m_timeout(0ms), m_interval(false)
+{ }
+
+CTimer::CTimer(ITimerCallback *callback)
+  : CTimer(std::bind(&ITimerCallback::OnTimeout, callback))
+{ }
+
+CTimer::~CTimer()
+{
+  Stop(true);
+}
+
+bool CTimer::Start(std::chrono::milliseconds timeout, bool interval /* = false */)
+{
+  if (m_callback == NULL || timeout == 0ms || IsRunning())
+    return false;
+
+  m_timeout = timeout;
+  m_interval = interval;
+
+  Create();
+  return true;
+}
+
+bool CTimer::Stop(bool wait /* = false */)
+{
+  if (!IsRunning())
+    return false;
+
+  m_bStop = true;
+  m_eventTimeout.Set();
+  StopThread(wait);
+
+  return true;
+}
+
+void CTimer::RestartAsync(std::chrono::milliseconds timeout)
+{
+  m_timeout = timeout;
+  m_endTime = std::chrono::steady_clock::now() + timeout;
+  m_eventTimeout.Set();
+}
+
+bool CTimer::Restart()
+{
+  if (!IsRunning())
+    return false;
+
+  Stop(true);
+
+  return Start(m_timeout, m_interval);
+}
+
+float CTimer::GetElapsedSeconds() const
+{
+  return GetElapsedMilliseconds() / 1000.0f;
+}
+
+float CTimer::GetElapsedMilliseconds() const
+{
+  if (!IsRunning())
+    return 0.0f;
+
+  auto now = std::chrono::steady_clock::now();
+  std::chrono::duration<float, std::milli> duration = (now - (m_endTime - m_timeout));
+
+  return duration.count();
+}
+
+void CTimer::Process()
+{
+  while (!m_bStop)
+  {
+    auto currentTime = std::chrono::steady_clock::now();
+    m_endTime = currentTime + m_timeout;
+
+    // wait the necessary time
+    auto duration = std::chrono::duration_cast<std::chrono::milliseconds>(m_endTime - currentTime);
+
+    if (!m_eventTimeout.Wait(duration))
+    {
+      currentTime = std::chrono::steady_clock::now();
+      if (m_endTime <= currentTime)
+      {
+        // execute OnTimeout() callback
+        m_callback();
+
+        // continue if this is an interval timer, or if it was restarted during callback
+        if (!m_interval && m_endTime <= currentTime)
+          break;
+      }
+    }
+  }
+}