src/intel/vulkan/anv_magma.c

/*
 * Copyright © 2016 Google, LLC
 *
 * Permission is hereby granted, free of charge, to any person obtaining a
 * copy of this software and associated documentation files (the "Software"),
 * to deal in the Software without restriction, including without limitation
 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
 * and/or sell copies of the Software, and to permit persons to whom the
 * Software is furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice (including the next
 * paragraph) shall be included in all copies or substantial portions of the
 * Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
 * IN THE SOFTWARE.
 */

#include "anv_private.h"
#include "anv_magma.h"
#include "anv_magma_map.h"
#include "dev/gen_device_info.h" // for gen_getparam
#include <magma_intel_gen_defs.h>
#include <sys/mman.h> // for MAP_FAILED
#include <drm_fourcc.h>

#if defined(__linux__)
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#endif

#if defined(__Fuchsia__)
#include "os/fuchsia.h"
#include <zircon/syscalls.h>
#endif

#include <util/magma_wait.h>

#define LOG_VERBOSE(...)                                                                           \
   do {                                                                                            \
      if (false)                                                                                   \
         mesa_logi(__VA_ARGS__);                                                                  \
   } while (0)

static magma_connection_t magma_connection(struct anv_device* device)
{
   assert(device);
   assert(device->connection);
   return device->connection->connection;
}

//////////////////////////////////////////////////////////////////////////////////////////////////

void BufferMap_Init(struct BufferMap* map)
{
   size_t node_size = 8;  /* grows as necessary */
   uint32_t sentinel = 0; /* invalid gem_handle */

   util_sparse_array_init(&map->array, sizeof(struct BufferMapEntry), node_size);
   util_sparse_array_free_list_init(&map->free_list, &map->array, sentinel,
                                    offsetof(struct BufferMapEntry, free_index));

   map->next_index = 1;
}

void BufferMap_Release(struct BufferMap* map)
{
   struct BufferMapEntry* entry;
   while ((entry = util_sparse_array_free_list_pop_elem(&map->free_list))) {
   }
   util_sparse_array_finish(&map->array);
}

void BufferMap_Get(struct BufferMap* map, struct BufferMapEntry** entry_out)
{
   *entry_out = util_sparse_array_free_list_pop_elem(&map->free_list);
   if (*entry_out)
      return;

   uint32_t gem_handle = atomic_fetch_add(&map->next_index, 1);

   struct BufferMapEntry* entry = util_sparse_array_get(&map->array, gem_handle);

   entry->gem_handle = gem_handle;

   *entry_out = entry;
}

void BufferMap_Query(struct BufferMap* map, uint32_t gem_handle, struct BufferMapEntry** entry_out)
{
   struct BufferMapEntry* entry = util_sparse_array_get(&map->array, gem_handle);
   assert(entry->gem_handle == gem_handle);
   *entry_out = entry;
}

void BufferMap_Put(struct BufferMap* map, uint32_t gem_handle)
{
   util_sparse_array_free_list_push(&map->free_list, &gem_handle, 1);
}

//////////////////////////////////////////////////////////////////////////////////////////////////

int anv_gem_connect(struct anv_device* device)
{
   magma_connection_t connection;
   magma_status_t status = magma_create_connection2((magma_device_t)device->handle, &connection);
   if (status != MAGMA_STATUS_OK || !connection) {
      mesa_logd("magma_create_connection failed: %d", status);
      return -1;
   }

   device->connection = AnvMagmaCreateConnection(connection);

   device->connection->buffer_map = malloc(sizeof(struct BufferMap));
   BufferMap_Init(device->connection->buffer_map);

   LOG_VERBOSE("created magma connection");

   return 0;
}

void anv_gem_disconnect(struct anv_device* device)
{
   BufferMap_Release(device->connection->buffer_map);
   free(device->connection->buffer_map);

   AnvMagmaReleaseConnection(device->connection);
   LOG_VERBOSE("released magma connection");
}

