Gitiles
Code Review Sign In
review.blissroms.org / platform_frameworks_native / 37c27efdf8232272648e56513f3caceeb5c66407 / . / libs / vr / libdisplay / graphics.cpp
blob: 36f80954757e99077144a5e236aad2494967fcd1 [file] [log] [blame]
#include <dvr/graphics.h>
#include <inttypes.h>
#include <sys/timerfd.h>
#include <array>
#include <vector>
#include <log/log.h>
#include <utils/Trace.h>
#ifndef VK_USE_PLATFORM_ANDROID_KHR
#define VK_USE_PLATFORM_ANDROID_KHR 1
#endif
#include <vulkan/vulkan.h>
#include <dvr/dvr_display_types.h>
#include <pdx/file_handle.h>
#include <private/dvr/clock_ns.h>
#include <private/dvr/debug.h>
#include <private/dvr/frame_history.h>
#include <private/dvr/gl_fenced_flush.h>
#include <private/dvr/graphics/vr_gl_extensions.h>
#include <private/dvr/graphics_private.h>
#include <private/dvr/late_latch.h>
#include <private/dvr/native_buffer_queue.h>
#include <private/dvr/platform_defines.h>
#include <private/dvr/sensor_constants.h>
#include <private/dvr/vsync_client.h>
#include <android/native_window.h>
#ifndef EGL_CONTEXT_MAJOR_VERSION
#define EGL_CONTEXT_MAJOR_VERSION 0x3098
#define EGL_CONTEXT_MINOR_VERSION 0x30FB
#endif
using android::pdx::ErrorStatus;
using android::pdx::LocalHandle;
using android::pdx::LocalChannelHandle;
using android::pdx::Status;
using android::dvr::display::DisplayClient;
using android::dvr::display::Metrics;
using android::dvr::display::NativeBufferQueue;
using android::dvr::display::Surface;
using android::dvr::display::SurfaceAttribute;
using android::dvr::display::SurfaceAttributes;
using android::dvr::display::SurfaceAttributeValue;
using android::dvr::VSyncClient;
namespace {
// TODO(urbanus): revisit once we have per-platform usage config in place.
constexpr uint64_t kDefaultDisplaySurfaceUsage =
GRALLOC1_PRODUCER_USAGE_GPU_RENDER_TARGET |
GRALLOC1_PRODUCER_USAGE_PRIVATE_1 | GRALLOC1_CONSUMER_USAGE_CLIENT_TARGET |
GRALLOC1_CONSUMER_USAGE_GPU_TEXTURE;
constexpr uint32_t kDefaultDisplaySurfaceFormat = HAL_PIXEL_FORMAT_RGBA_8888;
// TODO(alexst): revisit this count when HW encode is available for casting.
constexpr size_t kDefaultBufferCount = 4;
// Use with dvrBeginRenderFrame to disable EDS for the current frame.
constexpr float32x4_t DVR_POSE_NO_EDS = {10.0f, 0.0f, 0.0f, 0.0f};
// Use with dvrBeginRenderFrame to indicate that GPU late-latching is being used
// for determining the render pose.
constexpr float32x4_t DVR_POSE_LATE_LATCH = {20.0f, 0.0f, 0.0f, 0.0f};
#ifndef NDEBUG
static const char* GetGlCallbackType(GLenum type) {
switch (type) {
case GL_DEBUG_TYPE_ERROR_KHR:
return "ERROR";
case GL_DEBUG_TYPE_DEPRECATED_BEHAVIOR_KHR:
return "DEPRECATED_BEHAVIOR";
case GL_DEBUG_TYPE_UNDEFINED_BEHAVIOR_KHR:
return "UNDEFINED_BEHAVIOR";
case GL_DEBUG_TYPE_PORTABILITY_KHR:
return "PORTABILITY";
case GL_DEBUG_TYPE_PERFORMANCE_KHR:
return "PERFORMANCE";
case GL_DEBUG_TYPE_OTHER_KHR:
return "OTHER";
default:
return "UNKNOWN";
}
}
static void on_gl_error(GLenum /*source*/, GLenum type, GLuint /*id*/,
GLenum severity, GLsizei /*length*/,
const char* message, const void* /*user_param*/) {
char msg[400];
snprintf(msg, sizeof(msg), "[" __FILE__ ":%u] GL %s: %s", __LINE__,
GetGlCallbackType(type), message);
switch (severity) {
case GL_DEBUG_SEVERITY_LOW_KHR:
ALOGI("%s", msg);
break;
case GL_DEBUG_SEVERITY_MEDIUM_KHR:
ALOGW("%s", msg);
break;
case GL_DEBUG_SEVERITY_HIGH_KHR:
ALOGE("%s", msg);
break;
}
fprintf(stderr, "%s\n", msg);
}
#endif
int DvrToHalSurfaceFormat(int dvr_surface_format) {
switch (dvr_surface_format) {
case DVR_SURFACE_FORMAT_RGBA_8888:
return HAL_PIXEL_FORMAT_RGBA_8888;
case DVR_SURFACE_FORMAT_RGB_565:
return HAL_PIXEL_FORMAT_RGB_565;
default:
return HAL_PIXEL_FORMAT_RGBA_8888;
}
}
int SelectEGLConfig(EGLDisplay dpy, EGLint* attr, unsigned format,
EGLConfig* config) {
std::array<EGLint, 4> desired_rgba;
switch (format) {
case HAL_PIXEL_FORMAT_RGBA_8888:
case HAL_PIXEL_FORMAT_BGRA_8888:
desired_rgba = {{8, 8, 8, 8}};
break;
case HAL_PIXEL_FORMAT_RGB_565:
desired_rgba = {{5, 6, 5, 0}};
break;
default:
ALOGE("Unsupported framebuffer pixel format %d", format);
return -1;
}
EGLint max_configs = 0;
if (eglGetConfigs(dpy, NULL, 0, &max_configs) == EGL_FALSE) {
ALOGE("No EGL configurations available?!");
return -1;
}
std::vector<EGLConfig> configs(max_configs);
EGLint num_configs;
if (eglChooseConfig(dpy, attr, &configs[0], max_configs, &num_configs) ==
EGL_FALSE) {
ALOGE("eglChooseConfig failed");
return -1;
}
std::array<EGLint, 4> config_rgba;
for (int i = 0; i < num_configs; i++) {
eglGetConfigAttrib(dpy, configs[i], EGL_RED_SIZE, &config_rgba[0]);
eglGetConfigAttrib(dpy, configs[i], EGL_GREEN_SIZE, &config_rgba[1]);
eglGetConfigAttrib(dpy, configs[i], EGL_BLUE_SIZE, &config_rgba[2]);
eglGetConfigAttrib(dpy, configs[i], EGL_ALPHA_SIZE, &config_rgba[3]);
if (config_rgba == desired_rgba) {
*config = configs[i];
return 0;
}
}
ALOGE("Cannot find a matching EGL config");
return -1;
}
void DestroyEglContext(EGLDisplay egl_display, EGLContext* egl_context) {
if (*egl_context != EGL_NO_CONTEXT) {
eglDestroyContext(egl_display, *egl_context);
*egl_context = EGL_NO_CONTEXT;
}
}
// Perform internal initialization. A GL context must be bound to the current
// thread.
// @param internally_created_context True if we created and own the GL context,
// false if it was supplied by the application.
// @return 0 if init was successful, or a negative error code on failure.
int InitGl(bool internally_created_context) {
EGLDisplay egl_display = eglGetDisplay(EGL_DEFAULT_DISPLAY);
if (egl_display == EGL_NO_DISPLAY) {
ALOGE("eglGetDisplay failed");
return -EINVAL;
}
EGLContext egl_context = eglGetCurrentContext();
if (egl_context == EGL_NO_CONTEXT) {
ALOGE("No GL context bound");
return -EINVAL;
}
glGetError(); // Clear the error state
GLint major_version, minor_version;
glGetIntegerv(GL_MAJOR_VERSION, &major_version);
glGetIntegerv(GL_MINOR_VERSION, &minor_version);
if (glGetError() != GL_NO_ERROR) {
// GL_MAJOR_VERSION and GL_MINOR_VERSION were added in GLES 3. If we get an
// error querying them it's almost certainly because it's GLES 1 or 2.
ALOGE("Error getting GL version. Must be GLES 3.2 or greater.");
return -EINVAL;
}
if (major_version < 3 || (major_version == 3 && minor_version < 2)) {
ALOGE("Invalid GL version: %d.%d. Must be GLES 3.2 or greater.",
major_version, minor_version);
return -EINVAL;
}
#ifndef NDEBUG
if (internally_created_context) {
// Enable verbose GL debug output.
glEnable(GL_DEBUG_OUTPUT_SYNCHRONOUS_KHR);
glDebugMessageCallbackKHR(on_gl_error, NULL);
GLuint unused_ids = 0;
glDebugMessageControlKHR(GL_DONT_CARE, GL_DONT_CARE, GL_DONT_CARE, 0,
&unused_ids, GL_TRUE);
}
#else
(void)internally_created_context;
#endif
load_gl_extensions();
return 0;
}
int CreateEglContext(EGLDisplay egl_display, DvrSurfaceParameter* parameters,
EGLContext* egl_context) {
*egl_context = EGL_NO_CONTEXT;
EGLint major, minor;
if (!eglInitialize(egl_display, &major, &minor)) {
ALOGE("Failed to initialize EGL");
return -ENXIO;
}
ALOGI("EGL version: %d.%d\n", major, minor);
int buffer_format = kDefaultDisplaySurfaceFormat;
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_FORMAT_IN:
buffer_format = DvrToHalSurfaceFormat(p->value);
break;
}
}
EGLint config_attrs[] = {EGL_SURFACE_TYPE, EGL_WINDOW_BIT,
EGL_RENDERABLE_TYPE, EGL_OPENGL_ES2_BIT, EGL_NONE};
EGLConfig config = {0};
int ret = SelectEGLConfig(egl_display, config_attrs, buffer_format, &config);
if (ret < 0)
return ret;
ALOGI("EGL SelectEGLConfig ok.\n");
EGLint context_attrs[] = {EGL_CONTEXT_MAJOR_VERSION,
3,
EGL_CONTEXT_MINOR_VERSION,
2,
#ifndef NDEBUG
EGL_CONTEXT_FLAGS_KHR,
EGL_CONTEXT_OPENGL_DEBUG_BIT_KHR,
#endif
EGL_NONE};
*egl_context =
eglCreateContext(egl_display, config, EGL_NO_CONTEXT, context_attrs);
if (*egl_context == EGL_NO_CONTEXT) {
ALOGE("eglCreateContext failed");
return -ENXIO;
}
ALOGI("eglCreateContext ok.\n");
if (!eglMakeCurrent(egl_display, EGL_NO_SURFACE, EGL_NO_SURFACE,
*egl_context)) {
ALOGE("eglMakeCurrent failed");
DestroyEglContext(egl_display, egl_context);
return -EINVAL;
}
return 0;
}
// Utility structure to hold info related to creating a surface.
struct SurfaceResult {
std::shared_ptr<Surface> surface;
Metrics metrics;
uint32_t width;
uint32_t height;
uint32_t format;
uint64_t usage;
size_t capacity;
int geometry;
bool direct_surface;
};
Status<std::tuple<std::shared_ptr<android::dvr::ProducerQueue>,
std::shared_ptr<android::dvr::BufferProducer>,
volatile DisplaySurfaceMetadata*>>
CreateMetadataBuffer(const std::shared_ptr<Surface>& surface,
bool direct_surface) {
std::shared_ptr<android::dvr::ProducerQueue> queue;
std::shared_ptr<android::dvr::BufferProducer> buffer;
if (!direct_surface) {
auto queue_status = surface->CreateQueue(
sizeof(DisplaySurfaceMetadata), 1, 1, HAL_PIXEL_FORMAT_BLOB,
GRALLOC1_PRODUCER_USAGE_GPU_RENDER_TARGET |
GRALLOC1_PRODUCER_USAGE_CPU_WRITE_OFTEN |
GRALLOC1_CONSUMER_USAGE_GPU_DATA_BUFFER,
1);
if (!queue_status) {
ALOGE("CreateMetadataBuffer: Failed to create queue: %s",
queue_status.GetErrorMessage().c_str());
return queue_status.error_status();
}
queue = queue_status.take();
LocalHandle fence;
size_t slot;
auto buffer_status = queue->Dequeue(-1, &slot, &fence);
if (!buffer_status) {
ALOGE("CreateMetadataBuffer: Failed to dequeue buffer: %s",
buffer_status.GetErrorMessage().c_str());
return buffer_status.error_status();
}
buffer = buffer_status.take();
} else {
buffer = android::dvr::BufferProducer::CreateUncachedBlob(
sizeof(DisplaySurfaceMetadata));
if (!buffer) {
ALOGE("CreateMetadataBuffer: Failed to create stand-in buffer!");
return ErrorStatus(ENOMEM);
}
}
void* address = nullptr;
int ret =
buffer->GetBlobReadWritePointer(sizeof(DisplaySurfaceMetadata), &address);
if (ret < 0) {
ALOGE("CreateMetadataBuffer: Failed to map buffer: %s", strerror(-ret));
return ErrorStatus(-ret);
}
// Post the buffer so that the compositor can retrieve it from the consumer
// queue.
ret = buffer->Post<void>(LocalHandle{});
if (ret < 0) {
ALOGE("CreateMetadataBuffer: Failed to post buffer: %s", strerror(-ret));
return ErrorStatus(-ret);
}
ALOGD_IF(TRACE, "CreateMetadataBuffer: queue_id=%d buffer_id=%d address=%p",
queue ? queue->id() : -1, buffer->id(), address);
return {{std::move(queue), std::move(buffer),
static_cast<DisplaySurfaceMetadata*>(address)}};
}
} // anonymous namespace
Status<SurfaceResult> CreateSurface(struct DvrSurfaceParameter* parameters) {
int error;
auto client = DisplayClient::Create(&error);
if (!client) {
ALOGE("CreateApplicationSurface: Failed to create display client!");
return ErrorStatus(error);
}
auto metrics_status = client->GetDisplayMetrics();
if (!metrics_status) {
ALOGE("CreateApplicationSurface: Failed to get display metrics: %s",
metrics_status.GetErrorMessage().c_str());
return metrics_status.error_status();
}
// Parameters that may be modified by the parameters array. Some of these are
// here for future expansion.
uint32_t request_width = metrics_status.get().display_width;
uint32_t request_height = metrics_status.get().display_width;
uint32_t request_format = kDefaultDisplaySurfaceFormat;
uint64_t request_usage = kDefaultDisplaySurfaceUsage;
size_t request_capacity = kDefaultBufferCount;
int request_geometry = DVR_SURFACE_GEOMETRY_SINGLE;
bool disable_distortion = false;
bool disable_stabilization = false;
bool disable_cac = false;
bool request_visible = false;
bool vertical_flip = false;
bool direct_surface = false;
int request_z_order = 0;
// Handle parameter inputs.
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_DISABLE_DISTORTION_IN:
disable_distortion = !!p->value;
break;
case DVR_SURFACE_PARAMETER_DISABLE_STABILIZATION_IN:
disable_stabilization = !!p->value;
break;
case DVR_SURFACE_PARAMETER_DISABLE_CAC_IN:
disable_cac = !!p->value;
break;
case DVR_SURFACE_PARAMETER_VISIBLE_IN:
request_visible = !!p->value;
break;
case DVR_SURFACE_PARAMETER_Z_ORDER_IN:
request_z_order = p->value;
break;
case DVR_SURFACE_PARAMETER_VERTICAL_FLIP_IN:
vertical_flip = !!p->value;
break;
case DVR_SURFACE_PARAMETER_DIRECT_IN:
direct_surface = !!p->value;
break;
case DVR_SURFACE_PARAMETER_WIDTH_IN:
request_width = p->value;
break;
case DVR_SURFACE_PARAMETER_HEIGHT_IN:
request_height = p->value;
break;
case DVR_SURFACE_PARAMETER_FORMAT_IN:
request_format = p->value;
break;
case DVR_SURFACE_PARAMETER_GEOMETRY_IN:
request_geometry = p->value;
break;
case DVR_SURFACE_PARAMETER_ENABLE_LATE_LATCH_IN:
case DVR_SURFACE_PARAMETER_CREATE_GL_CONTEXT_IN:
case DVR_SURFACE_PARAMETER_DISPLAY_WIDTH_OUT:
case DVR_SURFACE_PARAMETER_DISPLAY_HEIGHT_OUT:
case DVR_SURFACE_PARAMETER_SURFACE_WIDTH_OUT:
case DVR_SURFACE_PARAMETER_SURFACE_HEIGHT_OUT:
case DVR_SURFACE_PARAMETER_INTER_LENS_METERS_OUT:
case DVR_SURFACE_PARAMETER_LEFT_FOV_LRBT_OUT:
case DVR_SURFACE_PARAMETER_RIGHT_FOV_LRBT_OUT:
case DVR_SURFACE_PARAMETER_VSYNC_PERIOD_OUT:
case DVR_SURFACE_PARAMETER_SURFACE_TEXTURE_TARGET_TYPE_OUT:
case DVR_SURFACE_PARAMETER_SURFACE_TEXTURE_TARGET_ID_OUT:
case DVR_SURFACE_PARAMETER_GRAPHICS_API_IN:
case DVR_SURFACE_PARAMETER_VK_INSTANCE_IN:
case DVR_SURFACE_PARAMETER_VK_PHYSICAL_DEVICE_IN:
case DVR_SURFACE_PARAMETER_VK_DEVICE_IN:
case DVR_SURFACE_PARAMETER_VK_PRESENT_QUEUE_IN:
case DVR_SURFACE_PARAMETER_VK_PRESENT_QUEUE_FAMILY_IN:
case DVR_SURFACE_PARAMETER_VK_SWAPCHAIN_IMAGE_COUNT_OUT:
case DVR_SURFACE_PARAMETER_VK_SWAPCHAIN_IMAGE_FORMAT_OUT:
break;
default:
ALOGE(
"CreateSurface: Invalid display surface parameter: key=%d "
"value=%" PRId64,
p->key, p->value);
return ErrorStatus(EINVAL);
}
}
// TODO(eieio): Setup a "surface flags" attribute based on the surface
// parameters gathered above.
SurfaceAttributes surface_attributes;
surface_attributes[SurfaceAttribute::Direct] = direct_surface;
surface_attributes[SurfaceAttribute::Visible] = request_visible;
surface_attributes[SurfaceAttribute::ZOrder] = request_z_order;
auto surface_status = Surface::CreateSurface(surface_attributes);
if (!surface_status) {
ALOGE("CreateSurface: Failed to create surface: %s",
surface_status.GetErrorMessage().c_str());
return surface_status.error_status();
}
return {{surface_status.take(), metrics_status.get(), request_width,
request_height, request_format, request_usage, request_capacity,
request_geometry, direct_surface}};
}
// TODO(hendrikw): When we remove the calls to this in native_window.cpp, move
// this back into the anonymous namespace
Status<SurfaceResult> CreateApplicationSurface(
struct DvrSurfaceParameter* parameters) {
auto surface_status = CreateSurface(parameters);
if (!surface_status)
return surface_status;
// Handle parameter output requests down here so we can return surface info.
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_DISPLAY_WIDTH_OUT:
*static_cast<int32_t*>(p->value_out) =
surface_status.get().metrics.display_width;
break;
case DVR_SURFACE_PARAMETER_DISPLAY_HEIGHT_OUT:
*static_cast<int32_t*>(p->value_out) =
surface_status.get().metrics.display_height;
break;
case DVR_SURFACE_PARAMETER_VSYNC_PERIOD_OUT:
*static_cast<uint64_t*>(p->value_out) =
surface_status.get().metrics.vsync_period_ns;
break;
case DVR_SURFACE_PARAMETER_SURFACE_WIDTH_OUT:
*static_cast<uint32_t*>(p->value_out) = surface_status.get().width;
break;
case DVR_SURFACE_PARAMETER_SURFACE_HEIGHT_OUT:
*static_cast<uint32_t*>(p->value_out) = surface_status.get().height;
break;
default:
break;
}
}
return surface_status;
}
extern "C" int dvrGetNativeDisplayDimensions(int* display_width,
int* display_height) {
int error = 0;
auto client = DisplayClient::Create(&error);
if (!client) {
ALOGE("dvrGetNativeDisplayDimensions: Failed to create display client!");
return -error;
}
auto metrics_status = client->GetDisplayMetrics();
if (!metrics_status) {
ALOGE("dvrGetNativeDisplayDimensions: Failed to get display metrics: %s",
metrics_status.GetErrorMessage().c_str());
return -metrics_status.error();
}
*display_width = static_cast<int>(metrics_status.get().display_width);
*display_height = static_cast<int>(metrics_status.get().display_height);
return 0;
}
struct DvrGraphicsContext : public android::ANativeObjectBase<
ANativeWindow, DvrGraphicsContext,
android::LightRefBase<DvrGraphicsContext>> {
public:
DvrGraphicsContext();
~DvrGraphicsContext();
int graphics_api; // DVR_SURFACE_GRAPHICS_API_*
// GL specific members.
struct {
EGLDisplay egl_display;
EGLContext egl_context;
bool owns_egl_context;
GLuint texture_id[kSurfaceViewMaxCount];
int texture_count;
GLenum texture_target_type;
} gl;
// VK specific members
struct {
// These objects are passed in by the application, and are NOT owned
// by the context.
VkInstance instance;
VkPhysicalDevice physical_device;
VkDevice device;
VkQueue present_queue;
uint32_t present_queue_family;
const VkAllocationCallbacks* allocation_callbacks;
// These objects are owned by the context.
ANativeWindow* window;
VkSurfaceKHR surface;
VkSwapchainKHR swapchain;
std::vector<VkImage> swapchain_images;
std::vector<VkImageView> swapchain_image_views;
} vk;
// Display surface, metrics, and buffer management members.
std::shared_ptr<Surface> display_surface;
uint32_t width;
uint32_t height;
uint32_t format;
Metrics display_metrics;
std::unique_ptr<NativeBufferQueue> buffer_queue;
android::dvr::NativeBufferProducer* current_buffer;
bool buffer_already_posted;
// Synchronization members.
std::unique_ptr<android::dvr::VSyncClient> vsync_client;
LocalHandle timerfd;
android::dvr::FrameHistory frame_history;
// Metadata queue and buffer.
// TODO(eieio): Remove the queue once one-off buffers are supported as a
// surface primitive element.
std::shared_ptr<android::dvr::ProducerQueue> metadata_queue;
std::shared_ptr<android::dvr::BufferProducer> metadata_buffer;
// Mapped surface metadata (ie: for pose delivery with presented frames).
volatile DisplaySurfaceMetadata* surface_metadata;
// LateLatch support.
std::unique_ptr<android::dvr::LateLatch> late_latch;
private:
// ANativeWindow function implementations
std::mutex lock_;
int Post(android::dvr::NativeBufferProducer* buffer, int fence_fd);
static int SetSwapInterval(ANativeWindow* window, int interval);
static int DequeueBuffer(ANativeWindow* window, ANativeWindowBuffer** buffer,
int* fence_fd);
static int QueueBuffer(ANativeWindow* window, ANativeWindowBuffer* buffer,
int fence_fd);
static int CancelBuffer(ANativeWindow* window, ANativeWindowBuffer* buffer,
int fence_fd);
static int Query(const ANativeWindow* window, int what, int* value);
static int Perform(ANativeWindow* window, int operation, ...);
static int DequeueBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer** buffer);
static int CancelBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer* buffer);
static int QueueBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer* buffer);
static int LockBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer* buffer);
DvrGraphicsContext(const DvrGraphicsContext&) = delete;
void operator=(const DvrGraphicsContext&) = delete;
};
DvrGraphicsContext::DvrGraphicsContext()
: graphics_api(DVR_GRAPHICS_API_GLES),
gl{},
vk{},
current_buffer(nullptr),
buffer_already_posted(false),
surface_metadata(nullptr) {
gl.egl_display = EGL_NO_DISPLAY;
gl.egl_context = EGL_NO_CONTEXT;
gl.owns_egl_context = true;
gl.texture_target_type = GL_TEXTURE_2D;
ANativeWindow::setSwapInterval = SetSwapInterval;
ANativeWindow::dequeueBuffer = DequeueBuffer;
ANativeWindow::cancelBuffer = CancelBuffer;
ANativeWindow::queueBuffer = QueueBuffer;
ANativeWindow::query = Query;
ANativeWindow::perform = Perform;
ANativeWindow::dequeueBuffer_DEPRECATED = DequeueBuffer_DEPRECATED;
ANativeWindow::cancelBuffer_DEPRECATED = CancelBuffer_DEPRECATED;
ANativeWindow::lockBuffer_DEPRECATED = LockBuffer_DEPRECATED;
ANativeWindow::queueBuffer_DEPRECATED = QueueBuffer_DEPRECATED;
}
DvrGraphicsContext::~DvrGraphicsContext() {
if (graphics_api == DVR_GRAPHICS_API_GLES) {
glDeleteTextures(gl.texture_count, gl.texture_id);
if (gl.owns_egl_context)
DestroyEglContext(gl.egl_display, &gl.egl_context);
} else if (graphics_api == DVR_GRAPHICS_API_VULKAN) {
if (vk.swapchain != VK_NULL_HANDLE) {
for (auto view : vk.swapchain_image_views) {
vkDestroyImageView(vk.device, view, vk.allocation_callbacks);
}
vkDestroySwapchainKHR(vk.device, vk.swapchain, vk.allocation_callbacks);
vkDestroySurfaceKHR(vk.instance, vk.surface, vk.allocation_callbacks);
delete vk.window;
}
}
}
int dvrGraphicsContextCreate(struct DvrSurfaceParameter* parameters,
DvrGraphicsContext** return_graphics_context) {
auto context = std::make_unique<DvrGraphicsContext>();
// See whether we're using GL or Vulkan
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_GRAPHICS_API_IN:
context->graphics_api = p->value;
break;
}
}
if (context->graphics_api == DVR_GRAPHICS_API_GLES) {
context->gl.egl_display = eglGetDisplay(EGL_DEFAULT_DISPLAY);
if (context->gl.egl_display == EGL_NO_DISPLAY) {
ALOGE("eglGetDisplay failed");
return -ENXIO;
}
// See if we should create a GL context
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_CREATE_GL_CONTEXT_IN:
context->gl.owns_egl_context = p->value != 0;
break;
}
}
if (context->gl.owns_egl_context) {
int ret = CreateEglContext(context->gl.egl_display, parameters,
&context->gl.egl_context);
if (ret < 0)
return ret;
} else {
context->gl.egl_context = eglGetCurrentContext();
}
int ret = InitGl(context->gl.owns_egl_context);
if (ret < 0)
return ret;
} else if (context->graphics_api == DVR_GRAPHICS_API_VULKAN) {
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_VK_INSTANCE_IN:
context->vk.instance = reinterpret_cast<VkInstance>(p->value);
break;
case DVR_SURFACE_PARAMETER_VK_PHYSICAL_DEVICE_IN:
context->vk.physical_device =
reinterpret_cast<VkPhysicalDevice>(p->value);
break;
case DVR_SURFACE_PARAMETER_VK_DEVICE_IN:
context->vk.device = reinterpret_cast<VkDevice>(p->value);
break;
case DVR_SURFACE_PARAMETER_VK_PRESENT_QUEUE_IN:
context->vk.present_queue = reinterpret_cast<VkQueue>(p->value);
break;
case DVR_SURFACE_PARAMETER_VK_PRESENT_QUEUE_FAMILY_IN:
context->vk.present_queue_family = static_cast<uint32_t>(p->value);
break;
}
}
} else {
ALOGE("Error: invalid graphics API type");
return -EINVAL;
}
auto surface_status = CreateApplicationSurface(parameters);
if (!surface_status) {
ALOGE("dvrGraphicsContextCreate: Failed to create surface: %s",
surface_status.GetErrorMessage().c_str());
return -surface_status.error();
}
auto surface_result = surface_status.take();
context->display_surface = surface_result.surface;
context->display_metrics = surface_result.metrics;
context->width = surface_result.width;
context->height = surface_result.height;
context->format = surface_result.format;
// Create an empty queue. NativeBufferQueue allocates the buffers for this
// queue.
auto queue_status = context->display_surface->CreateQueue();
if (!queue_status) {
ALOGE("dvrGraphicsContextCreate: Failed to create queue: %s",
queue_status.GetErrorMessage().c_str());
return -queue_status.error();
}
context->buffer_queue.reset(new NativeBufferQueue(
context->gl.egl_display, queue_status.take(), surface_result.width,
surface_result.height, surface_result.format, surface_result.usage,
surface_result.capacity));
// Create the metadata buffer.
auto metadata_status = CreateMetadataBuffer(context->display_surface,
surface_result.direct_surface);
if (!metadata_status) {
ALOGE("dvrGraphicsContextCreate: Failed to create metadata buffer: %s",
metadata_status.GetErrorMessage().c_str());
return -metadata_status.error();
}
std::tie(context->metadata_queue, context->metadata_buffer,
context->surface_metadata) = metadata_status.take();
// The way the call sequence works we need 1 more than the buffer queue
// capacity to store data for all pending frames
context->frame_history.Reset(context->buffer_queue->capacity() + 1);
context->vsync_client = VSyncClient::Create();
if (!context->vsync_client) {
ALOGE("dvrGraphicsContextCreate: failed to create vsync client");
return -ECOMM;
}
context->timerfd.Reset(timerfd_create(CLOCK_MONOTONIC, 0));
if (!context->timerfd) {
ALOGE("dvrGraphicsContextCreate: timerfd_create failed because: %s",
strerror(errno));
return -EPERM;
}
if (context->graphics_api == DVR_GRAPHICS_API_GLES) {
context->gl.texture_count =
(surface_result.geometry == DVR_SURFACE_GEOMETRY_SEPARATE_2) ? 2 : 1;
// Create the GL textures.
glGenTextures(context->gl.texture_count, context->gl.texture_id);
// We must make sure that we have at least one buffer allocated at this time
// so that anyone who tries to bind an FBO to context->texture_id
// will not get an incomplete buffer.
context->current_buffer = context->buffer_queue->Dequeue();
LOG_ALWAYS_FATAL_IF(context->gl.texture_count != 1);
for (int i = 0; i < context->gl.texture_count; ++i) {
glBindTexture(context->gl.texture_target_type, context->gl.texture_id[i]);
glEGLImageTargetTexture2DOES(context->gl.texture_target_type,
context->current_buffer->image_khr(i));
}
glBindTexture(context->gl.texture_target_type, 0);
CHECK_GL();
bool is_late_latch = false;
// Pass back the texture target type and id.
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_ENABLE_LATE_LATCH_IN:
is_late_latch = !!p->value;
break;
case DVR_SURFACE_PARAMETER_SURFACE_TEXTURE_TARGET_TYPE_OUT:
*static_cast<GLenum*>(p->value_out) = context->gl.texture_target_type;
break;
case DVR_SURFACE_PARAMETER_SURFACE_TEXTURE_TARGET_ID_OUT:
for (int i = 0; i < context->gl.texture_count; ++i) {
*(static_cast<GLuint*>(p->value_out) + i) =
context->gl.texture_id[i];
}
break;
}
}
// Initialize late latch.
if (is_late_latch) {
LocalHandle fd = context->metadata_buffer->GetBlobFd();
context->late_latch.reset(
new android::dvr::LateLatch(true, std::move(fd)));
}
} else if (context->graphics_api == DVR_GRAPHICS_API_VULKAN) {
VkResult result = VK_SUCCESS;
// Create a VkSurfaceKHR from the ANativeWindow.
VkAndroidSurfaceCreateInfoKHR android_surface_ci = {};
android_surface_ci.sType =
VK_STRUCTURE_TYPE_ANDROID_SURFACE_CREATE_INFO_KHR;
android_surface_ci.window = context.get();
result = vkCreateAndroidSurfaceKHR(
context->vk.instance, &android_surface_ci,
context->vk.allocation_callbacks, &context->vk.surface);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
VkBool32 surface_supports_present = VK_FALSE;
result = vkGetPhysicalDeviceSurfaceSupportKHR(
context->vk.physical_device, context->vk.present_queue_family,
context->vk.surface, &surface_supports_present);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
if (!surface_supports_present) {
ALOGE("Error: provided queue family (%u) does not support presentation",
context->vk.present_queue_family);
return -EPERM;
}
VkSurfaceCapabilitiesKHR surface_capabilities = {};
result = vkGetPhysicalDeviceSurfaceCapabilitiesKHR(
context->vk.physical_device, context->vk.surface,
&surface_capabilities);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
// Determine the swapchain image format.
uint32_t device_surface_format_count = 0;
result = vkGetPhysicalDeviceSurfaceFormatsKHR(
context->vk.physical_device, context->vk.surface,
&device_surface_format_count, nullptr);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
std::vector<VkSurfaceFormatKHR> device_surface_formats(
device_surface_format_count);
result = vkGetPhysicalDeviceSurfaceFormatsKHR(
context->vk.physical_device, context->vk.surface,
&device_surface_format_count, device_surface_formats.data());
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
LOG_ALWAYS_FATAL_IF(device_surface_format_count == 0U);
LOG_ALWAYS_FATAL_IF(device_surface_formats[0].format ==
VK_FORMAT_UNDEFINED);
VkSurfaceFormatKHR present_surface_format = device_surface_formats[0];
// Determine the swapchain present mode.
// TODO(cort): query device_present_modes to make sure MAILBOX is supported.
// But according to libvulkan, it is.
uint32_t device_present_mode_count = 0;
result = vkGetPhysicalDeviceSurfacePresentModesKHR(
context->vk.physical_device, context->vk.surface,
&device_present_mode_count, nullptr);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
std::vector<VkPresentModeKHR> device_present_modes(
device_present_mode_count);
result = vkGetPhysicalDeviceSurfacePresentModesKHR(
context->vk.physical_device, context->vk.surface,
&device_present_mode_count, device_present_modes.data());
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
VkPresentModeKHR present_mode = VK_PRESENT_MODE_MAILBOX_KHR;
// Extract presentation surface extents, image count, transform, usages,
// etc.
LOG_ALWAYS_FATAL_IF(
static_cast<int>(surface_capabilities.currentExtent.width) == -1 ||
static_cast<int>(surface_capabilities.currentExtent.height) == -1);
VkExtent2D swapchain_extent = surface_capabilities.currentExtent;
uint32_t desired_image_count = surface_capabilities.minImageCount;
if (surface_capabilities.maxImageCount > 0 &&
desired_image_count > surface_capabilities.maxImageCount) {
desired_image_count = surface_capabilities.maxImageCount;
}
VkSurfaceTransformFlagBitsKHR surface_transform =
surface_capabilities.currentTransform;
VkImageUsageFlags image_usage_flags =
surface_capabilities.supportedUsageFlags;
LOG_ALWAYS_FATAL_IF(surface_capabilities.supportedCompositeAlpha ==
static_cast<VkFlags>(0));
VkCompositeAlphaFlagBitsKHR composite_alpha =
VK_COMPOSITE_ALPHA_OPAQUE_BIT_KHR;
if (!(surface_capabilities.supportedCompositeAlpha &
VK_COMPOSITE_ALPHA_OPAQUE_BIT_KHR)) {
composite_alpha = VkCompositeAlphaFlagBitsKHR(
static_cast<int>(surface_capabilities.supportedCompositeAlpha) &
-static_cast<int>(surface_capabilities.supportedCompositeAlpha));
}
// Create VkSwapchainKHR
VkSwapchainCreateInfoKHR swapchain_ci = {};
swapchain_ci.sType = VK_STRUCTURE_TYPE_SWAPCHAIN_CREATE_INFO_KHR;
swapchain_ci.pNext = nullptr;
swapchain_ci.surface = context->vk.surface;
swapchain_ci.minImageCount = desired_image_count;
swapchain_ci.imageFormat = present_surface_format.format;
swapchain_ci.imageColorSpace = present_surface_format.colorSpace;
swapchain_ci.imageExtent.width = swapchain_extent.width;
swapchain_ci.imageExtent.height = swapchain_extent.height;
swapchain_ci.imageUsage = image_usage_flags;
swapchain_ci.preTransform = surface_transform;
swapchain_ci.compositeAlpha = composite_alpha;
swapchain_ci.imageArrayLayers = 1;
swapchain_ci.imageSharingMode = VK_SHARING_MODE_EXCLUSIVE;
swapchain_ci.queueFamilyIndexCount = 0;
swapchain_ci.pQueueFamilyIndices = nullptr;
swapchain_ci.presentMode = present_mode;
swapchain_ci.clipped = VK_TRUE;
swapchain_ci.oldSwapchain = VK_NULL_HANDLE;
result = vkCreateSwapchainKHR(context->vk.device, &swapchain_ci,
context->vk.allocation_callbacks,
&context->vk.swapchain);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
// Create swapchain image views
uint32_t image_count = 0;
result = vkGetSwapchainImagesKHR(context->vk.device, context->vk.swapchain,
&image_count, nullptr);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
LOG_ALWAYS_FATAL_IF(image_count == 0U);
context->vk.swapchain_images.resize(image_count);
result = vkGetSwapchainImagesKHR(context->vk.device, context->vk.swapchain,
&image_count,
context->vk.swapchain_images.data());
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
context->vk.swapchain_image_views.resize(image_count);
VkImageViewCreateInfo image_view_ci = {};
image_view_ci.sType = VK_STRUCTURE_TYPE_IMAGE_VIEW_CREATE_INFO;
image_view_ci.pNext = nullptr;
image_view_ci.flags = 0;
image_view_ci.format = swapchain_ci.imageFormat;
image_view_ci.components.r = VK_COMPONENT_SWIZZLE_IDENTITY;
image_view_ci.components.g = VK_COMPONENT_SWIZZLE_IDENTITY;
image_view_ci.components.b = VK_COMPONENT_SWIZZLE_IDENTITY;
image_view_ci.components.a = VK_COMPONENT_SWIZZLE_IDENTITY;
image_view_ci.subresourceRange.aspectMask = VK_IMAGE_ASPECT_COLOR_BIT;
image_view_ci.subresourceRange.baseMipLevel = 0;
image_view_ci.subresourceRange.levelCount = 1;
image_view_ci.subresourceRange.baseArrayLayer = 0;
image_view_ci.subresourceRange.layerCount = 1;
image_view_ci.viewType = VK_IMAGE_VIEW_TYPE_2D;
image_view_ci.image = VK_NULL_HANDLE; // filled in below
for (uint32_t i = 0; i < image_count; ++i) {
image_view_ci.image = context->vk.swapchain_images[i];
result = vkCreateImageView(context->vk.device, &image_view_ci,
context->vk.allocation_callbacks,
&context->vk.swapchain_image_views[i]);
LOG_ALWAYS_FATAL_IF(result != VK_SUCCESS);
}
// Fill in any requested output parameters.
for (auto p = parameters; p && p->key != DVR_SURFACE_PARAMETER_NONE; ++p) {
switch (p->key) {
case DVR_SURFACE_PARAMETER_VK_SWAPCHAIN_IMAGE_COUNT_OUT:
*static_cast<uint32_t*>(p->value_out) = image_count;
break;
case DVR_SURFACE_PARAMETER_VK_SWAPCHAIN_IMAGE_FORMAT_OUT:
*static_cast<VkFormat*>(p->value_out) = swapchain_ci.imageFormat;
break;
}
}
}
*return_graphics_context = context.release();
return 0;
}
void dvrGraphicsContextDestroy(DvrGraphicsContext* graphics_context) {
delete graphics_context;
}
// ANativeWindow function implementations. These should only be used
// by the Vulkan path.
int DvrGraphicsContext::Post(android::dvr::NativeBufferProducer* buffer,
int fence_fd) {
LOG_ALWAYS_FATAL_IF(graphics_api != DVR_GRAPHICS_API_VULKAN);
ATRACE_NAME(__PRETTY_FUNCTION__);
ALOGI_IF(TRACE, "DvrGraphicsContext::Post: buffer_id=%d, fence_fd=%d",
buffer->buffer()->id(), fence_fd);
ALOGW_IF(!display_surface->visible(),
"DvrGraphicsContext::Post: Posting buffer on invisible surface!!!");
// The NativeBufferProducer closes the fence fd, so dup it for tracking in the
// frame history.
frame_history.OnFrameSubmit(LocalHandle::AsDuplicate(fence_fd));
int result = buffer->Post(fence_fd, 0);
return result;
}
int DvrGraphicsContext::SetSwapInterval(ANativeWindow* window, int interval) {
ALOGI_IF(TRACE, "SetSwapInterval: window=%p interval=%d", window, interval);
DvrGraphicsContext* self = getSelf(window);
(void)self;
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
return android::NO_ERROR;
}
int DvrGraphicsContext::DequeueBuffer(ANativeWindow* window,
ANativeWindowBuffer** buffer,
int* fence_fd) {
ATRACE_NAME(__PRETTY_FUNCTION__);
DvrGraphicsContext* self = getSelf(window);
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
std::lock_guard<std::mutex> autolock(self->lock_);
if (!self->current_buffer) {
self->current_buffer = self->buffer_queue->Dequeue();
}
ATRACE_ASYNC_BEGIN("BufferDraw", self->current_buffer->buffer()->id());
*fence_fd = self->current_buffer->ClaimReleaseFence().Release();
*buffer = self->current_buffer;
ALOGI_IF(TRACE, "DvrGraphicsContext::DequeueBuffer: fence_fd=%d", *fence_fd);
return android::NO_ERROR;
}
int DvrGraphicsContext::QueueBuffer(ANativeWindow* window,
ANativeWindowBuffer* buffer, int fence_fd) {
ATRACE_NAME("NativeWindow::QueueBuffer");
ALOGI_IF(TRACE, "NativeWindow::QueueBuffer: fence_fd=%d", fence_fd);
DvrGraphicsContext* self = getSelf(window);
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
std::lock_guard<std::mutex> autolock(self->lock_);
android::dvr::NativeBufferProducer* native_buffer =
static_cast<android::dvr::NativeBufferProducer*>(buffer);
ATRACE_ASYNC_END("BufferDraw", native_buffer->buffer()->id());
bool do_post = true;
if (self->buffer_already_posted) {
// Check that the buffer is the one we expect, but handle it if this happens
// in production by allowing this buffer to post on top of the previous one.
LOG_FATAL_IF(native_buffer != self->current_buffer);
if (native_buffer == self->current_buffer) {
do_post = false;
if (fence_fd >= 0)
close(fence_fd);
}
}
if (do_post) {
ATRACE_ASYNC_BEGIN("BufferPost", native_buffer->buffer()->id());
self->Post(native_buffer, fence_fd);
}
self->buffer_already_posted = false;
self->current_buffer = nullptr;
return android::NO_ERROR;
}
int DvrGraphicsContext::CancelBuffer(ANativeWindow* window,
ANativeWindowBuffer* buffer,
int fence_fd) {
ATRACE_NAME("DvrGraphicsContext::CancelBuffer");
ALOGI_IF(TRACE, "DvrGraphicsContext::CancelBuffer: fence_fd: %d", fence_fd);
DvrGraphicsContext* self = getSelf(window);
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
std::lock_guard<std::mutex> autolock(self->lock_);
android::dvr::NativeBufferProducer* native_buffer =
static_cast<android::dvr::NativeBufferProducer*>(buffer);
ATRACE_ASYNC_END("BufferDraw", native_buffer->buffer()->id());
ATRACE_INT("CancelBuffer", native_buffer->buffer()->id());
bool do_enqueue = true;
if (self->buffer_already_posted) {
// Check that the buffer is the one we expect, but handle it if this happens
// in production by returning this buffer to the buffer queue.
LOG_FATAL_IF(native_buffer != self->current_buffer);
if (native_buffer == self->current_buffer) {
do_enqueue = false;
}
}
if (do_enqueue) {
self->buffer_queue->Enqueue(native_buffer);
}
if (fence_fd >= 0)
close(fence_fd);
self->buffer_already_posted = false;
self->current_buffer = nullptr;
return android::NO_ERROR;
}
int DvrGraphicsContext::Query(const ANativeWindow* window, int what,
int* value) {
DvrGraphicsContext* self = getSelf(const_cast<ANativeWindow*>(window));
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
std::lock_guard<std::mutex> autolock(self->lock_);
switch (what) {
case NATIVE_WINDOW_WIDTH:
*value = self->width;
return android::NO_ERROR;
case NATIVE_WINDOW_HEIGHT:
*value = self->height;
return android::NO_ERROR;
case NATIVE_WINDOW_FORMAT:
*value = self->format;
return android::NO_ERROR;
case NATIVE_WINDOW_MIN_UNDEQUEUED_BUFFERS:
*value = 1;
return android::NO_ERROR;
case NATIVE_WINDOW_CONCRETE_TYPE:
*value = NATIVE_WINDOW_SURFACE;
return android::NO_ERROR;
case NATIVE_WINDOW_QUEUES_TO_WINDOW_COMPOSER:
*value = 1;
return android::NO_ERROR;
case NATIVE_WINDOW_DEFAULT_WIDTH:
*value = self->width;
return android::NO_ERROR;
case NATIVE_WINDOW_DEFAULT_HEIGHT:
*value = self->height;
return android::NO_ERROR;
case NATIVE_WINDOW_TRANSFORM_HINT:
*value = 0;
return android::NO_ERROR;
}
*value = 0;
return android::BAD_VALUE;
}
int DvrGraphicsContext::Perform(ANativeWindow* window, int operation, ...) {
DvrGraphicsContext* self = getSelf(window);
LOG_ALWAYS_FATAL_IF(self->graphics_api != DVR_GRAPHICS_API_VULKAN);
std::lock_guard<std::mutex> autolock(self->lock_);
va_list args;
va_start(args, operation);
// TODO(eieio): The following operations are not used at this time. They are
// included here to help document which operations may be useful and what
// parameters they take.
switch (operation) {
case NATIVE_WINDOW_SET_BUFFERS_DIMENSIONS: {
int w = va_arg(args, int);
int h = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_BUFFERS_DIMENSIONS: w=%d h=%d", w, h);
return android::NO_ERROR;
}
case NATIVE_WINDOW_SET_BUFFERS_FORMAT: {
int format = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_BUFFERS_FORMAT: format=%d", format);
return android::NO_ERROR;
}
case NATIVE_WINDOW_SET_BUFFERS_TRANSFORM: {
int transform = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_BUFFERS_TRANSFORM: transform=%d",
transform);
return android::NO_ERROR;
}
case NATIVE_WINDOW_SET_USAGE: {
int usage = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_USAGE: usage=%d", usage);
return android::NO_ERROR;
}
case NATIVE_WINDOW_CONNECT:
case NATIVE_WINDOW_DISCONNECT:
case NATIVE_WINDOW_SET_BUFFERS_GEOMETRY:
case NATIVE_WINDOW_API_CONNECT:
case NATIVE_WINDOW_API_DISCONNECT:
// TODO(eieio): we should implement these
return android::NO_ERROR;
case NATIVE_WINDOW_SET_BUFFER_COUNT: {
int buffer_count = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_BUFFER_COUNT: bufferCount=%d",
buffer_count);
return android::NO_ERROR;
}
case NATIVE_WINDOW_SET_BUFFERS_DATASPACE: {
android_dataspace_t data_space =
static_cast<android_dataspace_t>(va_arg(args, int));
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_BUFFERS_DATASPACE: dataSpace=%d",
data_space);
return android::NO_ERROR;
}
case NATIVE_WINDOW_SET_SCALING_MODE: {
int mode = va_arg(args, int);
ALOGD_IF(TRACE, "NATIVE_WINDOW_SET_SCALING_MODE: mode=%d", mode);
return android::NO_ERROR;
}
case NATIVE_WINDOW_LOCK:
case NATIVE_WINDOW_UNLOCK_AND_POST:
case NATIVE_WINDOW_SET_CROP:
case NATIVE_WINDOW_SET_BUFFERS_TIMESTAMP:
return android::INVALID_OPERATION;
}
return android::NAME_NOT_FOUND;
}
int DvrGraphicsContext::DequeueBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer** buffer) {
int fence_fd = -1;
int ret = DequeueBuffer(window, buffer, &fence_fd);
// wait for fence
if (ret == android::NO_ERROR && fence_fd != -1)
close(fence_fd);
return ret;
}
int DvrGraphicsContext::CancelBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer* buffer) {
return CancelBuffer(window, buffer, -1);
}
int DvrGraphicsContext::QueueBuffer_DEPRECATED(ANativeWindow* window,
ANativeWindowBuffer* buffer) {
return QueueBuffer(window, buffer, -1);
}
int DvrGraphicsContext::LockBuffer_DEPRECATED(ANativeWindow* /*window*/,
ANativeWindowBuffer* /*buffer*/) {
return android::NO_ERROR;
}
// End ANativeWindow implementation
int dvrSetEdsPose(DvrGraphicsContext* graphics_context,
float32x4_t render_pose_orientation,
float32x4_t render_pose_translation) {
ATRACE_NAME("dvrSetEdsPose");
if (!graphics_context->current_buffer) {
ALOGE("dvrBeginRenderFrame must be called before dvrSetEdsPose");
return -EPERM;
}
// When late-latching is enabled, the pose buffer is written by the GPU, so
// we don't touch it here.
float32x4_t is_late_latch = DVR_POSE_LATE_LATCH;
if (render_pose_orientation[0] != is_late_latch[0]) {
volatile DisplaySurfaceMetadata* data = graphics_context->surface_metadata;
uint32_t buffer_index = 0;
ALOGE_IF(TRACE, "write pose index %d %f %f", buffer_index,
render_pose_orientation[0], render_pose_orientation[1]);
data->orientation[buffer_index] = render_pose_orientation;
data->translation[buffer_index] = render_pose_translation;
}
return 0;
}
int dvrBeginRenderFrameEds(DvrGraphicsContext* graphics_context,
float32x4_t render_pose_orientation,
float32x4_t render_pose_translation) {
ATRACE_NAME("dvrBeginRenderFrameEds");
LOG_ALWAYS_FATAL_IF(graphics_context->graphics_api != DVR_GRAPHICS_API_GLES);
CHECK_GL();
// Grab a buffer from the queue and set its pose.
if (!graphics_context->current_buffer) {
graphics_context->current_buffer =
graphics_context->buffer_queue->Dequeue();
}
int ret = dvrSetEdsPose(graphics_context, render_pose_orientation,
render_pose_translation);
if (ret < 0)
return ret;
ATRACE_ASYNC_BEGIN("BufferDraw",
graphics_context->current_buffer->buffer()->id());
{
ATRACE_NAME("glEGLImageTargetTexture2DOES");
// Bind the texture to the latest buffer in the queue.
for (int i = 0; i < graphics_context->gl.texture_count; ++i) {
glBindTexture(graphics_context->gl.texture_target_type,
graphics_context->gl.texture_id[i]);
glEGLImageTargetTexture2DOES(
graphics_context->gl.texture_target_type,
graphics_context->current_buffer->image_khr(i));
}
glBindTexture(graphics_context->gl.texture_target_type, 0);
}
CHECK_GL();
return 0;
}
int dvrBeginRenderFrameEdsVk(DvrGraphicsContext* graphics_context,
float32x4_t render_pose_orientation,
float32x4_t render_pose_translation,
VkSemaphore acquire_semaphore,
VkFence acquire_fence,
uint32_t* swapchain_image_index,
VkImageView* swapchain_image_view) {
ATRACE_NAME("dvrBeginRenderFrameEds");
LOG_ALWAYS_FATAL_IF(graphics_context->graphics_api !=
DVR_GRAPHICS_API_VULKAN);
// Acquire a swapchain image. This calls Dequeue() internally.
VkResult result = vkAcquireNextImageKHR(
graphics_context->vk.device, graphics_context->vk.swapchain, UINT64_MAX,
acquire_semaphore, acquire_fence, swapchain_image_index);
if (result != VK_SUCCESS)
return -EINVAL;
// Set the pose pose.
int ret = dvrSetEdsPose(graphics_context, render_pose_orientation,
render_pose_translation);
if (ret < 0)
return ret;
*swapchain_image_view =
graphics_context->vk.swapchain_image_views[*swapchain_image_index];
return 0;
}
int dvrBeginRenderFrame(DvrGraphicsContext* graphics_context) {
return dvrBeginRenderFrameEds(graphics_context, DVR_POSE_NO_EDS,
DVR_POSE_NO_EDS);
}
int dvrBeginRenderFrameVk(DvrGraphicsContext* graphics_context,
VkSemaphore acquire_semaphore, VkFence acquire_fence,
uint32_t* swapchain_image_index,
VkImageView* swapchain_image_view) {
return dvrBeginRenderFrameEdsVk(
graphics_context, DVR_POSE_NO_EDS, DVR_POSE_NO_EDS, acquire_semaphore,
acquire_fence, swapchain_image_index, swapchain_image_view);
}
int dvrBeginRenderFrameLateLatch(DvrGraphicsContext* graphics_context,
uint32_t /*flags*/,
uint32_t target_vsync_count, int num_views,
const float** projection_matrices,
const float** eye_from_head_matrices,
const float** pose_offset_matrices,
uint32_t* out_late_latch_buffer_id) {
if (!graphics_context->late_latch) {
return -EPERM;
}
if (num_views > DVR_GRAPHICS_SURFACE_MAX_VIEWS) {
ALOGE("dvrBeginRenderFrameLateLatch called with too many views.");
return -EINVAL;
}
dvrBeginRenderFrameEds(graphics_context, DVR_POSE_LATE_LATCH,
DVR_POSE_LATE_LATCH);
auto& ll = graphics_context->late_latch;
// TODO(jbates) Need to change this shader so that it dumps the single
// captured pose for both eyes into the display surface metadata buffer at
// the right index.
android::dvr::LateLatchInput input;
memset(&input, 0, sizeof(input));
for (int i = 0; i < num_views; ++i) {
memcpy(input.proj_mat + i, *(projection_matrices + i), 16 * sizeof(float));
memcpy(input.eye_from_head_mat + i, *(eye_from_head_matrices + i),
16 * sizeof(float));
memcpy(input.pose_offset + i, *(pose_offset_matrices + i),
16 * sizeof(float));
}
input.pose_index =
target_vsync_count & android::dvr::kPoseAsyncBufferIndexMask;
input.render_pose_index =
graphics_context->current_buffer->surface_buffer_index();
ll->AddLateLatch(input);
*out_late_latch_buffer_id = ll->output_buffer_id();
return 0;
}
extern "C" int dvrGraphicsWaitNextFrame(
DvrGraphicsContext* graphics_context, int64_t start_delay_ns,
DvrFrameSchedule* out_next_frame_schedule) {
start_delay_ns = std::max(start_delay_ns, static_cast<int64_t>(0));
// We only do one-shot timers:
int64_t wake_time_ns = 0;
uint32_t current_frame_vsync;
int64_t current_frame_scheduled_finish_ns;
int64_t vsync_period_ns;
int fetch_schedule_result = graphics_context->vsync_client->GetSchedInfo(
&vsync_period_ns, &current_frame_scheduled_finish_ns,
&current_frame_vsync);
if (fetch_schedule_result == 0) {
wake_time_ns = current_frame_scheduled_finish_ns + start_delay_ns;
// If the last wakeup time is still in the future, use it instead to avoid
// major schedule jumps when applications call WaitNextFrame with
// aggressive offsets.
int64_t now = android::dvr::GetSystemClockNs();
if (android::dvr::TimestampGT(wake_time_ns - vsync_period_ns, now)) {
wake_time_ns -= vsync_period_ns;
--current_frame_vsync;
}
// If the next wakeup time is in the past, add a vsync period to keep the
// application on schedule.
if (android::dvr::TimestampLT(wake_time_ns, now)) {
wake_time_ns += vsync_period_ns;
++current_frame_vsync;
}
} else {
ALOGE("Error getting frame schedule because: %s",
strerror(-fetch_schedule_result));
// Sleep for a vsync period to avoid cascading failure.
wake_time_ns = android::dvr::GetSystemClockNs() +
graphics_context->display_metrics.vsync_period_ns;
}
// Adjust nsec to [0..999,999,999].
struct itimerspec wake_time;
wake_time.it_interval.tv_sec = 0;
wake_time.it_interval.tv_nsec = 0;
wake_time.it_value = android::dvr::NsToTimespec(wake_time_ns);
bool sleep_result =
timerfd_settime(graphics_context->timerfd.Get(), TFD_TIMER_ABSTIME,
&wake_time, nullptr) == 0;
if (sleep_result) {
ATRACE_NAME("sleep");
uint64_t expirations = 0;
sleep_result = read(graphics_context->timerfd.Get(), &expirations,
sizeof(uint64_t)) == sizeof(uint64_t);
if (!sleep_result) {
ALOGE("Error: timerfd read failed");
}
} else {
ALOGE("Error: timerfd_settime failed because: %s", strerror(errno));
}
auto& frame_history = graphics_context->frame_history;
frame_history.CheckForFinishedFrames();
if (fetch_schedule_result == 0) {
uint32_t next_frame_vsync =
current_frame_vsync +
frame_history.PredictNextFrameVsyncInterval(vsync_period_ns);
int64_t next_frame_scheduled_finish =
(wake_time_ns - start_delay_ns) + vsync_period_ns;
frame_history.OnFrameStart(next_frame_vsync, next_frame_scheduled_finish);
if (out_next_frame_schedule) {
out_next_frame_schedule->vsync_count = next_frame_vsync;
out_next_frame_schedule->scheduled_frame_finish_ns =
next_frame_scheduled_finish;
}
} else {
frame_history.OnFrameStart(UINT32_MAX, -1);
}
return (fetch_schedule_result == 0 && sleep_result) ? 0 : -1;
}
extern "C" void dvrGraphicsPostEarly(DvrGraphicsContext* graphics_context) {
ATRACE_NAME("dvrGraphicsPostEarly");
ALOGI_IF(TRACE, "dvrGraphicsPostEarly");
LOG_ALWAYS_FATAL_IF(graphics_context->graphics_api != DVR_GRAPHICS_API_GLES);
// Note that this function can be called before or after
// dvrBeginRenderFrame.
if (!graphics_context->buffer_already_posted) {
graphics_context->buffer_already_posted = true;
if (!graphics_context->current_buffer) {
graphics_context->current_buffer =
graphics_context->buffer_queue->Dequeue();
}
auto buffer = graphics_context->current_buffer->buffer().get();
ATRACE_ASYNC_BEGIN("BufferPost", buffer->id());
int result = buffer->Post<void>(LocalHandle());
if (result < 0)
ALOGE("Buffer post failed: %d (%s)", result, strerror(-result));
}
}
int dvrPresent(DvrGraphicsContext* graphics_context) {
LOG_ALWAYS_FATAL_IF(graphics_context->graphics_api != DVR_GRAPHICS_API_GLES);
std::array<char, 128> buf;
snprintf(buf.data(), buf.size(), "dvrPresent|vsync=%d|",
graphics_context->frame_history.GetCurrentFrameVsync());
ATRACE_NAME(buf.data());
if (!graphics_context->current_buffer) {
ALOGE("Error: dvrPresent called without dvrBeginRenderFrame");
return -EPERM;
}
LocalHandle fence_fd =
android::dvr::CreateGLSyncAndFlush(graphics_context->gl.egl_display);
ALOGI_IF(TRACE, "PostBuffer: buffer_id=%d, fence_fd=%d",
graphics_context->current_buffer->buffer()->id(), fence_fd.Get());
ALOGW_IF(!graphics_context->display_surface->visible(),
"PostBuffer: Posting buffer on invisible surface!!!");
auto buffer = graphics_context->current_buffer->buffer().get();
ATRACE_ASYNC_END("BufferDraw", buffer->id());
if (!graphics_context->buffer_already_posted) {
ATRACE_ASYNC_BEGIN("BufferPost", buffer->id());
int result = buffer->Post<void>(fence_fd);
if (result < 0)
ALOGE("Buffer post failed: %d (%s)", result, strerror(-result));
}
graphics_context->frame_history.OnFrameSubmit(std::move(fence_fd));
graphics_context->buffer_already_posted = false;
graphics_context->current_buffer = nullptr;
return 0;
}
int dvrPresentVk(DvrGraphicsContext* graphics_context,
VkSemaphore submit_semaphore, uint32_t swapchain_image_index) {
LOG_ALWAYS_FATAL_IF(graphics_context->graphics_api !=
DVR_GRAPHICS_API_VULKAN);
std::array<char, 128> buf;
snprintf(buf.data(), buf.size(), "dvrPresent|vsync=%d|",
graphics_context->frame_history.GetCurrentFrameVsync());
ATRACE_NAME(buf.data());
if (!graphics_context->current_buffer) {
ALOGE("Error: dvrPresentVk called without dvrBeginRenderFrameVk");
return -EPERM;
}
// Present the specified image. Internally, this gets a fence from the
// Vulkan driver and passes it to DvrGraphicsContext::Post(),
// which in turn passes it to buffer->Post() and adds it to frame_history.
VkPresentInfoKHR present_info = {};
present_info.sType = VK_STRUCTURE_TYPE_PRESENT_INFO_KHR;
present_info.swapchainCount = 1;
present_info.pSwapchains = &graphics_context->vk.swapchain;
present_info.pImageIndices = &swapchain_image_index;
present_info.waitSemaphoreCount =
(submit_semaphore != VK_NULL_HANDLE) ? 1 : 0;
present_info.pWaitSemaphores = &submit_semaphore;
VkResult result =
vkQueuePresentKHR(graphics_context->vk.present_queue, &present_info);
if (result != VK_SUCCESS) {
return -EINVAL;
}
return 0;
}
extern "C" int dvrGetFrameScheduleResults(DvrGraphicsContext* context,
DvrFrameScheduleResult* results,
int in_result_count) {
if (!context || !results)
return -EINVAL;
return context->frame_history.GetPreviousFrameResults(results,
in_result_count);
}
extern "C" void dvrGraphicsSurfaceSetVisible(
DvrGraphicsContext* graphics_context, int visible) {
graphics_context->display_surface->SetVisible(visible);
}
extern "C" int dvrGraphicsSurfaceGetVisible(
DvrGraphicsContext* graphics_context) {
return !!graphics_context->display_surface->visible();
}
extern "C" void dvrGraphicsSurfaceSetZOrder(
DvrGraphicsContext* graphics_context, int z_order) {
graphics_context->display_surface->SetZOrder(z_order);
}
extern "C" int dvrGraphicsSurfaceGetZOrder(
DvrGraphicsContext* graphics_context) {
return graphics_context->display_surface->z_order();
}