blob: 02e0c549452499ec716af105dc8e7b363142e749 [file]
//
// Copyright 2002 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.
//
// Display.cpp: Implements the egl::Display class, representing the abstract
// display on which graphics are drawn. Implements EGLDisplay.
// [EGL 1.4] section 2.1.2 page 3.
#include "libANGLE/Display.h"
#include "common/unsafe_buffers.h"
#include <algorithm>
#include <array>
#include <iterator>
#include <sstream>
#include <thread>
#include <vector>
#include <EGL/eglext.h>
#include <platform/PlatformMethods.h>
#include "anglebase/no_destructor.h"
#include "common/android_util.h"
#include "common/debug.h"
#include "common/mathutil.h"
#include "common/platform_helpers.h"
#include "common/string_utils.h"
#include "common/system_utils.h"
#include "common/tls.h"
#include "common/utilities.h"
#include "gpu_info_util/SystemInfo.h"
#include "image_util/loadimage.h"
#include "libANGLE/Constants.h"
#include "libANGLE/Context.h"
#include "libANGLE/Device.h"
#include "libANGLE/EGLSync.h"
#include "libANGLE/ErrorStrings.h"
#include "libANGLE/Image.h"
#include "libANGLE/ResourceManager.h"
#include "libANGLE/Stream.h"
#include "libANGLE/Surface.h"
#include "libANGLE/Thread.h"
#include "libANGLE/capture/FrameCapture.h"
#include "libANGLE/histogram_macros.h"
#include "libANGLE/renderer/DeviceImpl.h"
#include "libANGLE/renderer/DisplayImpl.h"
#include "libANGLE/renderer/EGLReusableSync.h"
#include "libANGLE/renderer/ImageImpl.h"
#include "libANGLE/trace.h"
#if defined(ANGLE_USE_PERFETTO)
# include <perfetto/tracing/tracing.h>
#endif
#if defined(ANGLE_USE_X11) || defined(ANGLE_USE_WAYLAND)
# include "common/linux/window_system.h"
#endif
#if defined(ANGLE_PLATFORM_APPLE)
# include <dispatch/dispatch.h>
# include "common/tls.h"
#endif
#if defined(ANGLE_ENABLE_D3D11)
# include "libANGLE/renderer/d3d/DisplayD3D.h"
#endif
#if defined(ANGLE_ENABLE_OPENGL)
# if defined(ANGLE_PLATFORM_WINDOWS)
# include "libANGLE/renderer/gl/wgl/DisplayWGL.h"
# elif ANGLE_ENABLE_CGL
# include "libANGLE/renderer/gl/cgl/DisplayCGL.h"
# elif defined(ANGLE_PLATFORM_LINUX)
# include "libANGLE/renderer/gl/egl/DisplayEGL.h"
# if defined(ANGLE_USE_X11)
# include "libANGLE/renderer/gl/glx/DisplayGLX_api.h"
# endif
# elif defined(ANGLE_PLATFORM_ANDROID)
# include "libANGLE/renderer/gl/egl/android/DisplayAndroid.h"
# else
# error Unsupported OpenGL platform.
# endif
#endif
#if defined(ANGLE_ENABLE_NULL)
# include "libANGLE/renderer/null/DisplayNULL.h"
#endif // defined(ANGLE_ENABLE_NULL)
#if defined(ANGLE_ENABLE_WGPU)
# include "libANGLE/renderer/wgpu/DisplayWgpu_api.h"
#endif
#if defined(ANGLE_ENABLE_VULKAN)
# include "libANGLE/renderer/vulkan/DisplayVk_api.h"
#endif // defined(ANGLE_ENABLE_VULKAN)
#if defined(ANGLE_ENABLE_METAL)
# include "libANGLE/renderer/metal/DisplayMtl_api.h"
#endif // defined(ANGLE_ENABLE_METAL)
namespace egl
{
namespace
{
#if defined(ANGLE_USE_PERFETTO)
# if defined(ANGLE_PLATFORM_ANDROID) && PERFETTO_BUILDFLAG(PERFETTO_IPC)
bool isPerfettoTraceEnabledOnAndroid()
{
std::string debugAngleEnablePerfetto;
return angle::android::GetSystemProperty("debug.angle.perfetto_trace.enabled",
&debugAngleEnablePerfetto) &&
debugAngleEnablePerfetto == "1";
}
# endif // defined(ANGLE_PLATFORM_ANDROID) && PERFETTO_BUILDFLAG(PERFETTO_IPC)
void MaybeInitializePerfetto()
{
// TrackEvent::Register() can only be done after Perfetto itself has been
// initialized (typically by the embedder).
// Android process doesn't initialize Perfetto by default, so we will
// initialize it with perfetto::kSystemBackend when:
// 1) debug.angle.perfetto_trace.enabled is set to 1.
// 2) PERFETTO_IPC is defined.
static std::once_flag sInitOnce;
std::call_once(sInitOnce, []() {
# if defined(ANGLE_PLATFORM_ANDROID) && PERFETTO_BUILDFLAG(PERFETTO_IPC)
if (!perfetto::Tracing::IsInitialized() && isPerfettoTraceEnabledOnAndroid())
{
perfetto::TracingInitArgs args;
args.backends = perfetto::kSystemBackend;
perfetto::Tracing::Initialize(args);
}
# endif // defined(ANGLE_PLATFORM_ANDROID) && PERFETTO_BUILDFLAG(PERFETTO_IPC)
// If Perfetto is already initialized, register ANGLE's categories now.
if (perfetto::Tracing::IsInitialized())
{
angle_tracing::TrackEvent::Register();
}
});
}
#endif // defined(ANGLE_USE_PERFETTO)
struct TLSData
{
angle::UnlockedTailCall unlockedTailCall;
Error errorScratchSpace;
TLSData();
};
TLSData::TLSData() : errorScratchSpace(0) {}
#if defined(ANGLE_PLATFORM_APPLE)
// TODO(http://anglebug.com/42264979): Due to a bug in Apple's dyld loader, `thread_local` will
// cause excessive memory use. Temporarily avoid it by using pthread's thread local storage instead.
static angle::TLSIndex GetDisplayTLSIndex()
{
static angle::TLSIndex DisplayIndex = TLS_INVALID_INDEX;
static dispatch_once_t once;
dispatch_once(&once, ^{
ASSERT(DisplayIndex == TLS_INVALID_INDEX);
DisplayIndex = angle::CreateTLSIndex(nullptr);
});
return DisplayIndex;
}
TLSData *GetDisplayTLS()
{
angle::TLSIndex DisplayIndex = GetDisplayTLSIndex();
ASSERT(DisplayIndex != TLS_INVALID_INDEX);
return static_cast<TLSData *>(angle::GetTLSValue(DisplayIndex));
}
void SetDisplayTLS(TLSData *tlsData)
{
angle::TLSIndex DisplayIndex = GetDisplayTLSIndex();
ASSERT(DisplayIndex != TLS_INVALID_INDEX);
angle::SetTLSValue(DisplayIndex, tlsData);
}
#else
// Tail calls generated during execution of the entry point, to be run at the end of the entry
// point. gTLSData->unlockedTailCall.run() is called at the end of any EGL entry point that is
// expected to generate such calls. At the end of every other call, it is asserted that this is
// empty.
thread_local TLSData *gDisplayTLS = nullptr;
TLSData *GetDisplayTLS()
{
return gDisplayTLS;
}
#endif
constexpr angle::SubjectIndex kGPUSwitchedSubjectIndex = 0;
static constexpr size_t kWindowSurfaceMapSize = 32;
typedef angle::FlatUnorderedMap<EGLNativeWindowType, Surface *, kWindowSurfaceMapSize>
WindowSurfaceMap;
// Get a map of all EGL window surfaces to validate that no window has more than one EGL surface
// associated with it.
static WindowSurfaceMap *GetWindowSurfaces()
{
static angle::base::NoDestructor<WindowSurfaceMap> windowSurfaces;
return windowSurfaces.get();
}
size_t EGLStringArrayHash(const char **ary)
{
size_t hash = 0;
if (ary != nullptr)
{
for (; *ary != nullptr; ANGLE_UNSAFE_TODO(ary++))
{
hash ^= std::hash<std::string>{}(std::string(*ary));
}
}
return hash;
}
// EGL_PLATFORM_ANGLE_VULKAN_DEVICE_UUID_ANGLE and
// EGL_PLATFORM_ANGLE_VULKAN_DRIVER_UUID_ANGLE are pointers to kVulkanUUIDSize
// bytes rather than values, so everything that outlives eglGetPlatformDisplay
// holds a copy of the pointed-to bytes. Keying the display map on the pointer
// itself would both separate displays that requested the same device through
// different buffers and alias displays whose buffers happened to be reused at
// the same address.
//
// An absent attribute yields an all-zero UUID, matching the convention used for
// the other attributes in the key.
VulkanUUID EGLAttribToVulkanUUID(EGLAttrib attrib)
{
VulkanUUID uuid = {};
if (attrib != 0)
{
// SAFETY: the extension requires the attribute to point to
// kVulkanUUIDSize bytes, which is exactly the size of `uuid`.
ANGLE_UNSAFE_BUFFERS(
memcpy(uuid.data(), reinterpret_cast<const uint8_t *>(attrib), kVulkanUUIDSize));
}
return uuid;
}
// DisplayState keeps an absent attribute distinct from a UUID value, because
// the Vulkan backend matches a physical device by UUID only when one was
// actually requested.
std::optional<VulkanUUID> EGLAttribToOptionalVulkanUUID(EGLAttrib attrib)
{
if (attrib == 0)
{
return std::nullopt;
}
return EGLAttribToVulkanUUID(attrib);
}
struct ANGLEPlatformDisplay
{
ANGLEPlatformDisplay() = default;
ANGLEPlatformDisplay(EGLNativeDisplayType nativeDisplayType)
: nativeDisplayType(nativeDisplayType)
{}
ANGLEPlatformDisplay(EGLNativeDisplayType nativeDisplayType,
EGLAttrib powerPreference,
EGLAttrib platformANGLEType,
EGLAttrib deviceIdHigh,
EGLAttrib deviceIdLow,
EGLAttrib displayKey,
EGLAttrib nativePlatformType,
EGLAttrib x11VisualID,
EGLAttrib vulkanDeviceUUID,
EGLAttrib vulkanDriverUUID,
EGLAttrib vulkanDriverID,
EGLAttrib enabledFeatureOverrides,
EGLAttrib disabledFeatureOverrides,
EGLAttrib disableAllNonOverriddenFeatures)
: nativeDisplayType(nativeDisplayType),
powerPreference(powerPreference),
platformANGLEType(platformANGLEType),
deviceIdHigh(deviceIdHigh),
deviceIdLow(deviceIdLow),
displayKey(displayKey),
nativePlatformType(nativePlatformType),
x11VisualID(x11VisualID),
vulkanDeviceUUID(EGLAttribToVulkanUUID(vulkanDeviceUUID)),
vulkanDriverUUID(EGLAttribToVulkanUUID(vulkanDriverUUID)),
vulkanDriverID(vulkanDriverID),
disableAllNonOverriddenFeatures(static_cast<bool>(disableAllNonOverriddenFeatures))
{
enabledFeatureOverridesHash =
EGLStringArrayHash(reinterpret_cast<const char **>(enabledFeatureOverrides));
disabledFeatureOverridesHash =
EGLStringArrayHash(reinterpret_cast<const char **>(disabledFeatureOverrides));
}
auto tie() const
{
return std::tie(nativeDisplayType, powerPreference, platformANGLEType, deviceIdHigh,
deviceIdLow, displayKey, nativePlatformType, x11VisualID, vulkanDeviceUUID,
vulkanDriverUUID, vulkanDriverID, enabledFeatureOverridesHash,
disabledFeatureOverridesHash, disableAllNonOverriddenFeatures);
}
EGLNativeDisplayType nativeDisplayType{EGL_DEFAULT_DISPLAY};
EGLAttrib powerPreference{EGL_LOW_POWER_ANGLE};
EGLAttrib platformANGLEType{EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE};
EGLAttrib deviceIdHigh{0};
EGLAttrib deviceIdLow{0};
EGLAttrib displayKey{0};
EGLAttrib nativePlatformType{0};
EGLAttrib x11VisualID{0};
VulkanUUID vulkanDeviceUUID{};
VulkanUUID vulkanDriverUUID{};
EGLAttrib vulkanDriverID{0};
size_t enabledFeatureOverridesHash;
size_t disabledFeatureOverridesHash;
bool disableAllNonOverriddenFeatures;
};
inline bool operator==(const ANGLEPlatformDisplay &a, const ANGLEPlatformDisplay &b)
{
return a.tie() == b.tie();
}
template <typename Key, size_t N>
class PlatformDisplayMap : angle::NonCopyable
{
public:
PlatformDisplayMap() = default;
Display *get(const Key &key)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
auto iter = mDisplays.find(key);
return (iter != mDisplays.end()) ? iter->second : nullptr;
}
template <typename CreateDisplayFunc>
Display *getOrInsert(const Key &key, CreateDisplayFunc createDisplayFunc)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
auto iter = mDisplays.find(key);
if (iter != mDisplays.end())
{
return iter->second;
}
Display *display = createDisplayFunc();
if (display != nullptr)
{
mDisplays.insert(std::make_pair(key, display));
}
return display;
}
Display *getDisplayFromDevice(Device *device)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
for (const auto &displayMapEntry : mDisplays)
{
Display *iterDisplay = displayMapEntry.second;
if (iterDisplay->getDevice() == device)
{
return iterDisplay;
}
}
return nullptr;
}
// Erasing by identity spares the caller of getOrInsert() from having to
// reproduce the key later. Some of the attributes a key is built from are
// pointers into memory the application owns, which it is free to release
// once eglGetPlatformDisplay has returned.
void eraseDisplay(const Display *display)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
for (auto iter = mDisplays.begin(); iter != mDisplays.end(); ++iter)
{
if (iter->second == display)
{
mDisplays.erase(iter);
return;
}
}
}
void erase(const Key &key)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
auto iter = mDisplays.find(key);
if (iter != mDisplays.end())
{
mDisplays.erase(iter);
}
}
bool contains(const egl::Display *display) const
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
for (const auto &displayPair : mDisplays)
{
if (displayPair.second == display)
{
return true;
}
}
return false;
}
private:
angle::FlatUnorderedMap<Key, Display *, N> mDisplays;
mutable angle::SimpleMutex mMutex;
};
static constexpr size_t kANGLEPlatformDisplayMapSize = 9;
using ANGLEPlatformDisplayMap =
PlatformDisplayMap<ANGLEPlatformDisplay, kANGLEPlatformDisplayMapSize>;
static ANGLEPlatformDisplayMap *GetANGLEPlatformDisplayMap()
{
static angle::base::NoDestructor<ANGLEPlatformDisplayMap> displays;
return displays.get();
}
static constexpr size_t kDevicePlatformDisplayMapSize = 8;
using DevicePlatformDisplayMap = PlatformDisplayMap<Device *, kDevicePlatformDisplayMapSize>;
static DevicePlatformDisplayMap *GetDevicePlatformDisplayMap()
{
static angle::base::NoDestructor<DevicePlatformDisplayMap> displays;
return displays.get();
}
rx::DisplayImpl *CreateDisplayFromDevice(Device *eglDevice, const DisplayState &state)
{
rx::DisplayImpl *impl = nullptr;
#if defined(ANGLE_ENABLE_D3D11)
if (eglDevice->getExtensions().deviceD3D11)
{
impl = new rx::DisplayD3D(state);
}
#endif
ASSERT(impl != nullptr);
return impl;
}
// On platforms with support for multiple back-ends, allow an environment variable to control
// the default. This is useful to run angle with benchmarks without having to modify the
// benchmark source. Possible values for this environment variable (ANGLE_DEFAULT_PLATFORM)
// are: vulkan, gl, d3d11, null.
EGLAttrib GetDisplayTypeFromEnvironment()
{
std::string angleDefaultEnv = angle::GetEnvironmentVar("ANGLE_DEFAULT_PLATFORM");
angle::ToLower(&angleDefaultEnv);
#if defined(ANGLE_ENABLE_VULKAN)
if ((angleDefaultEnv == "vulkan") || (angleDefaultEnv == "vulkan-null") ||
(angleDefaultEnv == "swiftshader"))
{
return EGL_PLATFORM_ANGLE_TYPE_VULKAN_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_WGPU)
if (angleDefaultEnv == "webgpu")
{
return EGL_PLATFORM_ANGLE_TYPE_WEBGPU_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_OPENGL)
if (angleDefaultEnv == "gl")
{
return EGL_PLATFORM_ANGLE_TYPE_OPENGLES_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_D3D11)
if (angleDefaultEnv == "d3d11")
{
return EGL_PLATFORM_ANGLE_TYPE_D3D11_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_METAL)
if (angleDefaultEnv == "metal")
{
return EGL_PLATFORM_ANGLE_TYPE_METAL_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_NULL)
if (angleDefaultEnv == "null")
{
return EGL_PLATFORM_ANGLE_TYPE_NULL_ANGLE;
}
#endif
#if defined(ANGLE_ENABLE_D3D11)
return EGL_PLATFORM_ANGLE_TYPE_D3D11_ANGLE;
#elif defined(ANGLE_ENABLE_VULKAN) && defined(ANGLE_PLATFORM_ANDROID)
return EGL_PLATFORM_ANGLE_TYPE_VULKAN_ANGLE;
#elif defined(ANGLE_ENABLE_OPENGL)
# if defined(ANGLE_PLATFORM_ANDROID) || defined(ANGLE_USE_GBM)
return EGL_PLATFORM_ANGLE_TYPE_OPENGLES_ANGLE;
# else
return EGL_PLATFORM_ANGLE_TYPE_OPENGL_ANGLE;
# endif
#elif defined(ANGLE_ENABLE_METAL)
return EGL_PLATFORM_ANGLE_TYPE_METAL_ANGLE;
#elif defined(ANGLE_ENABLE_VULKAN)
return EGL_PLATFORM_ANGLE_TYPE_VULKAN_ANGLE;
#elif defined(ANGLE_ENABLE_NULL)
return EGL_PLATFORM_ANGLE_TYPE_NULL_ANGLE;
#else
# error No default ANGLE platform type
#endif
}
EGLAttrib GetDeviceTypeFromEnvironment()
{
std::string angleDefaultEnv = angle::GetEnvironmentVar("ANGLE_DEFAULT_PLATFORM");
angle::ToLower(&angleDefaultEnv);
#if defined(ANGLE_ENABLE_VULKAN)
if (angleDefaultEnv == "vulkan-null")
{
return EGL_PLATFORM_ANGLE_DEVICE_TYPE_NULL_ANGLE;
}
else if (angleDefaultEnv == "swiftshader")
{
return EGL_PLATFORM_ANGLE_DEVICE_TYPE_SWIFTSHADER_ANGLE;
}
#endif
return EGL_PLATFORM_ANGLE_DEVICE_TYPE_HARDWARE_ANGLE;
}
EGLAttrib GetPlatformTypeFromEnvironment()
{
#if defined(ANGLE_USE_X11) || defined(ANGLE_USE_WAYLAND)
// Reached when the caller supplied no native platform type, as EGL 1.4
// eglGetDisplay() cannot. Delegate to the shared policy so this implicit
// choice agrees with the util window layer (common/linux/window_system.h).
# if defined(ANGLE_USE_X11)
constexpr bool kX11Compiled = true;
# else
constexpr bool kX11Compiled = false;
# endif
# if defined(ANGLE_USE_WAYLAND)
constexpr bool kWaylandCompiled = true;
# else
constexpr bool kWaylandCompiled = false;
# endif
switch (angle::ChoosePreferredWindowSystem(kX11Compiled, kWaylandCompiled,
angle::GetWindowSystemFromEnvironment()))
{
case angle::WindowSystem::X11:
return EGL_PLATFORM_X11_EXT;
case angle::WindowSystem::Wayland:
return EGL_PLATFORM_WAYLAND_EXT;
case angle::WindowSystem::Unspecified:
break;
}
return 0;
#elif defined(ANGLE_USE_VULKAN_DISPLAY) && defined(ANGLE_VULKAN_DISPLAY_MODE_SIMPLE)
return EGL_PLATFORM_VULKAN_DISPLAY_MODE_SIMPLE_ANGLE;
#elif defined(ANGLE_USE_VULKAN_DISPLAY) && defined(ANGLE_VULKAN_DISPLAY_MODE_HEADLESS)
return EGL_PLATFORM_VULKAN_DISPLAY_MODE_HEADLESS_ANGLE;
#else
return 0;
#endif
}
EGLAttrib GetPlatformTypeFromAttribs(EGLenum platform, const AttributeMap &attribMap)
{
if (platform == EGL_PLATFORM_ANGLE_ANGLE)
{
return attribMap.get(EGL_PLATFORM_ANGLE_NATIVE_PLATFORM_TYPE_ANGLE, 0);
}
return platform;
}
rx::DisplayImpl *CreateDisplayFromAttribs(EGLAttrib displayType,
EGLAttrib deviceType,
EGLAttrib platformType,
const DisplayState &state)
{
ASSERT(displayType != EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE);
rx::DisplayImpl *impl = nullptr;
switch (displayType)
{
case EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE:
UNREACHABLE();
break;
case EGL_PLATFORM_ANGLE_TYPE_D3D11_ANGLE:
#if defined(ANGLE_ENABLE_D3D11)
impl = new rx::DisplayD3D(state);
break;
#else
// A D3D display was requested on a platform that doesn't support it
UNREACHABLE();
break;
#endif
case EGL_PLATFORM_ANGLE_TYPE_OPENGL_ANGLE:
#if defined(ANGLE_ENABLE_OPENGL)
# if defined(ANGLE_PLATFORM_WINDOWS)
impl = new rx::DisplayWGL(state);
break;
# elif ANGLE_ENABLE_CGL
impl = new rx::DisplayCGL(state);
break;
# elif defined(ANGLE_PLATFORM_LINUX)
# if defined(ANGLE_USE_GBM) || defined(ANGLE_USE_WAYLAND)
if (platformType == 0)
{
impl = new rx::DisplayEGL(state);
break;
}
if (platformType == EGL_PLATFORM_GBM_KHR)
{
impl = new rx::DisplayEGL(state);
break;
}
# endif
if (deviceType == EGL_PLATFORM_ANGLE_DEVICE_TYPE_EGL_ANGLE)
{
impl = new rx::DisplayEGL(state);
break;
}
# if defined(ANGLE_USE_X11)
if (platformType == EGL_PLATFORM_X11_EXT)
{
impl = rx::CreateGLXDisplay(state);
break;
}
# endif
# if defined(ANGLE_USE_WAYLAND)
if (platformType == EGL_PLATFORM_WAYLAND_EXT)
{
impl = new rx::DisplayEGL(state);
break;
}
# endif
if (platformType == EGL_PLATFORM_SURFACELESS_MESA)
{
impl = new rx::DisplayEGL(state);
break;
}
break;
# elif defined(ANGLE_PLATFORM_ANDROID)
// No GL support on this platform, fail display creation.
impl = nullptr;
break;
# else
# error Unsupported OpenGL platform.
# endif
#else
// No display available
UNREACHABLE();
break;
#endif // defined(ANGLE_ENABLE_OPENGL)
case EGL_PLATFORM_ANGLE_TYPE_OPENGLES_ANGLE:
#if defined(ANGLE_ENABLE_OPENGL)
# if defined(ANGLE_PLATFORM_WINDOWS)
impl = new rx::DisplayWGL(state);
# elif defined(ANGLE_PLATFORM_LINUX)
# if defined(ANGLE_USE_GBM) || defined(ANGLE_USE_WAYLAND)
if (platformType == 0)
{
impl = new rx::DisplayEGL(state);
break;
}
if (platformType == EGL_PLATFORM_GBM_KHR)
{
impl = new rx::DisplayEGL(state);
break;
}
# endif
if (deviceType == EGL_PLATFORM_ANGLE_DEVICE_TYPE_EGL_ANGLE)
{
impl = new rx::DisplayEGL(state);
break;
}
else
{
# if defined(ANGLE_USE_X11)
if (platformType == EGL_PLATFORM_X11_EXT)
{
impl = rx::CreateGLXDisplay(state);
break;
}
# endif
# if defined(ANGLE_USE_WAYLAND)
if (platformType == EGL_PLATFORM_WAYLAND_EXT)
{
impl = new rx::DisplayEGL(state);
break;
}
# endif
if (platformType == EGL_PLATFORM_SURFACELESS_MESA)
{
impl = new rx::DisplayEGL(state);
break;
}
}
# elif defined(ANGLE_PLATFORM_ANDROID)
impl = new rx::DisplayAndroid(state);
# else
// No GLES support on this platform, fail display creation.
impl = nullptr;
# endif
#endif // defined(ANGLE_ENABLE_OPENGL)
break;
case EGL_PLATFORM_ANGLE_TYPE_VULKAN_ANGLE:
#if defined(ANGLE_ENABLE_VULKAN)
# if defined(ANGLE_USE_VULKAN_NULL_DISPLAY)
if (rx::IsVulkanNullDisplayAvailable())
{
impl = rx::CreateVulkanNullDisplay(state);
}
break;
# elif defined(ANGLE_PLATFORM_WINDOWS)
if (rx::IsVulkanWin32DisplayAvailable())
{
impl = rx::CreateVulkanWin32Display(state);
}
break;
# elif defined(ANGLE_PLATFORM_LINUX)
# if defined(ANGLE_USE_GBM)
if (platformType == EGL_PLATFORM_GBM_KHR && rx::IsVulkanGbmDisplayAvailable())
{
impl = rx::CreateVulkanGbmDisplay(state);
break;
}
# endif
# if defined(ANGLE_USE_X11)
if (platformType == EGL_PLATFORM_X11_EXT && rx::IsVulkanXcbDisplayAvailable())
{
impl = rx::CreateVulkanXcbDisplay(state);
break;
}
# endif
# if defined(ANGLE_USE_WAYLAND)
if (platformType == EGL_PLATFORM_WAYLAND_EXT && rx::IsVulkanWaylandDisplayAvailable())
{
impl = rx::CreateVulkanWaylandDisplay(state);
break;
}
# endif
if (platformType == EGL_PLATFORM_SURFACELESS_MESA &&
rx::IsVulkanOffscreenDisplayAvailable())
{
impl = rx::CreateVulkanOffscreenDisplay(state);
break;
}
# if defined(ANGLE_USE_VULKAN_DISPLAY)
if (platformType == EGL_PLATFORM_VULKAN_DISPLAY_MODE_SIMPLE_ANGLE &&
rx::IsVulkanSimpleDisplayAvailable())
{
impl = rx::CreateVulkanSimpleDisplay(state);
}
else if (platformType == EGL_PLATFORM_VULKAN_DISPLAY_MODE_HEADLESS_ANGLE &&
rx::IsVulkanHeadlessDisplayAvailable())
{
impl = rx::CreateVulkanHeadlessDisplay(state);
}
else if (rx::IsVulkanOffscreenDisplayAvailable())
{
impl = rx::CreateVulkanOffscreenDisplay(state);
}
else
{
// Not supported creation type on vulkan display, fail display creation.
impl = nullptr;
}
# endif
break;
# elif defined(ANGLE_PLATFORM_ANDROID)
if (rx::IsVulkanAndroidDisplayAvailable())
{
impl = rx::CreateVulkanAndroidDisplay(state);
}
break;
# elif defined(ANGLE_PLATFORM_FUCHSIA)
if (rx::IsVulkanFuchsiaDisplayAvailable())
{
impl = rx::CreateVulkanFuchsiaDisplay(state);
}
break;
# elif defined(ANGLE_PLATFORM_APPLE)
if (rx::IsVulkanMacDisplayAvailable())
{
impl = rx::CreateVulkanMacDisplay(state);
}
break;
# else
# error Unsupported Vulkan platform.
# endif
#else
// Vulkan isn't available
break;
#endif // defined(ANGLE_ENABLE_VULKAN)
case EGL_PLATFORM_ANGLE_TYPE_METAL_ANGLE:
#if defined(ANGLE_ENABLE_METAL)
if (rx::IsMetalDisplayAvailable())
{
impl = rx::CreateMetalDisplay(state);
break;
}
#endif
// Metal isn't available.
break;
case EGL_PLATFORM_ANGLE_TYPE_WEBGPU_ANGLE:
#if defined(ANGLE_ENABLE_WGPU)
impl = rx::CreateWgpuDisplay(state);
#endif // defined(ANGLE_ENABLE_WGPU)
// WebGPU isn't available.
break;
case EGL_PLATFORM_ANGLE_TYPE_NULL_ANGLE:
#if defined(ANGLE_ENABLE_NULL)
impl = new rx::DisplayNULL(state);
break;
#else
// No display available
UNREACHABLE();
break;
#endif // defined(ANGLE_ENABLE_NULL)
default:
UNREACHABLE();
break;
}
return impl;
}
void Display_logError(angle::PlatformMethods *platform, const char *errorMessage)
{
gl::Trace(gl::LOG_ERR, errorMessage);
}
void Display_logWarning(angle::PlatformMethods *platform, const char *warningMessage)
{
gl::Trace(gl::LOG_WARN, warningMessage);
}
void Display_logInfo(angle::PlatformMethods *platform, const char *infoMessage)
{
// Uncomment to get info spam
#if defined(ANGLE_ENABLE_DEBUG_TRACE)
gl::Trace(gl::LOG_INFO, infoMessage);
#endif
}
const std::vector<std::string> EGLStringArrayToStringVector(const char **ary)
{
std::vector<std::string> vec;
if (ary != nullptr)
{
for (; *ary != nullptr; ANGLE_UNSAFE_TODO(ary++))
{
vec.push_back(std::string(*ary));
}
}
return vec;
}
void ANGLESetDefaultDisplayPlatform(angle::EGLDisplayType display)
{
angle::PlatformMethods *platformMethods = ANGLEPlatformCurrent();
ANGLEResetDisplayPlatform(display);
platformMethods->logError = Display_logError;
platformMethods->logWarning = Display_logWarning;
platformMethods->logInfo = Display_logInfo;
}
void UpdateAttribsFromEnvironment(AttributeMap &attribMap)
{
EGLAttrib displayType =
attribMap.get(EGL_PLATFORM_ANGLE_TYPE_ANGLE, EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE);
if (displayType == EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE)
{
displayType = GetDisplayTypeFromEnvironment();
attribMap.insert(EGL_PLATFORM_ANGLE_TYPE_ANGLE, displayType);
}
EGLAttrib deviceType = attribMap.get(EGL_PLATFORM_ANGLE_DEVICE_TYPE_ANGLE, 0);
if (deviceType == 0)
{
deviceType = GetDeviceTypeFromEnvironment();
attribMap.insert(EGL_PLATFORM_ANGLE_DEVICE_TYPE_ANGLE, deviceType);
}
EGLAttrib platformType = attribMap.get(EGL_PLATFORM_ANGLE_NATIVE_PLATFORM_TYPE_ANGLE, 0);
if (platformType == 0)
{
platformType = GetPlatformTypeFromEnvironment();
attribMap.insert(EGL_PLATFORM_ANGLE_NATIVE_PLATFORM_TYPE_ANGLE, platformType);
}
}
static constexpr uint32_t kScratchBufferLifetime = 64u;
class [[nodiscard]] ScopedResetThreadContextOnError : angle::NonCopyable
{
public:
ScopedResetThreadContextOnError(Thread *thread, bool resetOnError)
: mThread(thread), mResetOnError(resetOnError)
{}
~ScopedResetThreadContextOnError()
{
if (mResetOnError)
{
mThread->setCurrent(nullptr);
}
}
// No error, so reset won't happen
void success() { mResetOnError = false; }
private:
Thread *mThread;
bool mResetOnError;
};
} // anonymous namespace
SyncSet::SyncSet() : mHandleAllocator(gl::IMPLEMENTATION_MAX_OBJECT_HANDLES) {}
SyncSet::~SyncSet()
{
clearPools();
}
Error SyncSet::createSync(const ThreadSafeDisplay *display,
const gl::Context *currentContext,
EGLenum type,
const AttributeMap &attribs,
Sync **outSync)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
SyncID id;
if (!mHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
std::unique_ptr<Sync> sync;
SyncPool &pool = mSyncPools[type];
if (!pool.empty())
{
sync = std::move(pool.back());
pool.pop_back();
}
else
{
sync.reset(new Sync(display->getImplementation(), type));
}
Error err = sync->initialize(display, currentContext, id, attribs);
if (err.isError())
{
mHandleAllocator.release(id.value);
sync->onDestroy(display);
return err;
}
// The sync is now owned by the sync map.
sync->addRef();
*outSync = sync.release();
mSyncMap.insert(std::pair(id.value, *outSync));
return NoError();
}
ScopedSyncRef SyncSet::getSync(ThreadSafeDisplay *display, SyncID syncID) const
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
auto iter = mSyncMap.find(syncID.value);
if (iter != mSyncMap.end())
{
return ScopedSyncRef(display, iter->second);
}
return ScopedSyncRef();
}
void SyncSet::destroySync(const ThreadSafeDisplay *display, SyncID syncID)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
auto iter = mSyncMap.find(syncID.value);
if (iter == mSyncMap.end())
{
return;
}
mHandleAllocator.release(syncID.value);
Sync *sync = iter->second;
mSyncMap.erase(iter);
if (sync->releaseRef())
{
releaseSyncImpl(display, sync);
}
}
void SyncSet::releaseSync(const ThreadSafeDisplay *display, Sync *sync)
{
if (sync == nullptr)
{
return;
}
if (sync->releaseRef())
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
releaseSyncImpl(display, sync);
}
}
void SyncSet::releaseSyncImpl(const ThreadSafeDisplay *display, Sync *sync)
{
sync->onDestroy(display);
SyncPool &pool = mSyncPools[sync->getType()];
if (pool.size() < kMaxSyncPoolSizePerType)
{
pool.push_back(std::unique_ptr<Sync>(sync));
}
else
{
delete sync;
}
}
void SyncSet::invalidateAllSyncs()
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
mInvalidSyncMap.insert(mSyncMap.begin(), mSyncMap.end());
mSyncMap.clear();
}
void SyncSet::destroyAllInvalidSyncs(Display *display)
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
while (!mInvalidSyncMap.empty())
{
auto iter = mInvalidSyncMap.begin();
mHandleAllocator.release(iter->first);
Sync *sync = iter->second;
mInvalidSyncMap.erase(iter);
if (sync->releaseRef())
{
releaseSyncImpl(display, sync);
}
}
}
void SyncSet::clearPools()
{
std::lock_guard<angle::SimpleMutex> lock(mMutex);
mSyncPools.clear();
}
// DisplayState
DisplayState::DisplayState(EGLNativeDisplayType nativeDisplayId)
: label(nullptr),
displayId(nativeDisplayId),
singleThreadPool(nullptr),
multiThreadPool(nullptr),
deviceLost(false)
{}
DisplayState::~DisplayState() {}
void DisplayState::notifyDeviceLost() const
{
// Notify all contexts and surfaces that the device has been lost. This needs to be protected by
// contextMap lock so that it is set atomically. This is the only place it gets set to true.
contextMap.notifyDeviceLost(&deviceLost);
}
// ThreadSafeDisplay implementation:
bool ThreadSafeDisplay::isInitialized() const
{
return (mRefCount.load(std::memory_order_acquire) & kInitializedBit) != 0;
}
bool ThreadSafeDisplay::isTerminating() const
{
return (mRefCount.load(std::memory_order_acquire) & kTerminatingBit) != 0;
}
bool ThreadSafeDisplay::isInitializedAndNotTerminating() const
{
// A single load ensures the initialized and terminating bits are observed as a consistent
// pair. With two separate atomics, a reader could load an already-stale initialized flag and
// then observe the terminating bit after terminate() cleared it, reporting a state that never
// existed.
constexpr uint32_t kMask = kInitializedBit | kTerminatingBit;
return (mRefCount.load(std::memory_order_acquire) & kMask) == kInitializedBit;
}
void ThreadSafeDisplay::setInitialized()
{
// Read-modify-write rather than a plain store: the reference count bits in the same word may
// be concurrently modified by other threads.
mRefCount.fetch_or(kInitializedBit, std::memory_order_release);
}
void ThreadSafeDisplay::setUninitialized()
{
mRefCount.fetch_and(~kInitializedBit, std::memory_order_release);
}
bool ThreadSafeDisplay::isDeviceLost() const
{
ASSERT(isInitialized());
return mState.deviceLost.load(std::memory_order_relaxed);
}
ScopedSyncRef ThreadSafeDisplay::getSync(egl::SyncID syncID) const
{
// Looking up a sync does not modify the display, but the returned ScopedSyncRef releases the
// sync through ThreadSafeDisplay::releaseSync(), which does.
return mSyncSet.getSync(const_cast<ThreadSafeDisplay *>(this), syncID);
}
bool ThreadSafeDisplay::isValidSync(SyncID syncID) const
{
return getSync(syncID).get() != nullptr;
}
void ThreadSafeDisplay::releaseSync(Sync *sync)
{
mSyncSet.releaseSync(this, sync);
}
void ThreadSafeDisplay::destroySync(Sync *sync)
{
if (sync == nullptr)
{
return;
}
mSyncSet.destroySync(this, sync->id());
}
Error ThreadSafeDisplay::createSync(const gl::Context *currentContext,
EGLenum type,
const AttributeMap &attribs,
Sync **outSync)
{
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
return mSyncSet.createSync(this, currentContext, type, attribs, outSync);
}
Error ThreadSafeDisplay::restoreLostDevice() const
{
// If reset notifications have been requested, application must delete all contexts first
const bool noResetNotificationRequested = mState.contextMap.forEach(
[](gl::Context *context) { return !context->isResetNotificationEnabled(); });
if (!noResetNotificationRequested)
{
return egl::Error(EGL_CONTEXT_LOST);
}
return mThreadSafeImpl->restoreLostDevice(this);
}
// Note that ANGLE support on Ozone platform is limited. Our preferred support Matrix for
// EGL_ANGLE_platform_angle on Linux and Ozone/Linux/Fuchsia platforms should be the following:
//
// |--------------------------------------------------------|
// | ANGLE type | DEVICE type | PLATFORM type | Display |
// |--------------------------------------------------------|
// | OPENGL | EGL | ANY | EGL |
// | OPENGL | HARDWARE | X11_EXT | GLX |
// | OPENGLES | HARDWARE | X11_EXT | GLX |
// | OPENGLES | EGL | ANY | EGL |
// | VULKAN | HARDWARE | X11_EXT | VkXcb |
// | VULKAN | SWIFTSHADER | X11_EXT | VkXcb |
// | OPENGLES | HARDWARE | SURFACELESS_MESA | EGL* |
// | OPENGLES | HARDWARE | DEVICE_EXT | EGL |
// | VULKAN | HARDWARE | SURFACELESS_MESA | VkBase** |
// | VULKAN | SWIFTSHADER | SURFACELESS_MESA | VkBase** |
// |--------------------------------------------------------|
//
// * No surfaceless support yet.
// ** Not implemented yet.
//
// |-----------------------------------------------|
// | OS | BUILD type | Default PLATFORM type |
// |-----------------------------------------------|
// | Linux | X11 | X11_EXT |
// | Linux | Ozone | SURFACELESS_MESA |
// | Fuchsia | Ozone | FUCHSIA*** |
// |-----------------------------------------------|
//
// *** Chosen implicitly. No EGLAttrib available.
//
// For more details, please refer to
// https://docs.google.com/document/d/1XjHiDZQISq1AMrg_l1TX1_kIKvDpU76hidn9i4cAjl8/edit?disco=AAAAJl9V_YY
//
// static
Display *Display::GetDisplayFromNativeDisplay(EGLenum platform,
EGLNativeDisplayType nativeDisplay,
const AttributeMap &attribMap)
{
Display *display = nullptr;
AttributeMap updatedAttribMap(attribMap);
UpdateAttribsFromEnvironment(updatedAttribMap);
const EGLAttrib powerPreference =
updatedAttribMap.get(EGL_POWER_PREFERENCE_ANGLE, EGL_LOW_POWER_ANGLE);
const EGLAttrib platformANGLEType =
updatedAttribMap.get(EGL_PLATFORM_ANGLE_TYPE_ANGLE, EGL_PLATFORM_ANGLE_TYPE_DEFAULT_ANGLE);
const EGLAttrib deviceIdHigh = updatedAttribMap.get(EGL_PLATFORM_ANGLE_DEVICE_ID_HIGH_ANGLE, 0);
const EGLAttrib deviceIdLow = updatedAttribMap.get(EGL_PLATFORM_ANGLE_DEVICE_ID_LOW_ANGLE, 0);
const EGLAttrib displayKey = updatedAttribMap.get(EGL_PLATFORM_ANGLE_DISPLAY_KEY_ANGLE, 0);
const EGLAttrib enabledFeatureOverrides =
updatedAttribMap.get(EGL_FEATURE_OVERRIDES_ENABLED_ANGLE, 0);
const EGLAttrib disabledFeatureOverrides =
updatedAttribMap.get(EGL_FEATURE_OVERRIDES_DISABLED_ANGLE, 0);
const EGLAttrib disableAllNonOverriddenFeatures =
updatedAttribMap.get(EGL_FEATURE_ALL_DISABLED_ANGLE, 0);
const EGLAttrib nativePlatformType = GetPlatformTypeFromAttribs(platform, updatedAttribMap);
const EGLAttrib x11VisualID = updatedAttribMap.get(EGL_X11_VISUAL_ID_ANGLE, 0);
const EGLAttrib vulkanDeviceUUID =
updatedAttribMap.get(EGL_PLATFORM_ANGLE_VULKAN_DEVICE_UUID_ANGLE, 0);
const EGLAttrib vulkanDriverUUID =
updatedAttribMap.get(EGL_PLATFORM_ANGLE_VULKAN_DRIVER_UUID_ANGLE, 0);
const EGLAttrib vulkanDriverID =
updatedAttribMap.get(EGL_PLATFORM_ANGLE_VULKAN_DRIVER_ID_ANGLE, 0);
const ANGLEPlatformDisplay combinedDisplayKey(
nativeDisplay, powerPreference, platformANGLEType, deviceIdHigh, deviceIdLow, displayKey,
nativePlatformType, x11VisualID, vulkanDeviceUUID, vulkanDriverUUID, vulkanDriverID,
enabledFeatureOverrides, disabledFeatureOverrides, disableAllNonOverriddenFeatures);
display = GetANGLEPlatformDisplayMap()->getOrInsert(
combinedDisplayKey, [platform, nativeDisplay]() -> Display * {
if (!Display::isValidNativeDisplay(nativeDisplay))
{
return nullptr;
}
return new Display(platform, nativeDisplay, nullptr);
});
if (display == nullptr)
{
return nullptr;
}
// Apply new attributes if the display is not initialized yet.
if (!display->initFromNativeDisplay(updatedAttribMap, nativePlatformType))
{
return nullptr;
}
return display;
}
// static
Display *Display::GetExistingDisplayFromNativeDisplay(EGLNativeDisplayType nativeDisplay)
{
return GetANGLEPlatformDisplayMap()->get(nativeDisplay);
}
// static
Display *Display::GetDisplayFromDevice(Device *device, const AttributeMap &attribMap)
{
Display *display = nullptr;
ASSERT(Device::IsValidDevice(device));
{
// First see if this eglDevice is in use by a Display created using ANGLE platform
display = GetANGLEPlatformDisplayMap()->getDisplayFromDevice(device);
}
if (display == nullptr)
{
// Next see if this eglDevice is in use by a Display created using the DEVICE platform
display = GetDevicePlatformDisplayMap()->getOrInsert(
device, [&]() -> Display * { return new Display(EGL_PLATFORM_DEVICE_EXT, 0, device); });
}
// Apply new attributes if the display is not initialized yet.
display->initFromDevice(device, attribMap);
return display;
}
Display::Display(EGLenum platform, EGLNativeDisplayType displayId, Device *eglDevice)
: ThreadSafeDisplay(displayId),
mImplementation(nullptr),
mGPUSwitchedBinding(this, kGPUSwitchedSubjectIndex),
mAttributeMap(),
mConfigSet(),
mStreamSet(),
mInvalidContextMap(),
mInvalidImageMap(),
mInvalidStreamSet(),
mInvalidSurfaceMap(),
mCaps(),
mDisplayExtensionString(),
mVendorString(),
mVersionString(),
mDevice(eglDevice),
mSurface(nullptr),
mPlatform(platform),
mManagersMutex(nullptr),
mTextureManager(nullptr),
mSemaphoreManager(nullptr),
mBlobCache(gl::kDefaultMaxProgramCacheMemoryBytes),
mMemoryProgramCache(mBlobCache),
mMemoryShaderCache(mBlobCache),
mGlobalTextureShareGroupUsers(0),
mGlobalSemaphoreShareGroupUsers(0),
mImageHandleAllocator(gl::IMPLEMENTATION_MAX_OBJECT_HANDLES),
mSurfaceHandleAllocator(gl::IMPLEMENTATION_MAX_OBJECT_HANDLES, 64),
mTerminatedByApi(false)
{}
Display::~Display()
{
switch (mPlatform)
{
case EGL_PLATFORM_ANGLE_ANGLE:
case EGL_PLATFORM_GBM_KHR:
case EGL_PLATFORM_WAYLAND_EXT:
case EGL_PLATFORM_SURFACELESS_MESA:
{
GetANGLEPlatformDisplayMap()->eraseDisplay(this);
break;
}
case EGL_PLATFORM_DEVICE_EXT:
{
GetDevicePlatformDisplayMap()->erase(mDevice);
break;
}
default:
{
UNREACHABLE();
}
}
SafeDelete(mDevice);
SafeDelete(mImplementation);
}
void Display::setLabel(EGLLabelKHR label)
{
mState.label = label;
}
EGLLabelKHR Display::getLabel() const
{
return mState.label;
}
void Display::onSubjectStateChange(angle::SubjectIndex index, angle::SubjectMessage message)
{
ASSERT(index == kGPUSwitchedSubjectIndex);
ASSERT(message == angle::SubjectMessage::SubjectChanged);
mState.contextMap.forEach([](gl::Context *context) { context->onGPUSwitch(); });
}
void Display::setupDisplayPlatform(rx::DisplayImpl *impl)
{
ASSERT(!isInitialized());
ASSERT(impl != nullptr);
mDisplayMutex.assertLocked();
SafeDelete(mImplementation);
mImplementation = impl;
mThreadSafeImpl = impl->getThreadSafeDisplayImpl();
// TODO(anglebug.com/42265835): Remove PlatformMethods.
const angle::PlatformMethods *platformMethods =
reinterpret_cast<const angle::PlatformMethods *>(
mAttributeMap.get(EGL_PLATFORM_ANGLE_PLATFORM_METHODS_ANGLEX, 0));
if (platformMethods != nullptr)
{
*ANGLEPlatformCurrent() = *platformMethods;
}
else
{
ANGLESetDefaultDisplayPlatform(this);
}
const char **featuresForceEnabled =
reinterpret_cast<const char **>(mAttributeMap.get(EGL_FEATURE_OVERRIDES_ENABLED_ANGLE, 0));
const char **featuresForceDisabled =
reinterpret_cast<const char **>(mAttributeMap.get(EGL_FEATURE_OVERRIDES_DISABLED_ANGLE, 0));
mState.featureOverrides.enabled = EGLStringArrayToStringVector(featuresForceEnabled);
mState.featureOverrides.disabled = EGLStringArrayToStringVector(featuresForceDisabled);
mState.featureOverrides.allDisabled =
static_cast<bool>(mAttributeMap.get(EGL_FEATURE_ALL_DISABLED_ANGLE, 0));
// Take the UUIDs by value here, while eglGetPlatformDisplay is still
// running. The backend consults them from eglInitialize, by which time the
// caller is free to have released the buffers the attributes point to.
mState.vulkanDeviceUUID = EGLAttribToOptionalVulkanUUID(
mAttributeMap.get(EGL_PLATFORM_ANGLE_VULKAN_DEVICE_UUID_ANGLE, 0));
mState.vulkanDriverUUID = EGLAttribToOptionalVulkanUUID(
mAttributeMap.get(EGL_PLATFORM_ANGLE_VULKAN_DRIVER_UUID_ANGLE, 0));
mImplementation->addObserver(&mGPUSwitchedBinding);
}
void Display::initFromDevice(Device *device, const AttributeMap &attribMap)
{
std::lock_guard<angle::SimpleMutex> lock(mDisplayMutex);
if (!isInitialized())
{
setAttributes(attribMap);
rx::DisplayImpl *impl = CreateDisplayFromDevice(device, getState());
setupDisplayPlatform(impl);
}
}
bool Display::initFromNativeDisplay(const AttributeMap &attribMap,
const EGLAttrib nativePlatformType)
{
std::lock_guard<angle::SimpleMutex> lock(mDisplayMutex);
if (!isInitialized())
{
setAttributes(attribMap);
EGLAttrib displayType = mAttributeMap.get(EGL_PLATFORM_ANGLE_TYPE_ANGLE);
EGLAttrib deviceType = mAttributeMap.get(EGL_PLATFORM_ANGLE_DEVICE_TYPE_ANGLE);
rx::DisplayImpl *impl =
CreateDisplayFromAttribs(displayType, deviceType, nativePlatformType, getState());
if (impl == nullptr)
{
// No valid display implementation for these attributes
return false;
}
#if defined(ANGLE_USE_ANDROID_TLS_SLOT)
angle::gUseAndroidOpenGLTlsSlot = displayType == EGL_PLATFORM_ANGLE_TYPE_VULKAN_ANGLE;
#endif // defined(ANGLE_PLATFORM_ANDROID)
setupDisplayPlatform(impl);
}
return true;
}
Error Display::initialize()
{
mDisplayMutex.assertLocked();
ASSERT(!isTerminating());
mTerminatedByApi = false;
#if defined(ANGLE_USE_PERFETTO)
// ANGLE's track event categories must be registered with Perfetto.
MaybeInitializePerfetto();
#endif
ASSERT(mImplementation != nullptr);
mImplementation->setBlobCache(&mBlobCache);
// Enable shader caching if debug layers are turned on. This allows us to test that shaders are
// properly saved & restored on all platforms. The cache won't allocate space until it's used
// and will be ignored entirely if the application / system sets it's own cache functions.
if (rx::ShouldUseDebugLayers(mAttributeMap))
{
mBlobCache.resize(1024 * 1024);
}
setGlobalDebugAnnotator();
gl::InitializeDebugMutexIfNeeded();
ANGLE_TRACE_EVENT0("gpu.angle", "egl::Display::initialize");
if (isInitialized())
{
return NoError();
}
Error error = mImplementation->initialize(this);
if (error.isError())
{
// Log extended error message here
ERR() << "ANGLE Display::initialize error " << error.getID() << ": " << error.getMessage();
return error;
}
mCaps = mImplementation->getCaps();
mConfigSet = mImplementation->generateConfigs();
if (mConfigSet.size() == 0)
{
mImplementation->terminate();
return egl::Error(EGL_NOT_INITIALIZED, "No configs were generated.");
}
// OpenGL ES1 is implemented in the frontend, explicitly add ES1 support to all configs
for (auto &config : mConfigSet)
{
// TODO(geofflang): Enable the conformant bit once we pass enough tests
// config.second.conformant |= EGL_OPENGL_ES_BIT;
config.second.renderableType |= EGL_OPENGL_ES_BIT;
}
mFrontendFeatures.reset();
rx::ApplyFeatureOverrides(&mFrontendFeatures, mState.featureOverrides);
if (!mState.featureOverrides.allDisabled)
{
initializeFrontendFeatures();
}
mFeatures.clear();
mFrontendFeatures.populateFeatureList(&mFeatures);
mImplementation->populateFeatureList(&mFeatures);
initDisplayExtensions();
initVendorString();
initVersionString();
initClientAPIString();
// Populate the Display's EGLDeviceEXT if the Display wasn't created using one
if (mPlatform == EGL_PLATFORM_DEVICE_EXT)
{
// For EGL_PLATFORM_DEVICE_EXT, mDevice should always be populated using
// an external device
ASSERT(mDevice != nullptr);
}
else if (GetClientExtensions().deviceQueryEXT)
{
std::unique_ptr<rx::DeviceImpl> impl(mImplementation->createDevice());
ASSERT(impl);
error = impl->initialize();
if (error.isError())
{
ERR() << "Failed to initialize display because device creation failed: "
<< error.getMessage();
mImplementation->terminate();
return error;
}
// Don't leak Device memory.
ASSERT(mDevice == nullptr);
mDevice = new Device(this, impl.release());
}
else
{
mDevice = nullptr;
}
mState.singleThreadPool = angle::WorkerThreadPool::Create(angle::ThreadPoolType::Synchronous, 0,
ANGLEPlatformCurrent());
mState.multiThreadPool = angle::WorkerThreadPool::Create(angle::ThreadPoolType::Asynchronous, 0,
ANGLEPlatformCurrent());
if (kIsContextMutexEnabled)
{
ASSERT(mManagersMutex == nullptr);
mManagersMutex = new ContextMutex();
mManagersMutex->addRef();
}
setInitialized();
return NoError();
}
Error Display::destroyInvalidEglObjects()
{
// Destroy invalid EGL objects
// Note that we don't need to lock mState.contextMapMutex here.
// Write and read access to mInvalidContextMap are coming from
// EGL_Terminate, EGL_ReleaseThread, ThreadCleanupCallBACK.
// Those functions are protected by egl global lock,
// so there is no race condition on mInvalidContextMap.
for (gl::Context *context : mInvalidContextMap.extractAll())
{
ASSERT(!context->isReferenced());
// eglReleaseThread() may call to this method when there are still Contexts, that may
// potentially acces shared state of the "context".
// Need AddRefLock because there may be ContextMutex destruction.
ScopedContextMutexAddRefLock lock(context->getContextMutex());
context->setIsDestroyed();
ANGLE_TRY(releaseContextImpl(std::unique_ptr<gl::Context>(context)));
}
while (!mInvalidImageMap.empty())
{
destroyImageImpl(mInvalidImageMap.begin()->second, &mInvalidImageMap);
}
while (!mInvalidStreamSet.empty())
{
destroyStreamImpl(*mInvalidStreamSet.begin(), &mInvalidStreamSet);
}
for (Surface *surface : mInvalidSurfaceMap.extractAll())
{
ANGLE_TRY(destroySurfaceImpl(surface, nullptr));
}
mSyncSet.destroyAllInvalidSyncs(this);
return NoError();
}
void Display::waitUntilUnreferenced(uint32_t expectedCount)
{
mDisplayMutex.assertLocked();
while ((mRefCount.load(std::memory_order_acquire) & kRefCountMask) > expectedCount)
{
std::this_thread::yield();
}
}
Error Display::terminate(Thread *thread, TerminateReason terminateReason)
{
mDisplayMutex.assertLocked();
if (terminateReason == TerminateReason::Api)
{
mTerminatedByApi = true;
}
// All subsequent calls assume the display to be valid and terminated by app.
// If it is not terminated, if it isn't initialized, early return.
if (!mTerminatedByApi || !isInitialized())
{
return NoError();
}
ASSERT(!isTerminating());
struct [[nodiscard]] ScopedTerminating
{
ScopedTerminating(Display *display) : mDisplay(display)
{
// std::memory_order_relaxed might be sufficient, but std::memory_order_release is used
// for safety since terminate is not on a performance-critical path.
mDisplay->mRefCount.fetch_or(kTerminatingBit, std::memory_order_release);
}
~ScopedTerminating()
{
mDisplay->mRefCount.fetch_and(~kTerminatingBit, std::memory_order_release);
}
Display *mDisplay;
} settingTerminating(this);
// Wait until all outstanding references from other threads go away before proceeding.
waitUntilUnreferenced(1);
// EGL 1.5 Specification
// 3.2 Initialization
// Termination marks all EGL-specific resources, such as contexts and surfaces, associated
// with the specified display for deletion. Handles to all such resources are invalid as
// soon as eglTerminate returns. Cache EGL objects that are no longer valid.
//
// It is fairly common for apps to call eglTerminate while some contexts and/or surfaces are
// still current on some thread. Since objects are refCounted, trying to destroy them right
// away would only result in a decRef. We instead cache such invalid objects and use other
// EGL entrypoints like eglReleaseThread or thread exit events (on the Android platform) to
// perform the necessary cleanup.
mInvalidImageMap.insert(mImageMap.begin(), mImageMap.end());
mImageMap.clear();
mInvalidStreamSet.insert(mStreamSet.begin(), mStreamSet.end());
mStreamSet.clear();
mState.surfaceMap.moveTo(&mInvalidSurfaceMap);
mSyncSet.invalidateAllSyncs();
mState.contextMap.pruneUnreferenced(&mInvalidContextMap);
if (!mState.contextMap.empty())
{
// There was at least 1 context that was current on some thread, early return.
return NoError();
}
// The global texture and semaphore managers should be deleted with the last context that uses
// it.
ASSERT(mGlobalTextureShareGroupUsers == 0 && mTextureManager == nullptr);
ASSERT(mGlobalSemaphoreShareGroupUsers == 0 && mSemaphoreManager == nullptr);
if (mManagersMutex != nullptr)
{
mManagersMutex->release();
mManagersMutex = nullptr;
}
// Clean up all invalid objects
ANGLE_TRY(destroyInvalidEglObjects());
mSyncSet.clearPools();
mConfigSet.clear();
if (mDevice != nullptr && mDevice->getOwningDisplay() != nullptr)
{
// Don't delete the device if it was created externally using eglCreateDeviceANGLE
// We also shouldn't set it to null in case eglInitialize() is called again later
SafeDelete(mDevice);
}
// Before tearing down the backend device, ensure all deferred operations are run. It is not
// possible to defer them beyond this point.
GetCurrentThreadUnlockedTailCall()->run(nullptr);
mImplementation->terminate();
mMemoryProgramCache.clear();
mMemoryShaderCache.clear();
mBlobCache.setBlobCacheFuncs(nullptr, nullptr);
mState.singleThreadPool.reset();
mState.multiThreadPool.reset();
mState.deviceLost = false;
setUninitialized();
gl::UninitializeDebugAnnotations();
// TODO(jmadill): Store Platform in Display and deinit here.
ANGLEResetDisplayPlatform(this);
return NoError();
}
Error Display::releaseThread()
{
// Need to check if initialized, because makeCurrent() may terminate the Display.
if (!isInitialized())
{
return NoError();
}
ANGLE_TRY(mImplementation->releaseThread());
return destroyInvalidEglObjects();
}
std::vector<const Config *> Display::getConfigs(const egl::AttributeMap &attribs) const
{
return mConfigSet.filter(attribs);
}
std::vector<const Config *> Display::chooseConfig(const egl::AttributeMap &attribs) const
{
egl::AttributeMap attribsWithDefaults = AttributeMap();
// Insert default values for attributes that have either an Exact or Mask selection criteria,
// and a default value that matters (e.g. isn't EGL_DONT_CARE):
attribsWithDefaults.insert(EGL_COLOR_BUFFER_TYPE, EGL_RGB_BUFFER);
attribsWithDefaults.insert(EGL_LEVEL, 0);
attribsWithDefaults.insert(EGL_RENDERABLE_TYPE, EGL_OPENGL_ES_BIT);
attribsWithDefaults.insert(EGL_SURFACE_TYPE, EGL_WINDOW_BIT);
attribsWithDefaults.insert(EGL_TRANSPARENT_TYPE, EGL_NONE);
if (getExtensions().pixelFormatFloat)
{
attribsWithDefaults.insert(EGL_COLOR_COMPONENT_TYPE_EXT,
EGL_COLOR_COMPONENT_TYPE_FIXED_EXT);
}
// Add the caller-specified values (Note: the poorly-named insert() method will replace any
// of the default values from above):
for (auto attribIter = attribs.begin(); attribIter != attribs.end(); attribIter++)
{
attribsWithDefaults.insert(attribIter->first, attribIter->second);
}
return mConfigSet.filter(attribsWithDefaults);
}
Error Display::createWindowSurface(const Config *configuration,
EGLNativeWindowType window,
const AttributeMap &attribs,
Surface **outSurface)
{
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
SurfaceID id;
if (!mSurfaceHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
SurfacePointer surface(new WindowSurface(mImplementation, id, configuration, window, attribs,
mFrontendFeatures.forceRobustResourceInit.enabled),
this);
ANGLE_TRY(surface->initialize(this));
ASSERT(outSurface != nullptr);
*outSurface = surface.release();
mState.surfaceMap.insert((*outSurface)->id(), *outSurface);
WindowSurfaceMap *windowSurfaces = GetWindowSurfaces();
ASSERT(windowSurfaces && windowSurfaces->find(window) == windowSurfaces->end());
windowSurfaces->insert(std::make_pair(window, *outSurface));
mSurface = *outSurface;
return NoError();
}
Error Display::createPbufferSurface(const Config *configuration,
const AttributeMap &attribs,
Surface **outSurface)
{
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
SurfaceID id;
if (!mSurfaceHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
SurfacePointer surface(new PbufferSurface(mImplementation, id, configuration, attribs,
mFrontendFeatures.forceRobustResourceInit.enabled),
this);
ANGLE_TRY(surface->initialize(this));
ASSERT(outSurface != nullptr);
*outSurface = surface.release();
mState.surfaceMap.insert((*outSurface)->id(), *outSurface);
return NoError();
}
Error Display::createPbufferFromClientBuffer(const Config *configuration,
EGLenum buftype,
EGLClientBuffer clientBuffer,
const AttributeMap &attribs,
Surface **outSurface)
{
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
SurfaceID id;
if (!mSurfaceHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
SurfacePointer surface(
new PbufferSurface(mImplementation, id, configuration, buftype, clientBuffer, attribs,
mFrontendFeatures.forceRobustResourceInit.enabled),
this);
ANGLE_TRY(surface->initialize(this));
ASSERT(outSurface != nullptr);
*outSurface = surface.release();
mState.surfaceMap.insert((*outSurface)->id(), *outSurface);
return NoError();
}
Error Display::createPixmapSurface(const Config *configuration,
NativePixmapType nativePixmap,
const AttributeMap &attribs,
Surface **outSurface)
{
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
SurfaceID id;
if (!mSurfaceHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
SurfacePointer surface(
new PixmapSurface(mImplementation, id, configuration, nativePixmap, attribs,
mFrontendFeatures.forceRobustResourceInit.enabled),
this);
ANGLE_TRY(surface->initialize(this));
ASSERT(outSurface != nullptr);
*outSurface = surface.release();
mState.surfaceMap.insert((*outSurface)->id(), *outSurface);
return NoError();
}
Error Display::createImage(const gl::Context *context,
EGLenum target,
EGLClientBuffer buffer,
const AttributeMap &attribs,
Image **outImage)
{
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
ImageID id;
if (!mImageHandleAllocator.allocate(&id.value))
{
return Error(EGL_BAD_ALLOC, gl::err::kHandleExhaustion);
}
egl::ImageSibling *sibling = nullptr;
if (IsTextureTarget(target))
{
gl::Texture *texture =
context->getTexture({egl_gl::EGLClientBufferToGLObjectHandle(buffer)});
texture->onBindAsEglImageSource();
sibling = texture;
}
else if (IsRenderbufferTarget(target))
{
sibling = context->getRenderbuffer({egl_gl::EGLClientBufferToGLObjectHandle(buffer)});
}
else if (IsExternalImageTarget(target))
{
sibling = new ExternalImageSibling(mImplementation, context, target, buffer, attribs);
}
else
{
UNREACHABLE();
}
ASSERT(sibling != nullptr);
angle::UniqueObjectPointer<Image, Display> imagePtr(
new Image(mImplementation, id, context, target, sibling, attribs), this);
ANGLE_TRY(imagePtr->initialize(this, context));
Image *image = imagePtr.release();
ASSERT(outImage != nullptr);
*outImage = image;
// Add this image to the list of all images and hold a ref to it.
image->addRef();
mImageMap.insert(std::pair(image->id().value, image));
return NoError();
}
Error Display::createStream(const AttributeMap &attribs, Stream **outStream)
{
ASSERT(isInitialized());
Stream *stream = new Stream(this, attribs);
ASSERT(stream != nullptr);
mStreamSet.insert(stream);
ASSERT(outStream != nullptr);
*outStream = stream;
return NoError();
}
Error Display::createContext(const Config *configuration,
gl::Context *shareContext,
const AttributeMap &attribs,
gl::Context **outContext)
{
ASSERT(!mTerminatedByApi);
ASSERT(isInitialized());
if (mThreadSafeImpl->testDeviceLost())
{
ANGLE_TRY(restoreLostDevice());
}
// This display texture sharing will allow the first context to create the texture share group.
bool usingDisplayTextureShareGroup =
attribs.get(EGL_DISPLAY_TEXTURE_SHARE_GROUP_ANGLE, EGL_FALSE) == EGL_TRUE;
gl::TextureManager *shareTextures = nullptr;
if (usingDisplayTextureShareGroup)
{
ASSERT((mTextureManager == nullptr) == (mGlobalTextureShareGroupUsers == 0));
if (mTextureManager == nullptr)
{
mTextureManager = new gl::TextureManager();
}
mGlobalTextureShareGroupUsers++;
shareTextures = mTextureManager;
}
// This display semaphore sharing will allow the first context to create the semaphore share
// group.
bool usingDisplaySemaphoreShareGroup =
attribs.get(EGL_DISPLAY_SEMAPHORE_SHARE_GROUP_ANGLE, EGL_FALSE) == EGL_TRUE;
gl::SemaphoreManager *shareSemaphores = nullptr;
if (usingDisplaySemaphoreShareGroup)
{
ASSERT((mSemaphoreManager == nullptr) == (mGlobalSemaphoreShareGroupUsers == 0));
if (mSemaphoreManager == nullptr)
{
mSemaphoreManager = new gl::SemaphoreManager();
}
mGlobalSemaphoreShareGroupUsers++;
shareSemaphores = mSemaphoreManager;
}
ScopedContextMutexLock mutexLock;
ContextMutex *sharedContextMutex = nullptr;
if (kIsContextMutexEnabled)
{
ASSERT(mManagersMutex != nullptr);
if (shareContext != nullptr)
{
sharedContextMutex = shareContext->getContextMutex().getRoot();
}
else if (shareTextures != nullptr || shareSemaphores != nullptr)
{
mutexLock = ScopedContextMutexLock(mManagersMutex);
sharedContextMutex = mManagersMutex->getRoot();
}
// When using shareTextures/Semaphores all Contexts in the Group must use mManagersMutex.
ASSERT((shareTextures == nullptr && shareSemaphores == nullptr) ||
sharedContextMutex == mManagersMutex->getRoot());
}
gl::MemoryProgramCache *programCachePointer = &mMemoryProgramCache;
// Check context creation attributes to see if we are using EGL_ANGLE_program_cache_control.
// If not, keep caching enabled for EGL_ANDROID_blob_cache, which can have its callbacks set
// at any time.
bool usesProgramCacheControl = attribs.contains(EGL_CONTEXT_PROGRAM_BINARY_CACHE_ENABLED_ANGLE);
if (usesProgramCacheControl)
{
bool programCacheControlEnabled =
(attribs.get(EGL_CONTEXT_PROGRAM_BINARY_CACHE_ENABLED_ANGLE, GL_FALSE) == GL_TRUE);
// A program cache size of zero indicates it should be disabled.
if (!programCacheControlEnabled || mMemoryProgramCache.maxSize() == 0)
{
programCachePointer = nullptr;
}
}
gl::MemoryShaderCache *shaderCachePointer = &mMemoryShaderCache;
// Check if shader caching frontend feature is enabled.
if (!mFrontendFeatures.cacheCompiledShader.enabled)
{
shaderCachePointer = nullptr;
}
gl::Context *context =
new gl::Context(this, configuration, shareContext, shareTextures, shareSemaphores,
sharedContextMutex, programCachePointer, shaderCachePointer, attribs,
mDisplayExtensions, GetClientExtensions());
Error error = context->initialize();
if (error.isError())
{
delete context;
return error;
}
if (shareContext != nullptr)
{
shareContext->setShared();
}
ASSERT(context != nullptr);
mState.contextMap.insert(context->id(), context);
ASSERT(outContext != nullptr);
*outContext = context;
return NoError();
}
Error Display::makeCurrent(Thread *thread,
gl::Context *previousContext,
egl::Surface *drawSurface,
egl::Surface *readSurface,
gl::Context *context)
{
if (!isInitialized())
{
return NoError();
}
bool contextChanged = context != previousContext;
if (previousContext != nullptr && contextChanged)
{
// Need AddRefLock because there may be ContextMutex destruction.
ScopedContextMutexAddRefLock lock(previousContext->getContextMutex());
previousContext->release();
thread->setCurrent(nullptr);
auto error = previousContext->unMakeCurrent(this);
if (!previousContext->isReferenced() && previousContext->isDestroyed())
{
// The previous Context may have been created with a different Display.
Display *previousDisplay = previousContext->getDisplay();
ANGLE_TRY(previousDisplay->releaseContext(previousContext, thread));
}
ANGLE_TRY(error);
}
{
ScopedContextMutexLock lock(context != nullptr ? &context->getContextMutex() : nullptr);
thread->setCurrent(context);
ScopedResetThreadContextOnError resetOnError(thread, contextChanged);
ANGLE_TRY(mImplementation->makeCurrent(this, drawSurface, readSurface, context));
if (context != nullptr)
{
ANGLE_TRY(context->makeCurrent(this, drawSurface, readSurface));
if (contextChanged)
{
context->addRef();
}
}
resetOnError.success();
}
// Tick all the scratch buffers to make sure they get cleaned up eventually if they stop being
// used.
{
std::lock_guard<angle::SimpleMutex> lock(mScratchBufferMutex);
for (angle::ScratchBuffer &scatchBuffer : mScratchBuffers)
{
scatchBuffer.tick();
}
for (angle::ScratchBuffer &zeroFilledBuffer : mZeroFilledBuffers)
{
zeroFilledBuffer.tick();
}
}
// If eglTerminate() has previously been called and Context was changed, perform InternalCleanup
// to invalidate any non-current Contexts, and possibly fully terminate the Display and release
// all of its resources.
if (mTerminatedByApi && contextChanged)
{
return terminate(thread, TerminateReason::InternalCleanup);
}
return NoError();
}
Error Display::destroySurfaceImpl(Surface *surface, SurfaceMap *surfaces)
{
if (surface->getType() == EGL_WINDOW_BIT)
{
WindowSurfaceMap *windowSurfaces = GetWindowSurfaces();
ASSERT(windowSurfaces);
bool surfaceRemoved = false;
for (WindowSurfaceMap::iterator iter = windowSurfaces->begin();
iter != windowSurfaces->end(); iter++)
{
if (iter->second == surface)
{
windowSurfaces->erase(iter);
surfaceRemoved = true;
break;
}
}
ASSERT(surfaceRemoved);
}
if (surfaces)
{
bool surfaceFound = surfaces->erase(surface->id());
ASSERT(surfaceFound);
}
mSurfaceHandleAllocator.release(surface->id().value);
ANGLE_TRY(surface->onDestroy(this));
return NoError();
}
void Display::destroyImageImpl(Image *image, ImageMap *images)
{
auto iter = images->find(image->id().value);
ASSERT(iter != images->end());
mImageHandleAllocator.release(image->id().value);
{
// Need AddRefLock because there may be ContextMutex destruction.
ScopedContextMutexAddRefLock lock(image->getContextMutex());
iter->second->release(this);
}
images->erase(iter);
}
void Display::destroyStreamImpl(Stream *stream, StreamSet *streams)
{
streams->erase(stream);
SafeDelete(stream);
}
// releaseContext must be called with the context being deleted as current.
// To do that we can only call this in two places, Display::makeCurrent at the point where this
// context is being made uncurrent and in Display::destroyContext where we make the context current
// as part of destruction.
Error Display::releaseContext(gl::Context *context, Thread *thread)
{
// Use scoped_ptr to make sure the context is always freed.
std::unique_ptr<gl::Context> uniqueContextPtr = eraseContextImpl(context, &mState.contextMap);
return releaseContextImpl(std::move(uniqueContextPtr));
}
std::unique_ptr<gl::Context> Display::eraseContextImpl(gl::Context *context, ContextMap *contexts)
{
ASSERT(!context->isReferenced());
bool contextFound = contexts->erase(context->id());
ASSERT(contextFound);
return std::unique_ptr<gl::Context>(context);
}
Error Display::releaseContextImpl(std::unique_ptr<gl::Context> &&context)
{
if (context->usingDisplayTextureShareGroup())
{
ASSERT(mGlobalTextureShareGroupUsers >= 1 && mTextureManager != nullptr);
if (mGlobalTextureShareGroupUsers == 1)
{
// If this is the last context using the global share group, destroy the global
// texture manager so that the textures can be destroyed while a context still
// exists
mTextureManager->release(context.get());
mTextureManager = nullptr;
}
mGlobalTextureShareGroupUsers--;
}
if (context->usingDisplaySemaphoreShareGroup())
{
ASSERT(mGlobalSemaphoreShareGroupUsers >= 1 && mSemaphoreManager != nullptr);
if (mGlobalSemaphoreShareGroupUsers == 1)
{
// If this is the last context using the global share group, destroy the global
// semaphore manager so that the semaphores can be destroyed while a context still
// exists
mSemaphoreManager->release(context.get());
mSemaphoreManager = nullptr;
}
mGlobalSemaphoreShareGroupUsers--;
}
ANGLE_TRY(context->onDestroy(this));
return NoError();
}
Error Display::destroyContext(Thread *thread, gl::Context *context)
{
auto *currentContext = thread->getContext();
auto *currentDrawSurface = thread->getCurrentDrawSurface();
auto *currentReadSurface = thread->getCurrentReadSurface();
context->setIsDestroyed();
// If the context is still current on at least 1 thread, just return since it'll be released
// once no threads have it current anymore.
if (context->isReferenced())
{
return NoError();
}
// For external context, we cannot change the current native context, and the API user should
// make sure the native context is current.
if (context->isExternal())
{
// Need AddRefLock because there may be ContextMutex destruction.
ScopedContextMutexAddRefLock lock(context->getContextMutex());
ANGLE_TRY(releaseContext(context, thread));
}
else
{
// Keep |currentContext| alive, while releasing |context|.
gl::ScopedContextRef scopedContextRef(currentContext);
// keep |currentDrawSurface| and |currentReadSurface| alive as well
// while releasing |context|.
ScopedSurfaceRef drawSurfaceRef(currentDrawSurface);
ScopedSurfaceRef readSurfaceRef(
currentReadSurface == currentDrawSurface ? nullptr : currentReadSurface);
// Make the context current, so we can release resources belong to the context, and then
// when context is released from the current, it will be destroyed.
// TODO(http://anglebug.com/42264840): Don't require a Context to be current in order to
// destroy it.
ANGLE_TRY(makeCurrent(thread, currentContext, nullptr, nullptr, context));
ANGLE_TRY(
makeCurrent(thread, context, currentDrawSurface, currentReadSurface, currentContext));
}
return NoError();
}
void Display::destroyImage(Image *image)
{
return destroyImageImpl(image, &mImageMap);
}
void Display::destroyStream(Stream *stream)
{
return destroyStreamImpl(stream, &mStreamSet);
}
Error Display::destroySurface(Surface *surface)
{
return destroySurfaceImpl(surface, &mState.surfaceMap);
}
bool Display::testDeviceLost()
{
ASSERT(isInitialized());
if (!mState.deviceLost && mThreadSafeImpl->testDeviceLost())
{
notifyDeviceLost();
}
return mState.deviceLost;
}
void Display::notifyDeviceLost()
{
mState.notifyDeviceLost();
}
void Display::setBlobCacheFuncs(EGLSetBlobFuncANDROID set, EGLGetBlobFuncANDROID get)
{
mBlobCache.setBlobCacheFuncs(set, get);
mImplementation->setBlobCacheFuncs(set, get);
}
// static
EGLClientBuffer Display::GetNativeClientBuffer(const AHardwareBuffer *buffer)
{
return angle::android::AHardwareBufferToClientBuffer(buffer);
}
// static
Error Display::CreateNativeClientBuffer(const egl::AttributeMap &attribMap,
EGLClientBuffer *eglClientBuffer)
{
int androidHardwareBufferFormat = gl::GetAndroidHardwareBufferFormatFromChannelSizes(attribMap);
int width = attribMap.getAsInt(EGL_WIDTH, 0);
int height = attribMap.getAsInt(EGL_HEIGHT, 0);
int usage = attribMap.getAsInt(EGL_NATIVE_BUFFER_USAGE_ANDROID, 0);
// https://developer.android.com/ndk/reference/group/a-hardware-buffer#ahardwarebuffer_lock
// for AHardwareBuffer_lock()
// The passed AHardwareBuffer must have one layer, otherwise the call will fail.
constexpr int kLayerCount = 1;
*eglClientBuffer = angle::android::CreateEGLClientBufferFromAHardwareBuffer(
width, height, kLayerCount, androidHardwareBufferFormat, usage);
return (*eglClientBuffer == nullptr)
? egl::Error(EGL_BAD_PARAMETER, "native client buffer allocation failed.")
: NoError();
}
Error Display::waitClient(const gl::Context *context)
{
return mImplementation->waitClient(context);
}
Error Display::waitNative(const gl::Context *context, EGLint engine)
{
return mImplementation->waitNative(context, engine);
}
const Caps &Display::getCaps() const
{
return mCaps;
}
bool Display::isValidConfig(const Config *config) const
{
return mConfigSet.contains(config);
}
bool Display::isValidContext(const gl::ContextID contextID) const
{
return getContext(contextID) != nullptr;
}
bool Display::isValidSurface(SurfaceID surfaceID) const
{
return getSurface(surfaceID) != nullptr;
}
bool Display::isValidImage(ImageID imageID) const
{
return getImage(imageID) != nullptr;
}
bool Display::isValidStream(const Stream *stream) const
{
return mStreamSet.find(const_cast<Stream *>(stream)) != mStreamSet.end();
}
bool Display::hasExistingWindowSurface(EGLNativeWindowType window)
{
WindowSurfaceMap *windowSurfaces = GetWindowSurfaces();
ASSERT(windowSurfaces);
return windowSurfaces->find(window) != windowSurfaces->end();
}
static ClientExtensions GenerateClientExtensions()
{
ClientExtensions extensions;
extensions.clientExtensions = true;
extensions.platformBase = true;
extensions.platformANGLE = true;
#if defined(ANGLE_ENABLE_D3D11)
extensions.platformANGLED3D = true;
extensions.platformDevice = true;
#endif
#if defined(ANGLE_USE_GBM) || defined(ANGLE_USE_WAYLAND)
extensions.platformGbmKHR = true;
#endif
#if defined(ANGLE_USE_WAYLAND)
extensions.platformWaylandEXT = true;
#endif
#if defined(ANGLE_PLATFORM_LINUX) && (defined(ANGLE_ENABLE_OPENGL) || defined(ANGLE_ENABLE_VULKAN))
extensions.platformSurfacelessMESA = true;
#endif
#if defined(ANGLE_ENABLE_D3D11)
extensions.platformANGLED3D11ON12 = angle::IsWindows10OrLater();
extensions.platformANGLED3DLUID = true;
extensions.platformANGLEDeviceId = true;
#endif
#if defined(ANGLE_ENABLE_OPENGL)
extensions.platformANGLEOpenGL = true;
#endif
#if defined(ANGLE_ENABLE_NULL)
extensions.platformANGLENULL = true;
#endif
#if defined(ANGLE_ENABLE_WGPU)
extensions.platformANGLEWebgpu = true;
#endif
#if defined(ANGLE_ENABLE_D3D11)
extensions.deviceCreation = true;
extensions.deviceCreationD3D11 = true;
extensions.experimentalPresentPath = true;
#endif
#if defined(ANGLE_ENABLE_VULKAN)
extensions.platformANGLEVulkan = true;
extensions.platformANGLEVulkanDeviceUUID = true;
extensions.platformANGLEDeviceId = true;
#endif
#if defined(ANGLE_ENABLE_SWIFTSHADER)
extensions.platformANGLEDeviceTypeSwiftShader = true;
#endif
#if defined(ANGLE_ENABLE_METAL)
extensions.platformANGLEMetal = true;
extensions.platformANGLEDeviceId = true;
#endif
#if defined(ANGLE_USE_X11)
extensions.x11Visual = true;
#endif
#if defined(ANGLE_PLATFORM_LINUX)
extensions.platformANGLEDeviceTypeEGLANGLE = true;
#endif
#if defined(ANGLE_ENABLE_METAL)
extensions.displayPowerPreferenceANGLE = true;
#endif
extensions.clientGetAllProcAddresses = true;
extensions.debug = true;
extensions.featureControlANGLE = true;
extensions.deviceQueryEXT = true;
extensions.noErrorANGLE = true;
extensions.platformANGLEDisplayKey = true;
return extensions;
}
template <typename T>
static std::string GenerateExtensionsString(const T &extensions)
{
std::vector<std::string> extensionsVector = extensions.getStrings();
std::ostringstream stream;
std::copy(extensionsVector.begin(), extensionsVector.end(),
std::ostream_iterator<std::string>(stream, " "));
return stream.str();
}
// static
const ClientExtensions &Display::GetClientExtensions()
{
static const ClientExtensions clientExtensions = GenerateClientExtensions();
return clientExtensions;
}
// static
const std::string &Display::GetClientExtensionString()
{
static const angle::base::NoDestructor<std::string> clientExtensionsString(
GenerateExtensionsString(GetClientExtensions()));
return *clientExtensionsString;
}
void Display::initDisplayExtensions()
{
mDisplayExtensions = mImplementation->getExtensions();
// Some extensions are always available because they are implemented in the EGL layer.
mDisplayExtensions.createContext = true;
mDisplayExtensions.createContextNoError = !mFrontendFeatures.forceGlErrorChecking.enabled;
mDisplayExtensions.createContextWebGLCompatibility = true;
mDisplayExtensions.createContextBindGeneratesResource = true;
mDisplayExtensions.createContextClientArrays = true;
mDisplayExtensions.pixelFormatFloat = true;
mDisplayExtensions.reusableSyncKHR = true;
// Force EGL_KHR_get_all_proc_addresses on.
mDisplayExtensions.getAllProcAddresses = true;
// Enable program cache control since it is not back-end dependent.
mDisplayExtensions.programCacheControlANGLE = true;
// Request extension is implemented in the ANGLE frontend
mDisplayExtensions.createContextExtensionsEnabled = true;
// Blob cache extension is provided by the ANGLE frontend
mDisplayExtensions.blobCache = true;
// The EGL_ANDROID_recordable extension is provided by the ANGLE frontend, and will always
// say that ANativeWindow is not recordable.
mDisplayExtensions.recordable = true;
// EGL_ANGLE_create_context_backwards_compatible
mDisplayExtensions.createContextBackwardsCompatible =
mFrontendFeatures.enableCreateContextBackwardsCompatible.enabled;
// EGL_ANGLE_memory_usage_report is implemented on front end.
mDisplayExtensions.memoryUsageReportANGLE = true;
mDisplayExtensionString = GenerateExtensionsString(mDisplayExtensions);
}
bool Display::isValidNativeWindow(EGLNativeWindowType window) const
{
return mImplementation->isValidNativeWindow(window);
}
Error Display::validateClientBuffer(const Config *configuration,
EGLenum buftype,
EGLClientBuffer clientBuffer,
const AttributeMap &attribs) const
{
return mImplementation->validateClientBuffer(configuration, buftype, clientBuffer, attribs);
}
Error Display::validateImageClientBuffer(const gl::Context *context,
EGLenum target,
EGLClientBuffer clientBuffer,
const egl::AttributeMap &attribs) const
{
return mImplementation->validateImageClientBuffer(context, target, clientBuffer, attribs);
}
Error Display::valdiatePixmap(const Config *config,
EGLNativePixmapType pixmap,
const AttributeMap &attributes) const
{
return mImplementation->validatePixmap(config, pixmap, attributes);
}
bool Display::isValidDisplay(const egl::Display *display)
{
if (GetANGLEPlatformDisplayMap()->contains(display))
{
return true;
}
if (GetDevicePlatformDisplayMap()->contains(display))
{
return true;
}
return false;
}
bool Display::isValidNativeDisplay(EGLNativeDisplayType display)
{
// TODO(jmadill): handle this properly
if (display == EGL_DEFAULT_DISPLAY)
{
return true;
}
#if defined(ANGLE_PLATFORM_WINDOWS) && !defined(ANGLE_ENABLE_WINDOWS_UWP)
if (display == EGL_SOFTWARE_DISPLAY_ANGLE || display == EGL_D3D11_ONLY_DISPLAY_ANGLE)
{
return true;
}
return (WindowFromDC(display) != nullptr);
#else
return true;
#endif
}
void Display::initVendorString()
{
mVendorString = "Google Inc.";
std::string vendorStringImpl = mImplementation->getVendorString();
if (!vendorStringImpl.empty())
{
mVendorString += " (" + vendorStringImpl + ")";
}
}
void Display::initVersionString()
{
mVersionString = mImplementation->getVersionString(true);
}
void Display::initClientAPIString()
{
mClientAPIString = "OpenGL_ES";
}
void Display::initializeFrontendFeatures()
{
// Enable on all Impls
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, loseContextOnOutOfMemory, true);
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, loseHardenedContextOnBackendError, true);
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, allowCompressedFormats, true);
// If this feature is enabled, the context can be created with a certain requested version
// via EGL_ANGLE_create_context_backwards_compatible. Otherwise, the context will be created
// with the latest compatible version with the device.
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, enableCreateContextBackwardsCompatible, true);
// Togglable until work on the extension is complete - anglebug.com/40096838.
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, emulatePixelLocalStorage, true);
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, forceMinimumMaxVertexAttributes, false);
// Incompatible redefinition of mutable textures is very tricky. Changing the texture's base
// level at the same time makes it much more tricky and is severely untested in dEQP. There are
// numerous GLES driver bugs around this combination of features. Some backends of ANGLE are
// also prone to bugs in this area. This feature can be used to disallow this combination on
// hardened contexts.
ANGLE_FEATURE_CONDITION(&mFrontendFeatures,
disallowNonZeroBaseLevelAndIncompatibleLevelsOnHardenedContexts, false);
// When the IR is built, use it by default.
#ifdef ANGLE_IR
ANGLE_FEATURE_CONDITION(&mFrontendFeatures, useIr, true);
#endif
mImplementation->initializeFrontendFeatures(&mFrontendFeatures);
}
const std::string &Display::getExtensionString() const
{
return mDisplayExtensionString;
}
const std::string &Display::getVendorString() const
{
return mVendorString;
}
const std::string &Display::getVersionString() const
{
return mVersionString;
}
const std::string &Display::getClientAPIString() const
{
return mClientAPIString;
}
std::string Display::getBackendRendererDescription() const
{
return mImplementation->getRendererDescription();
}
std::string Display::getBackendVendorString() const
{
return mImplementation->getVendorString();
}
std::string Display::getBackendVersionString(bool includeFullVersion) const
{
return mImplementation->getVersionString(includeFullVersion);
}
Device *Display::getDevice() const
{
return mDevice;
}
Surface *Display::getWGLSurface() const
{
return mSurface;
}
gl::Version Display::getMaxSupportedESVersion() const
{
return mImplementation->getMaxSupportedESVersion();
}
EGLint Display::programCacheGetAttrib(EGLenum attrib) const
{
switch (attrib)
{
case EGL_PROGRAM_CACHE_KEY_LENGTH_ANGLE:
return static_cast<EGLint>(angle::kProgramCacheControlKeySize);
case EGL_PROGRAM_CACHE_SIZE_ANGLE:
return static_cast<EGLint>(mMemoryProgramCache.entryCount());
default:
UNREACHABLE();
return 0;
}
}
Error Display::programCacheQuery(EGLint index,
void *key,
EGLint *keysize,
void *binary,
EGLint *binarysize)
{
ASSERT(index >= 0 && index < static_cast<EGLint>(mMemoryProgramCache.entryCount()));
const BlobCache::Key *programHash = nullptr;
BlobCache::Value programBinary;
// TODO(jmadill): Make this thread-safe.
bool result =
mMemoryProgramCache.getAt(static_cast<size_t>(index), &programHash, &programBinary);
if (!result)
{
return egl::Error(EGL_BAD_ACCESS, "Program binary not accessible.");
}
ASSERT(keysize && binarysize);
if (key)
{
ASSERT(*keysize == static_cast<EGLint>(angle::kProgramCacheControlKeySize));
ANGLE_UNSAFE_TODO(memset(key, 0, angle::kProgramCacheControlKeySize));
ANGLE_UNSAFE_TODO(memcpy(key, programHash->data(), BlobCache::kKeyLength));
}
if (binary)
{
// Note: we check the size here instead of in the validation code, since we need to
// access the cache as atomically as possible. It's possible that the cache contents
// could change between the validation size check and the retrieval.
if (programBinary.size() > static_cast<size_t>(*binarysize))
{
return egl::Error(EGL_BAD_ACCESS, "Program binary too large or changed during access.");
}
ANGLE_UNSAFE_TODO(memcpy(binary, programBinary.data(), programBinary.size()));
}
*binarysize = static_cast<EGLint>(programBinary.size());
*keysize = static_cast<EGLint>(angle::kProgramCacheControlKeySize);
return NoError();
}
Error Display::programCachePopulate(const void *key,
EGLint keysize,
const void *binary,
EGLint binarysize)
{
ASSERT(keysize == static_cast<EGLint>(angle::kProgramCacheControlKeySize));
BlobCache::Key programHash;
ANGLE_UNSAFE_TODO(memcpy(programHash.data(), key, BlobCache::kKeyLength));
if (!mMemoryProgramCache.putBinary(programHash, reinterpret_cast<const uint8_t *>(binary),
static_cast<size_t>(binarysize)))
{
return egl::Error(EGL_BAD_ACCESS, "Failed to copy program binary into the cache.");
}
return NoError();
}
EGLint Display::programCacheResize(EGLint limit, EGLenum mode)
{
switch (mode)
{
case EGL_PROGRAM_CACHE_RESIZE_ANGLE:
return static_cast<EGLint>(mMemoryProgramCache.resize(static_cast<size_t>(limit)));
case EGL_PROGRAM_CACHE_TRIM_ANGLE:
return static_cast<EGLint>(mMemoryProgramCache.trim(static_cast<size_t>(limit)));
default:
UNREACHABLE();
return 0;
}
}
void Display::overrideFrontendFeatures(const std::vector<std::string> &featureNames, bool enabled)
{
mFrontendFeatures.overrideFeatures(featureNames, enabled);
}
const char *Display::queryStringi(const EGLint name, const EGLint index)
{
const char *result = nullptr;
switch (name)
{
case EGL_FEATURE_NAME_ANGLE:
result = mFeatures[index]->name;
break;
case EGL_FEATURE_CATEGORY_ANGLE:
result = angle::FeatureCategoryToString(mFeatures[index]->category);
break;
case EGL_FEATURE_STATUS_ANGLE:
result = angle::FeatureStatusToString(mFeatures[index]->enabled);
break;
default:
UNREACHABLE();
return nullptr;
}
return result;
}
EGLAttrib Display::queryAttrib(const EGLint attribute)
{
EGLAttrib value = 0;
switch (attribute)
{
case EGL_DEVICE_EXT:
value = reinterpret_cast<EGLAttrib>(mDevice);
break;
case EGL_FEATURE_COUNT_ANGLE:
value = mFeatures.size();
break;
default:
UNREACHABLE();
}
return value;
}
angle::ScratchBuffer Display::requestScratchBuffer()
{
return requestScratchBufferImpl(&mScratchBuffers);
}
void Display::returnScratchBuffer(angle::ScratchBuffer scratchBuffer)
{
returnScratchBufferImpl(std::move(scratchBuffer), &mScratchBuffers);
}
angle::ScratchBuffer Display::requestZeroFilledBuffer()
{
return requestScratchBufferImpl(&mZeroFilledBuffers);
}
void Display::returnZeroFilledBuffer(angle::ScratchBuffer zeroFilledBuffer)
{
returnScratchBufferImpl(std::move(zeroFilledBuffer), &mZeroFilledBuffers);
}
angle::ScratchBuffer Display::requestScratchBufferImpl(
std::vector<angle::ScratchBuffer> *bufferVector)
{
std::lock_guard<angle::SimpleMutex> lock(mScratchBufferMutex);
if (!bufferVector->empty())
{
angle::ScratchBuffer buffer = std::move(bufferVector->back());
bufferVector->pop_back();
return buffer;
}
return angle::ScratchBuffer(kScratchBufferLifetime);
}
void Display::returnScratchBufferImpl(angle::ScratchBuffer scratchBuffer,
std::vector<angle::ScratchBuffer> *bufferVector)
{
std::lock_guard<angle::SimpleMutex> lock(mScratchBufferMutex);
bufferVector->push_back(std::move(scratchBuffer));
}
Error Display::handleGPUSwitch()
{
ANGLE_TRY(mImplementation->handleGPUSwitch());
initVendorString();
return NoError();
}
Error Display::forceGPUSwitch(EGLint gpuIDHigh, EGLint gpuIDLow)
{
ANGLE_TRY(mImplementation->forceGPUSwitch(gpuIDHigh, gpuIDLow));
initVendorString();
return NoError();
}
Error Display::waitUntilWorkScheduled()
{
ANGLE_TRY(mImplementation->waitUntilWorkScheduled());
return NoError();
}
void Display::lockVulkanQueue()
{
return mImplementation->lockVulkanQueue();
}
void Display::unlockVulkanQueue()
{
return mImplementation->unlockVulkanQueue();
}
bool Display::supportsDmaBufFormat(EGLint format) const
{
return mImplementation->supportsDmaBufFormat(format);
}
Error Display::queryDmaBufFormats(EGLint max_formats, EGLint *formats, EGLint *num_formats)
{
ANGLE_TRY(mImplementation->queryDmaBufFormats(max_formats, formats, num_formats));
return NoError();
}
Error Display::queryDmaBufModifiers(EGLint format,
EGLint max_modifiers,
EGLuint64KHR *modifiers,
EGLBoolean *external_only,
EGLint *num_modifiers)
{
ANGLE_TRY(mImplementation->queryDmaBufModifiers(format, max_modifiers, modifiers, external_only,
num_modifiers));
return NoError();
}
Error Display::querySupportedCompressionRates(const Config *configuration,
const AttributeMap &attributes,
EGLint *rates,
EGLint rate_size,
EGLint *num_rates) const
{
ANGLE_TRY(mImplementation->querySupportedCompressionRates(configuration, attributes, rates,
rate_size, num_rates));
return NoError();
}
angle::ImageLoadContext Display::getImageLoadContext() const
{
angle::ImageLoadContext imageLoadContext;
imageLoadContext.singleThreadPool = mState.singleThreadPool;
imageLoadContext.multiThreadPool = mFrontendFeatures.singleThreadedTextureDecompression.enabled
? nullptr
: mState.multiThreadPool;
return imageLoadContext;
}
const gl::Context *Display::getContext(gl::ContextID contextID) const
{
return mState.contextMap.find(contextID);
}
const egl::Surface *Display::getSurface(egl::SurfaceID surfaceID) const
{
return mState.surfaceMap.find(surfaceID);
}
const egl::Image *Display::getImage(egl::ImageID imageID) const
{
auto iter = mImageMap.find(imageID.value);
return iter != mImageMap.end() ? iter->second : nullptr;
}
gl::Context *Display::getContext(gl::ContextID contextID)
{
return mState.contextMap.find(contextID);
}
egl::Surface *Display::getSurface(egl::SurfaceID surfaceID)
{
return mState.surfaceMap.find(surfaceID);
}
egl::Image *Display::getImage(egl::ImageID imageID)
{
auto iter = mImageMap.find(imageID.value);
return iter != mImageMap.end() ? iter->second : nullptr;
}
// static
void Display::InitTLS()
{
TLSData *tlsData = new TLSData;
#if defined(ANGLE_PLATFORM_APPLE)
SetDisplayTLS(tlsData);
#else
gDisplayTLS = tlsData;
#endif
}
// static
angle::UnlockedTailCall *Display::GetCurrentThreadUnlockedTailCall()
{
return &GetDisplayTLS()->unlockedTailCall;
}
// static
Error *Display::GetCurrentThreadErrorScratchSpace()
{
return &GetDisplayTLS()->errorScratchSpace;
}
} // namespace egl