// Return handle, or 0 on failure. Gem handles are never 0.
uint32_t anv_gem_create(struct anv_device* device, size_t size)
{
   magma_buffer_t buffer;
   uint64_t magma_size = size;
   magma_status_t status =
       magma_create_buffer(magma_connection(device), magma_size, &magma_size, &buffer);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_create_buffer failed (%d) size 0x%zx", status, magma_size);
      return 0;
   }

   struct BufferMapEntry* entry;
   BufferMap_Get(device->connection->buffer_map, &entry);

   entry->buffer = AnvMagmaCreateBuffer(device->connection, buffer);

   LOG_VERBOSE("magma_create_buffer size 0x%zx returning buffer %lu gem_handle %u", magma_size,
               entry->buffer->id, entry->gem_handle);

   return entry->gem_handle;
}

void anv_gem_close(struct anv_device* device, uint32_t gem_handle)
{
   LOG_VERBOSE("anv_gem_close gem_handle %u", gem_handle);

   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return;
   }

   AnvMagmaReleaseBuffer(device->connection, entry->buffer);

   BufferMap_Put(device->connection->buffer_map, gem_handle);
}

static void* mmap_and_close_handle(magma_handle_t handle, uint64_t offset, uint64_t size) {
#if defined(__Fuchsia__)
   zx_handle_t vmo_handle = handle;

   zx_vaddr_t zx_vaddr;
   zx_status_t zx_status = zx_vmar_map(zx_vmar_root_self(), ZX_VM_PERM_READ | ZX_VM_PERM_WRITE,
                                       0 /*vmar_offset*/, vmo_handle, offset, size, &zx_vaddr);

   zx_handle_close(vmo_handle);

   if (zx_status != ZX_OK) {
      mesa_logd("zx_vmar_map failed: status %d", zx_status);
      return MAP_FAILED;
   }

   void* addr = (void*) zx_vaddr;

#elif defined(__linux__)
   int fd = handle;

   void* addr = mmap(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, offset);

   close(fd);

#else
#error Unsupported
#endif

   return addr;
}

void* anv_gem_mmap(struct anv_device* device, uint32_t gem_handle, uint64_t offset, uint64_t size,
                   uint32_t flags)
{
   assert(flags == 0);

   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return MAP_FAILED;
   }

   magma_buffer_t buffer = entry->buffer->buffer;

   magma_handle_t handle;
   magma_status_t status = magma_get_buffer_handle2(buffer, &handle);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_get_buffer_handle failed: status %d", status);
      return MAP_FAILED;
   }

   void* addr = mmap_and_close_handle(handle, offset, size);

   LOG_VERBOSE("anv_gem_mmap gem_handle %u buffer %lu offset %lu size 0x%zx returning %p",
               gem_handle, entry->buffer->id, offset, size, addr);

   return addr;
}

void anv_gem_munmap(struct anv_device* device, void* addr, uint64_t size)
{
   if (!addr)
      return;

#ifdef __Fuchsia__
   zx_status_t status = zx_vmar_unmap(zx_vmar_root_self(), (zx_vaddr_t) addr, size);
   if (status != ZX_OK) {
      mesa_logd("zx_vmar_unmap failed: %d", status);
      return;
   }
#endif

#ifdef __linux__
   int status = munmap(addr, size);
   if (status) {
      mesa_logd("munmap failed: %d", status);
      return;
   }
#endif

   LOG_VERBOSE("anv_gem_munmap addr %p sizee %lu", addr, size);
}

uint32_t anv_gem_userptr(struct anv_device* device, void* mem, size_t size)
{
   LOG_VERBOSE("anv_gem_userptr - STUB");
   assert(false);
   return 0;
}

int anv_gem_set_caching(struct anv_device* device, uint32_t gem_handle, uint32_t caching)
{
   LOG_VERBOSE("anv_get_set_caching - STUB");
   return 0;
}

int anv_gem_set_domain(struct anv_device* device, uint32_t gem_handle, uint32_t read_domains,
                       uint32_t write_domain)
{
   LOG_VERBOSE("anv_gem_set_domain - STUB");
   return 0;
}

/**
 * On error, \a timeout_ns holds the remaining time.
 */
