summaryrefslogtreecommitdiffstats
path: root/gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 19:33:14 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 19:33:14 +0000
commit36d22d82aa202bb199967e9512281e9a53db42c9 (patch)
tree105e8c98ddea1c1e4784a60a5a6410fa416be2de /gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp
parentInitial commit. (diff)
downloadfirefox-esr-upstream.tar.xz
firefox-esr-upstream.zip
Adding upstream version 115.7.0esr.upstream/115.7.0esrupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp')
-rw-r--r--gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp116
1 files changed, 116 insertions, 0 deletions
diff --git a/gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp b/gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp
new file mode 100644
index 0000000000..8441b028da
--- /dev/null
+++ b/gfx/angle/checkout/src/libANGLE/renderer/EGLReusableSync.cpp
@@ -0,0 +1,116 @@
+//
+// Copyright 2020 The ANGLE Project Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+//
+
+// EGLReusableSync.cpp: Implements the egl::ReusableSync class.
+
+#include "libANGLE/renderer/EGLReusableSync.h"
+
+#include "libANGLE/Context.h"
+#include "libANGLE/renderer/ContextImpl.h"
+
+namespace rx
+{
+
+ReusableSync::ReusableSync(const egl::AttributeMap &attribs)
+ : EGLSyncImpl(), mStatus(EGL_UNSIGNALED)
+{}
+
+void ReusableSync::onDestroy(const egl::Display *display) {}
+
+ReusableSync::~ReusableSync()
+{
+ // Release any waiting thread.
+ mCondVar.notify_all();
+}
+
+egl::Error ReusableSync::initialize(const egl::Display *display,
+ const gl::Context *context,
+ EGLenum type)
+{
+ return egl::NoError();
+}
+
+egl::Error ReusableSync::clientWait(const egl::Display *display,
+ const gl::Context *context,
+ EGLint flags,
+ EGLTime timeout,
+ EGLint *outResult)
+{
+ if (mStatus == EGL_SIGNALED)
+ {
+ *outResult = EGL_CONDITION_SATISFIED_KHR;
+ return egl::NoError();
+ }
+ if (((flags & EGL_SYNC_FLUSH_COMMANDS_BIT) != 0) && (context != nullptr))
+ {
+ angle::Result result = context->getImplementation()->flush(context);
+ if (result != angle::Result::Continue)
+ {
+ return ResultToEGL(result);
+ }
+ }
+ if (timeout == 0)
+ {
+ *outResult = EGL_TIMEOUT_EXPIRED_KHR;
+ return egl::NoError();
+ }
+
+ using NanoSeconds = std::chrono::duration<int64_t, std::nano>;
+ NanoSeconds duration = (timeout == EGL_FOREVER) ? NanoSeconds::max() : NanoSeconds(timeout);
+ std::cv_status waitStatus = std::cv_status::no_timeout;
+ mMutex.lock();
+ waitStatus = mCondVar.wait_for(mMutex, duration);
+ mMutex.unlock();
+
+ switch (waitStatus)
+ {
+ case std::cv_status::no_timeout: // Signaled.
+ *outResult = EGL_CONDITION_SATISFIED_KHR;
+ break;
+ case std::cv_status::timeout: // Timed-out.
+ *outResult = EGL_TIMEOUT_EXPIRED_KHR;
+ break;
+ default:
+ break;
+ }
+ return egl::NoError();
+}
+
+egl::Error ReusableSync::serverWait(const egl::Display *display,
+ const gl::Context *context,
+ EGLint flags)
+{
+ // Does not support server wait.
+ return egl::EglBadMatch();
+}
+
+egl::Error ReusableSync::signal(const egl::Display *display,
+ const gl::Context *context,
+ EGLint mode)
+{
+ if (mode == EGL_SIGNALED)
+ {
+ if (mStatus == EGL_UNSIGNALED)
+ {
+ // Release all threads.
+ mCondVar.notify_all();
+ }
+ mStatus = EGL_SIGNALED;
+ }
+ else
+ {
+ mStatus = EGL_UNSIGNALED;
+ }
+ return egl::NoError();
+}
+
+egl::Error ReusableSync::getStatus(const egl::Display *display, EGLint *outStatus)
+{
+ *outStatus = mStatus;
+ return egl::NoError();
+}
+
+} // namespace rx