diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-10 18:07:22 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-10 18:07:22 +0000 |
commit | c04dcc2e7d834218ef2d4194331e383402495ae1 (patch) | |
tree | 7333e38d10d75386e60f336b80c2443c1166031d /xbmc/interfaces/legacy/Monitor.cpp | |
parent | Initial commit. (diff) | |
download | kodi-c04dcc2e7d834218ef2d4194331e383402495ae1.tar.xz kodi-c04dcc2e7d834218ef2d4194331e383402495ae1.zip |
Adding upstream version 2:20.4+dfsg.upstream/2%20.4+dfsg
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'xbmc/interfaces/legacy/Monitor.cpp')
-rw-r--r-- | xbmc/interfaces/legacy/Monitor.cpp | 82 |
1 files changed, 82 insertions, 0 deletions
diff --git a/xbmc/interfaces/legacy/Monitor.cpp b/xbmc/interfaces/legacy/Monitor.cpp new file mode 100644 index 0000000..34d0553 --- /dev/null +++ b/xbmc/interfaces/legacy/Monitor.cpp @@ -0,0 +1,82 @@ +/* + * Copyright (C) 2005-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 "Monitor.h" + +#include "threads/SystemClock.h" + +#include <algorithm> +#include <math.h> + +using namespace std::chrono_literals; + +namespace XBMCAddon +{ + namespace xbmc + { + Monitor::Monitor(): abortEvent(true) + { + XBMC_TRACE; + if (languageHook) + { + Id = languageHook->GetAddonId(); + invokerId = languageHook->GetInvokerId(); + languageHook->RegisterMonitorCallback(this); + } + } + + void Monitor::AbortNotify() + { + XBMC_TRACE; + abortEvent.Set(); + } + + bool Monitor::waitForAbort(double timeout) + { + XBMC_TRACE; + int timeoutMS = ceil(timeout * 1000); + XbmcThreads::EndTime<> endTime{std::chrono::milliseconds(timeoutMS)}; + + if (timeoutMS <= 0) + endTime.SetInfinite(); + + while (!endTime.IsTimePast()) + { + { + DelayedCallGuard dg(languageHook); + auto timeout = std::min(endTime.GetTimeLeft(), 100ms); + if (abortEvent.Wait(timeout)) + return true; + } + if (languageHook) + languageHook->MakePendingCalls(); + } + return false; + } + + bool Monitor::abortRequested() + { + XBMC_TRACE; + return abortEvent.Signaled(); + } + + Monitor::~Monitor() + { + XBMC_TRACE; + deallocating(); + DelayedCallGuard dg(languageHook); + // we're shutting down so unregister me. + if (languageHook) + { + DelayedCallGuard dc; + languageHook->UnregisterMonitorCallback(this); + } + } + } +} + |