int anv_gem_wait(struct anv_device* device, uint32_t gem_handle, int64_t* timeout_ns)
{
   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return -1;
   }

   LOG_VERBOSE("anv_gem_wait gem_handle %u buffer_id %lu timeout_ns %lu", gem_handle,
               entry->buffer->id, *timeout_ns);

   magma_status_t status =
       AnvMagmaConnectionWait(device->connection, entry->buffer->id, *timeout_ns);
   switch (status) {
   case MAGMA_STATUS_OK:
      break;
   case MAGMA_STATUS_TIMED_OUT:
      errno = ETIME;
      return -1;
   default:
      return -1;
   }
   return 0;
}

/**
 * Returns 0, 1, or negative to indicate error
 */
int anv_gem_busy(struct anv_device* device, uint32_t gem_handle)
{
   LOG_VERBOSE("anv_gem_busy gem_handle %u", gem_handle);

   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return -1;
   }

   magma_status_t status =
       AnvMagmaConnectionWait(device->connection, entry->buffer->id, 0 /*timeout_ns*/);
   switch (status) {
   case MAGMA_STATUS_TIMED_OUT:
      return 1;
   case MAGMA_STATUS_OK:
      return 0;
   default:
      return -1;
   }
}

int anv_gem_get_context_param(anv_device_handle_t handle, int context, uint32_t param,
                              uint64_t* value)
{
   magma_status_t status;
   switch (param) {
   case I915_CONTEXT_PARAM_GTT_SIZE:
      status = magma_query2((magma_device_t)handle, kMagmaIntelGenQueryGttSize, value);
      if (status != MAGMA_STATUS_OK) {
         mesa_logd("magma_query failed: %d", status);
         return -1;
      }
      return 0;
   default:
      LOG_VERBOSE("anv_gem_get_context_param: unhandled param 0x%x", param);
      return -1;
   }
}

int anv_gem_execbuffer(struct anv_device* device, struct drm_i915_gem_execbuffer2* execbuf)
{
   LOG_VERBOSE("anv_gem_execbuffer");
   struct drm_i915_gem_exec_object2* exec_objects = (void*)execbuf->buffers_ptr;

   struct anv_magma_buffer* buffers[execbuf->buffer_count];

   // Translate gem_handles to struct anv_magma_buffer*
   for (uint32_t i = 0; i < execbuf->buffer_count; i++) {
      uint32_t gem_handle = exec_objects[i].handle;

      struct BufferMapEntry* entry;
      BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
      if (!entry) {
         mesa_logd("Unknown gem handle: %u", gem_handle);
         return -1;
      }

      buffers[i] = entry->buffer;
   }

   return AnvMagmaConnectionExec(device->connection, device->context_id, execbuf, buffers);
}

int anv_gem_set_tiling(struct anv_device* device, uint32_t gem_handle, uint32_t stride,
                       uint32_t tiling)
{
   LOG_VERBOSE("anv_gem_set_tiling - STUB");
   return 0;
}

#if VK_USE_PLATFORM_FUCHSIA
typedef VkResult(VKAPI_PTR* PFN_vkOpenInNamespaceAddr)(const char* pName, uint32_t handle);

PUBLIC VKAPI_ATTR void VKAPI_CALL
vk_icdInitializeOpenInNamespaceCallback(PFN_vkOpenInNamespaceAddr open_in_namespace_addr);

void vk_icdInitializeOpenInNamespaceCallback(PFN_vkOpenInNamespaceAddr open_in_namespace_addr)
{
   fuchsia_init(open_in_namespace_addr);
}

#endif // VK_USE_PLATFORM_FUCHSIA

VkResult anv_magma_open_device_handle(const char* path, anv_device_handle_t* device_out)
{
   magma_device_t device;
#if defined(__Fuchsia__)
   zx_handle_t client_handle;
   if (!fuchsia_open(path, &client_handle)) {
      return VK_ERROR_INCOMPATIBLE_DRIVER;
   }
   if (magma_device_import(client_handle, &device) != MAGMA_STATUS_OK) {
      return VK_ERROR_INCOMPATIBLE_DRIVER;
   }
#else
   int fd;
   fd = open(path, O_RDWR | O_CLOEXEC);
   if (fd < 0)
      return VK_ERROR_INCOMPATIBLE_DRIVER;
   if (magma_device_import(fd, &device) != MAGMA_STATUS_OK) {
      return VK_ERROR_INCOMPATIBLE_DRIVER;
   }
#endif
   *device_out = (anv_device_handle_t)device;
   return VK_SUCCESS;
}

void anv_magma_release_device_handle(anv_device_handle_t device)
{
   magma_device_release((magma_device_t)device);
}

int anv_gem_get_param(anv_device_handle_t fd, uint32_t param)
{
   int value;
   if (!intel_getparam((uintptr_t)fd, param, &value))
      return 0;
   return value;
}

bool anv_gem_get_bit6_swizzle(anv_device_handle_t fd, uint32_t tiling)
{
   LOG_VERBOSE("anv_gem_get_bit6_swizzle - STUB");
   return 0;
}

int anv_gem_create_context(struct anv_device* device)
{
   uint32_t context_id;
   magma_create_context(magma_connection(device), &context_id);
   LOG_VERBOSE("magma_create_context returned context_id %u", context_id);
   return context_id;
}

int anv_gem_destroy_context(struct anv_device* device, int context_id)
{
   magma_release_context(magma_connection(device), context_id);
   return 0;
}

int anv_gem_handle_to_fd(struct anv_device* device, uint32_t gem_handle)
{
   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return -1;
   }

   uint32_t handle = 0;
   magma_status_t result = magma_export(magma_connection(device), entry->buffer->buffer, &handle);

   assert(result == MAGMA_STATUS_OK);

   return (int)handle;
}

uint32_t anv_gem_fd_to_handle(struct anv_device* device, int fd)
{
   uint32_t handle = (uint32_t)fd;
   magma_buffer_t buffer;
   magma_status_t result = magma_import(magma_connection(device), handle, &buffer);
   assert(result == MAGMA_STATUS_OK);

   struct BufferMapEntry* entry;
   BufferMap_Get(device->connection->buffer_map, &entry);

   entry->buffer = AnvMagmaCreateBuffer(device->connection, buffer);

   return entry->gem_handle;
}

int anv_gem_context_get_reset_stats(anv_device_handle_t fd, int context, uint32_t* active, uint32_t* pending)
{
   LOG_VERBOSE("anv_gem_context_get_reset_stats - STUB");
   *active = 0;
   *pending = 0;
   return 0;
}

int anv_gem_import_fuchsia_buffer(struct anv_device* device, uint32_t handle,
                                  uint32_t* gem_handle_out, uint64_t* size_out)
{
   magma_buffer_t buffer;
   magma_status_t status = magma_import(magma_connection(device), handle, &buffer);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_import failed: %d", status);
      return -EINVAL;
   }

   struct BufferMapEntry* entry;
   BufferMap_Get(device->connection->buffer_map, &entry);

   entry->buffer = AnvMagmaCreateBuffer(device->connection, buffer);

   *size_out = magma_get_buffer_size(buffer);
   *gem_handle_out = entry->gem_handle;

   return 0;
}

#if VK_USE_PLATFORM_FUCHSIA
VkResult
anv_GetMemoryZirconHandleFUCHSIA(VkDevice vk_device,
                                 const VkMemoryGetZirconHandleInfoFUCHSIA* pGetZirconHandleInfo,
                                 uint32_t* pHandle)
{
   ANV_FROM_HANDLE(anv_device, device, vk_device);
   ANV_FROM_HANDLE(anv_device_memory, memory, pGetZirconHandleInfo->memory);

   assert(pGetZirconHandleInfo->sType ==
          VK_STRUCTURE_TYPE_MEMORY_GET_ZIRCON_HANDLE_INFO_FUCHSIA);
   assert(pGetZirconHandleInfo->handleType ==
          VK_EXTERNAL_MEMORY_HANDLE_TYPE_ZIRCON_VMO_BIT_FUCHSIA);

   uint32_t gem_handle = memory->bo->gem_handle;

   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   assert(entry);

   magma_status_t result = magma_export(magma_connection(device), entry->buffer->buffer, pHandle);
   assert(result == MAGMA_STATUS_OK);

   return VK_SUCCESS;
}

VkResult anv_GetMemoryZirconHandlePropertiesFUCHSIA(
    VkDevice vk_device, VkExternalMemoryHandleTypeFlagBitsKHR handleType, uint32_t handle,
    VkMemoryZirconHandlePropertiesFUCHSIA* pMemoryZirconHandleProperties)
{
   ANV_FROM_HANDLE(anv_device, device, vk_device);

   assert(handleType == VK_EXTERNAL_MEMORY_HANDLE_TYPE_ZIRCON_VMO_BIT_FUCHSIA);
   assert(pMemoryZirconHandleProperties->sType ==
          VK_STRUCTURE_TYPE_MEMORY_ZIRCON_HANDLE_PROPERTIES_FUCHSIA);

   zx_handle_t zx_handle = handle;

   struct zx_info_handle_basic handle_info;
   zx_status_t status = zx_object_get_info(zx_handle, ZX_INFO_HANDLE_BASIC, &handle_info,
                                           sizeof(handle_info), NULL, NULL);

   if (status != ZX_OK) {
      mesa_logd("zx_object_get_info failed: %d", status);
      return VK_ERROR_INVALID_EXTERNAL_HANDLE;
   }

   const uint32_t kNeededFlags = ZX_RIGHT_MAP | ZX_RIGHT_READ | ZX_RIGHT_WRITE;
   bool is_mappable = (handle_info.rights & kNeededFlags) == kNeededFlags ? true : false;

   if (!is_mappable) {
      pMemoryZirconHandleProperties->memoryTypeBits = 0;
   } else {
      // All memory types supported
      struct anv_physical_device* pdevice = device->physical;
      pMemoryZirconHandleProperties->memoryTypeBits = (1ull << pdevice->memory.type_count) - 1;
   }

   return VK_SUCCESS;
}

/* Similar to anv_ImportSemaphoreFdKHR */
VkResult
anv_ImportSemaphoreZirconHandleFUCHSIA(VkDevice vk_device,
                                       const VkImportSemaphoreZirconHandleInfoFUCHSIA* info)
{
   assert(info->sType == VK_STRUCTURE_TYPE_IMPORT_SEMAPHORE_ZIRCON_HANDLE_INFO_FUCHSIA);
   assert(info->handleType == VK_EXTERNAL_SEMAPHORE_HANDLE_TYPE_ZIRCON_EVENT_BIT_FUCHSIA);

   ANV_FROM_HANDLE(anv_device, device, vk_device);
   ANV_FROM_HANDLE(anv_semaphore, semaphore, info->semaphore);

   struct anv_magma_semaphore* magma_semaphore = malloc(sizeof(struct anv_magma_semaphore));

   magma_status_t status =
       magma_import_semaphore(magma_connection(device), info->zirconHandle,
                              &magma_semaphore->semaphore);
   if (status != MAGMA_STATUS_OK) {
      free(magma_semaphore);
      return vk_error(VK_ERROR_INVALID_EXTERNAL_HANDLE_KHR);
   }

   magma_semaphore->id = magma_get_semaphore_id(magma_semaphore->semaphore);

   struct anv_semaphore_impl new_impl = {.type = ANV_SEMAPHORE_TYPE_DRM_SYNCOBJ};
   new_impl.syncobj = (anv_syncobj_handle_t) magma_semaphore;

   if (info->flags & VK_SEMAPHORE_IMPORT_TEMPORARY_BIT_KHR) {
      anv_semaphore_impl_cleanup(device, &semaphore->temporary);
      semaphore->temporary = new_impl;
   } else {
      anv_semaphore_impl_cleanup(device, &semaphore->permanent);
      semaphore->permanent = new_impl;
   }

   return VK_SUCCESS;
}

/* Similar to anv_GetSemaphoreFdKHR */
VkResult anv_GetSemaphoreZirconHandleFUCHSIA(VkDevice vk_device,
                                             const VkSemaphoreGetZirconHandleInfoFUCHSIA* info,
                                             uint32_t* pZirconHandle)
{
   ANV_FROM_HANDLE(anv_device, device, vk_device);
   ANV_FROM_HANDLE(anv_semaphore, semaphore, info->semaphore);

   assert(info->sType == VK_STRUCTURE_TYPE_SEMAPHORE_GET_ZIRCON_HANDLE_INFO_FUCHSIA);

   if (info->handleType != VK_EXTERNAL_SEMAPHORE_HANDLE_TYPE_ZIRCON_EVENT_BIT_FUCHSIA)
      return VK_SUCCESS;

   struct anv_semaphore_impl* impl = semaphore->temporary.type != ANV_SEMAPHORE_TYPE_NONE
                                         ? &semaphore->temporary
                                         : &semaphore->permanent;

   struct anv_magma_semaphore* magma_semaphore = (struct anv_magma_semaphore*)impl->syncobj;

   uint32_t handle;
   magma_status_t status =
       magma_export_semaphore(magma_connection(device), magma_semaphore->semaphore, &handle);
   if (status != MAGMA_STATUS_OK)
      return vk_error(VK_ERROR_TOO_MANY_OBJECTS);

   /* From the Vulkan 1.0.53 spec:
    *
    *    "Export operations have the same transference as the specified handle
    *    type’s import operations. [...] If the semaphore was using a
    *    temporarily imported payload, the semaphore’s prior permanent payload
    *    will be restored.
    */
   anv_semaphore_reset_temporary(device, semaphore);

   *pZirconHandle = handle;
   return VK_SUCCESS;
}

#endif // VK_USE_PLATFORM_FUCHSIA

bool anv_gem_supports_syncobj_wait(anv_device_handle_t fd) { return true; }

anv_syncobj_handle_t anv_gem_syncobj_create(struct anv_device* device, uint32_t flags)
{
   magma_semaphore_t semaphore;
   magma_status_t status = magma_create_semaphore(magma_connection(device), &semaphore);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_create_semaphore failed: %d", status);
      return 0;
   }
   if (flags & DRM_SYNCOBJ_CREATE_SIGNALED)
      magma_signal_semaphore(semaphore);

   struct anv_magma_semaphore* magma_semaphore = malloc(sizeof(struct anv_magma_semaphore));
   magma_semaphore->semaphore = semaphore;
   magma_semaphore->id = magma_get_semaphore_id(semaphore);

   return (anv_syncobj_handle_t) magma_semaphore;
}

void anv_gem_syncobj_destroy(struct anv_device* device, anv_syncobj_handle_t sync_obj)
{
   struct anv_magma_semaphore* magma_semaphore = (struct anv_magma_semaphore*)sync_obj;
   magma_release_semaphore(magma_connection(device), magma_semaphore->semaphore);
   free(magma_semaphore);
}

void anv_gem_syncobj_reset(struct anv_device* device, anv_syncobj_handle_t sync_obj)
{
   struct anv_magma_semaphore* magma_semaphore = (struct anv_magma_semaphore*)sync_obj;
   magma_reset_semaphore(magma_semaphore->semaphore);
}

static void notification_callback(void* context)
{
   AnvMagmaConnectionServiceNotifications(((struct anv_device*)context)->connection);
}

int anv_gem_syncobj_wait(struct anv_device* device, anv_syncobj_handle_t* sync_objs, uint32_t count,
                         int64_t abs_timeout_ns, bool wait_all)
{
   magma_semaphore_t semaphores[count];

   for (uint32_t i = 0; i < count; i++) {
      struct anv_magma_semaphore* magma_semaphore = (struct anv_magma_semaphore*)sync_objs[i];
      semaphores[i] = magma_semaphore->semaphore;
   }

   return magma_wait(device->connection->notification_channel, semaphores, count, abs_timeout_ns,
                     wait_all, notification_callback, device);
}

int anv_gem_reg_read(anv_device_handle_t device, uint32_t offset, uint64_t* result)
{
#define TIMESTAMP 0x2358
   if (offset == (TIMESTAMP | I915_REG_READ_8B_WA)) {
      // Return 0 to enable support for calibrated timestamps, but the implmementation
      // should use anv_gem_query_timestamp.
      *result = 0;
      return 0;
   }
   // TODO(fxbug.dev/13248)
   assert(false);
   return 0;
}

anv_syncobj_handle_t anv_gem_syncobj_fd_to_handle(struct anv_device* device, int fd)
{
#if defined(DISABLE_EXTERNAL_SYNC_FD)
   assert(false);
   return 0;
#else
   magma_semaphore_t semaphore;
   magma_status_t status = magma_import_semaphore(magma_connection(device), fd, &semaphore);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_import_semaphore failed: %d", status);
      return 0;
   }

   struct anv_magma_semaphore* magma_semaphore = malloc(sizeof(struct anv_magma_semaphore));
   magma_semaphore->semaphore = semaphore;
   magma_semaphore->id = magma_get_semaphore_id(semaphore);

   return (anv_syncobj_handle_t) magma_semaphore;
#endif
}

int anv_gem_syncobj_handle_to_fd(struct anv_device* device, anv_syncobj_handle_t syncobj)
{
#if defined(DISABLE_EXTERNAL_SYNC_FD)
   assert(false);
   return 0;
#else
   struct anv_magma_semaphore* magma_semaphore = (struct anv_magma_semaphore*)syncobj;

   uint32_t handle;
   magma_status_t status =
       magma_export_semaphore(magma_connection(device), magma_semaphore->semaphore, &handle);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_export_semaphore failed: %d", status);
      return 0;
   }

   // Normally negative means error but while we're using zircon handles for fds we allow them
   // (corresponding changes made in anv_queue.c; also see fxbug.dev/67565)
   return (int)handle;
#endif
}

int anv_gem_syncobj_export_sync_file(struct anv_device* device, anv_syncobj_handle_t handle)
{
   assert(false);
   return -1;
}

int anv_gem_syncobj_import_sync_file(struct anv_device* device, anv_syncobj_handle_t handle, int fd)
{
   assert(false);
   return -1;
}

int anv_gem_sync_file_merge(struct anv_device* device, int fd1, int fd2)
{
   assert(false);
   return -1;
}

int anv_gem_set_context_param(anv_device_handle_t handle, int context, uint32_t param,
                              uint64_t value)
{
   assert(false);
   return -1;
}

bool anv_gem_has_context_priority(anv_device_handle_t fd) { return false; }

uint32_t anv_gem_create_image(struct anv_device *device, uint64_t drm_format,
   const uint64_t* drm_format_modifiers, uint32_t width, uint32_t height, uint64_t flags)
{
   magma_image_create_info_t info = {
      .drm_format = drm_format,
      .width = width,
      .height = height,
      .flags = (flags & ANV_CREATE_IMAGE_PRESENTABLE) ? MAGMA_IMAGE_CREATE_FLAGS_PRESENTABLE : 0,
   };

   const uint64_t* modifier_ptr = drm_format_modifiers;
   uint32_t index = 0;
   while (index < MAGMA_MAX_DRM_FORMAT_MODIFIERS - 1) {
      if (*modifier_ptr == DRM_FORMAT_MOD_INVALID)
         break;
      info.drm_format_modifiers[index++] = *modifier_ptr++;
   }
   info.drm_format_modifiers[index] = DRM_FORMAT_MOD_INVALID;

   magma_buffer_t image;
   magma_status_t status = magma_virt_create_image(magma_connection(device), &info, &image);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_virt_create_image failed (%d)", status);
      return 0;
   }

   struct BufferMapEntry* entry;
   BufferMap_Get(device->connection->buffer_map, &entry);

   entry->buffer = AnvMagmaCreateBuffer(device->connection, image);

   LOG_VERBOSE("magma_virt_create_image returning image buffer %lu gem_handle %u",
               entry->buffer->id, entry->gem_handle);

   return entry->gem_handle;
}

int anv_gem_get_image_info(struct anv_device *device, uint32_t gem_handle,
   uint64_t* drm_format_modifier_out, uint32_t* bytes_per_row_out, bool* is_cache_coherent_out)
{
   struct BufferMapEntry* entry;
   BufferMap_Query(device->connection->buffer_map, gem_handle, &entry);
   if (!entry) {
      mesa_logd("Unknown gem handle: %u", gem_handle);
      return -EINVAL;
   }

   magma_buffer_t image = entry->buffer->buffer;
   magma_image_info_t info;

   magma_status_t status = magma_virt_get_image_info(magma_connection(device), image, &info);

   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_virt_get_image_info failed: %d", status);
      return -EINVAL;
   }

   assert(info.plane_offsets[0] == 0);
   *bytes_per_row_out = info.plane_strides[0];
   *drm_format_modifier_out = info.drm_format_modifier;
   *is_cache_coherent_out = (info.coherency_domain == MAGMA_COHERENCY_DOMAIN_CPU);

   return 0;
}

int anv_gem_query_timestamp(anv_device_handle_t device, struct anv_timestamp_query* query_out)
{
   magma_handle_t handle;
   magma_status_t status = magma_query_returns_buffer2((magma_device_t)device,
      kMagmaIntelGenQueryTimestamp, &handle);
   if (status != MAGMA_STATUS_OK) {
      mesa_logd("magma_query_returns_buffer2 failed: %d", status);
      return -1;
   }

   struct magma_intel_gen_timestamp_query* magma_timestamp_query = mmap_and_close_handle(
      handle, 0 /*offset*/, sizeof(struct magma_intel_gen_timestamp_query));

   if (!magma_timestamp_query) {
      mesa_logd("failed to map timestamp query");
      return -1;
   }

   query_out->monotonic_raw_timestamp[0] = magma_timestamp_query->monotonic_raw_timestamp[0];
   query_out->monotonic_raw_timestamp[1] = magma_timestamp_query->monotonic_raw_timestamp[1];
   query_out->monotonic_timestamp = magma_timestamp_query->monotonic_timestamp;
   query_out->device_timestamp = magma_timestamp_query->device_timestamp;

   return 0;
}

uint64_t
anv_gem_get_drm_cap(anv_device_handle_t fd, uint32_t capability)
{
   switch (capability) {
      case DRM_CAP_SYNCOBJ_TIMELINE:
         return 0;
   }
   assert(false);
   return 0;
}

int anv_gem_syncobj_timeline_wait(struct anv_device *device,
                                  const anv_syncobj_handle_t *handles, const uint64_t *points,
                                  uint32_t num_items, int64_t abs_timeout_ns,
                                  bool wait_all, bool wait_materialize)
{
   LOG_VERBOSE("anv_gem_syncobj_timeline_wait - STUB");
   assert(false);
   return 0;
}

int anv_gem_syncobj_timeline_signal(struct anv_device *device,
                                    const anv_syncobj_handle_t *handles, const uint64_t *points,
                                    uint32_t num_items)
{
   LOG_VERBOSE("anv_gem_syncobj_timeline_signal - STUB");
   assert(false);
   return 0;
}

int anv_gem_syncobj_timeline_query(struct anv_device *device,
                                   const anv_syncobj_handle_t *handles, uint64_t *points,
                                   uint32_t num_items)
{
   LOG_VERBOSE("anv_gem_syncobj_timeline_query - STUB");
   assert(false);
   return 0;
}

struct drm_i915_query_engine_info *anv_gem_get_engine_info(int fd)
{
   LOG_VERBOSE("anv_gem_get_engine_info - STUB");
   return NULL;
}

int anv_gem_count_engines(const struct drm_i915_query_engine_info *info, uint16_t engine_class)
{
   LOG_VERBOSE("anv_gem_count_engines - STUB");
   assert(false);
   return 0;
}

int anv_gem_create_context_engines(struct anv_device *device,
                                   const struct drm_i915_query_engine_info *info,
                                   int num_engines,
                                   uint16_t *engine_classes)
{
   LOG_VERBOSE("anv_gem_create_context_engines - STUB");
   assert(false);
   return 0;
}