blob: 8aca8a24e2f234daee009b556d921fb92b224a3a [file] [log] [blame]
// Copyright 2023 The IREE Authors
//
// Licensed under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
#include "experimental/metal/metal_device.h"
#include "experimental/metal/api.h"
#include "experimental/metal/direct_allocator.h"
#include "experimental/metal/metal_shared_event.h"
#include "experimental/metal/nop_executable_cache.h"
#include "experimental/metal/pipeline_layout.h"
#include "iree/base/api.h"
#include "iree/base/tracing.h"
#include "iree/hal/api.h"
#include "iree/hal/utils/buffer_transfer.h"
typedef struct iree_hal_metal_device_t {
// Abstract resource used for injecting reference counting and vtable; must be at offset 0.
iree_hal_resource_t resource;
iree_string_view_t identifier;
// Original driver that owns this device.
iree_hal_driver_t* driver;
iree_allocator_t host_allocator;
iree_hal_allocator_t* device_allocator;
id<MTLDevice> device;
// A dispatch queue and associated event listener for running Objective-C blocks to singal
// semaphores and wake up threads.
dispatch_queue_t semaphore_notification_queue;
MTLSharedEventListener* event_listener;
} iree_hal_metal_device_t;
static const iree_hal_device_vtable_t iree_hal_metal_device_vtable;
static iree_hal_metal_device_t* iree_hal_metal_device_cast(iree_hal_device_t* base_value) {
IREE_HAL_ASSERT_TYPE(base_value, &iree_hal_metal_device_vtable);
return (iree_hal_metal_device_t*)base_value;
}
static const iree_hal_metal_device_t* iree_hal_metal_device_const_cast(
const iree_hal_device_t* base_value) {
IREE_HAL_ASSERT_TYPE(base_value, &iree_hal_metal_device_vtable);
return (const iree_hal_metal_device_t*)base_value;
}
void iree_hal_metal_device_params_initialize(iree_hal_metal_device_params_t* out_params) {
memset(out_params, 0, sizeof(*out_params));
out_params->arena_block_size = 32 * 1024;
out_params->command_dispatch_type = IREE_HAL_METAL_COMMAND_DISPATCH_TYPE_CONCURRENT;
}
const iree_hal_metal_device_params_t* iree_hal_metal_device_params(
const iree_hal_device_t* base_device) {
const iree_hal_metal_device_t* device = iree_hal_metal_device_const_cast(base_device);
return &device->params;
}
static iree_status_t iree_hal_metal_device_create_internal(
iree_string_view_t identifier, const iree_hal_metal_device_params_t* params,
id<MTLDevice> metal_device, iree_allocator_t host_allocator, iree_hal_device_t** out_device) {
iree_hal_metal_device_t* device = NULL;
iree_host_size_t total_size = iree_sizeof_struct(*device) + identifier.size;
IREE_RETURN_IF_ERROR(iree_allocator_malloc(host_allocator, total_size, (void**)&device));
iree_status_t status = iree_hal_metal_allocator_create((iree_hal_device_t*)device, metal_device,
host_allocator, &device->device_allocator);
if (iree_status_is_ok(status)) {
iree_hal_resource_initialize(&iree_hal_metal_device_vtable, &device->resource);
iree_string_view_append_to_buffer(identifier, &device->identifier,
(char*)device + iree_sizeof_struct(*device));
device->driver = driver;
iree_hal_driver_retain(device->driver);
device->host_allocator = host_allocator;
device->device = [metal_device retain]; // +1
device->semaphore_notification_queue = dispatch_queue_create("dev.iree.queue.metal", NULL);
device->event_listener = [[MTLSharedEventListener alloc]
initWithDispatchQueue:device->semaphore_notification_queue]; // +1
*out_device = (iree_hal_device_t*)device;
} else {
iree_hal_device_release((iree_hal_device_t*)device);
}
return status;
}
iree_status_t iree_hal_metal_device_create(iree_string_view_t identifier,
const iree_hal_metal_device_params_t* params,
id<MTLDevice> device, iree_allocator_t host_allocator,
iree_hal_device_t** out_device) {
IREE_ASSERT_ARGUMENT(out_device);
IREE_TRACE_ZONE_BEGIN(z0);
iree_status_t status =
iree_hal_metal_device_create_internal(identifier, params, device, host_allocator, out_device);
IREE_TRACE_ZONE_END(z0);
return status;
}
static void iree_hal_metal_device_destroy(iree_hal_device_t* base_device) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
iree_allocator_t host_allocator = iree_hal_device_host_allocator(base_device);
IREE_TRACE_ZONE_BEGIN(z0);
[device->event_listener release]; // -1
dispatch_release(device->semaphore_notification_queue);
iree_hal_allocator_release(device->device_allocator);
[device->device release]; // -1
iree_hal_driver_release(device->driver);
iree_allocator_free(host_allocator, device);
IREE_TRACE_ZONE_END(z0);
}
static iree_string_view_t iree_hal_metal_device_id(iree_hal_device_t* base_device) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return device->identifier;
}
static iree_allocator_t iree_hal_metal_device_host_allocator(iree_hal_device_t* base_device) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return device->host_allocator;
}
static iree_hal_allocator_t* iree_hal_metal_device_allocator(iree_hal_device_t* base_device) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return device->device_allocator;
}
static void iree_hal_metal_replace_device_allocator(iree_hal_device_t* base_device,
iree_hal_allocator_t* new_allocator) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
iree_hal_allocator_retain(new_allocator);
iree_hal_allocator_release(device->device_allocator);
device->device_allocator = new_allocator;
}
static iree_status_t iree_hal_metal_device_trim(iree_hal_device_t* base_device) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return iree_hal_allocator_trim(device->device_allocator);
}
static iree_status_t iree_hal_metal_device_query_i64(iree_hal_device_t* base_device,
iree_string_view_t category,
iree_string_view_t key, int64_t* out_value) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented device i64 query");
}
static iree_status_t iree_hal_metal_device_create_channel(iree_hal_device_t* base_device,
iree_hal_queue_affinity_t queue_affinity,
iree_hal_channel_params_t params,
iree_hal_channel_t** out_channel) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "collectives not yet supported");
}
static iree_status_t iree_hal_metal_device_create_command_buffer(
iree_hal_device_t* base_device, iree_hal_command_buffer_mode_t mode,
iree_hal_command_category_t command_categories, iree_hal_queue_affinity_t queue_affinity,
iree_host_size_t binding_capacity, iree_hal_command_buffer_t** out_command_buffer) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented command buffer create");
}
static iree_status_t iree_hal_metal_device_create_descriptor_set_layout(
iree_hal_device_t* base_device, iree_hal_descriptor_set_layout_flags_t flags,
iree_host_size_t binding_count, const iree_hal_descriptor_set_layout_binding_t* bindings,
iree_hal_descriptor_set_layout_t** out_descriptor_set_layout) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return iree_hal_metal_descriptor_set_layout_create(device->host_allocator, flags, binding_count,
bindings, out_descriptor_set_layout);
}
static iree_status_t iree_hal_metal_device_create_event(iree_hal_device_t* base_device,
iree_hal_event_t** out_event) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented event create");
}
static iree_status_t iree_hal_metal_device_create_executable_cache(
iree_hal_device_t* base_device, iree_string_view_t identifier, iree_loop_t loop,
iree_hal_executable_cache_t** out_executable_cache) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return iree_hal_metal_nop_executable_cache_create(device->device, device->host_allocator,
identifier, out_executable_cache);
}
static iree_status_t iree_hal_metal_device_create_pipeline_layout(
iree_hal_device_t* base_device, iree_host_size_t push_constants,
iree_host_size_t set_layout_count, iree_hal_descriptor_set_layout_t* const* set_layouts,
iree_hal_pipeline_layout_t** out_pipeline_layout) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return iree_hal_metal_pipeline_layout_create(device->host_allocator, set_layout_count,
set_layouts, push_constants, out_pipeline_layout);
}
static iree_status_t iree_hal_metal_device_create_semaphore(iree_hal_device_t* base_device,
uint64_t initial_value,
iree_hal_semaphore_t** out_semaphore) {
iree_hal_metal_device_t* device = iree_hal_metal_device_cast(base_device);
return iree_hal_metal_shared_event_create(device->device, initial_value, device->event_listener,
device->host_allocator, out_semaphore);
}
static iree_hal_semaphore_compatibility_t iree_hal_metal_device_query_semaphore_compatibility(
iree_hal_device_t* base_device, iree_hal_semaphore_t* semaphore) {
if (iree_hal_metal_shared_event_isa(semaphore)) {
// Fast-path for semaphores related to this device.
// TODO(benvanik): ensure the creating devices are compatible in cases where
// multiple devices are used.
return IREE_HAL_SEMAPHORE_COMPATIBILITY_ALL;
}
// TODO(benvanik): semaphore APIs for querying allowed export formats. We
// can check device caps to see what external semaphore types are supported.
return IREE_HAL_SEMAPHORE_COMPATIBILITY_HOST_ONLY;
}
static iree_status_t iree_hal_metal_device_queue_alloca(
iree_hal_device_t* base_device, iree_hal_queue_affinity_t queue_affinity,
const iree_hal_semaphore_list_t wait_semaphore_list,
const iree_hal_semaphore_list_t signal_semaphore_list, iree_hal_allocator_pool_t pool,
iree_hal_buffer_params_t params, iree_device_size_t allocation_size,
iree_hal_buffer_t** IREE_RESTRICT out_buffer) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented queue alloca");
}
static iree_status_t iree_hal_metal_device_queue_dealloca(
iree_hal_device_t* base_device, iree_hal_queue_affinity_t queue_affinity,
const iree_hal_semaphore_list_t wait_semaphore_list,
const iree_hal_semaphore_list_t signal_semaphore_list, iree_hal_buffer_t* buffer) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented queue dealloca");
}
static iree_status_t iree_hal_metal_device_queue_execute(
iree_hal_device_t* base_device, iree_hal_queue_affinity_t queue_affinity,
const iree_hal_semaphore_list_t wait_semaphore_list,
const iree_hal_semaphore_list_t signal_semaphore_list, iree_host_size_t command_buffer_count,
iree_hal_command_buffer_t* const* command_buffers) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented queue execute");
}
static iree_status_t iree_hal_metal_device_queue_flush(iree_hal_device_t* base_device,
iree_hal_queue_affinity_t queue_affinity) {
return iree_make_status(IREE_STATUS_UNIMPLEMENTED, "unimplmented queue flush");
}
static iree_status_t iree_hal_metal_device_wait_semaphores(
iree_hal_device_t* base_device, iree_hal_wait_mode_t wait_mode,
const iree_hal_semaphore_list_t semaphore_list, iree_timeout_t timeout) {
return iree_hal_metal_shared_event_multi_wait(wait_mode, &semaphore_list, timeout);
}
static iree_status_t iree_hal_metal_device_profiling_begin(
iree_hal_device_t* device, const iree_hal_device_profiling_options_t* options) {
// Unimplemented (and that's ok).
return iree_ok_status();
}
static iree_status_t iree_hal_metal_device_profiling_end(iree_hal_device_t* device) {
// Unimplemented (and that's ok).
return iree_ok_status();
}
static const iree_hal_device_vtable_t iree_hal_metal_device_vtable = {
.destroy = iree_hal_metal_device_destroy,
.id = iree_hal_metal_device_id,
.host_allocator = iree_hal_metal_device_host_allocator,
.device_allocator = iree_hal_metal_device_allocator,
.replace_device_allocator = iree_hal_metal_replace_device_allocator,
.trim = iree_hal_metal_device_trim,
.query_i64 = iree_hal_metal_device_query_i64,
.create_channel = iree_hal_metal_device_create_channel,
.create_command_buffer = iree_hal_metal_device_create_command_buffer,
.create_descriptor_set_layout = iree_hal_metal_device_create_descriptor_set_layout,
.create_event = iree_hal_metal_device_create_event,
.create_executable_cache = iree_hal_metal_device_create_executable_cache,
.create_pipeline_layout = iree_hal_metal_device_create_pipeline_layout,
.create_semaphore = iree_hal_metal_device_create_semaphore,
.query_semaphore_compatibility = iree_hal_metal_device_query_semaphore_compatibility,
.transfer_range = iree_hal_device_submit_transfer_range_and_wait,
.queue_alloca = iree_hal_metal_device_queue_alloca,
.queue_dealloca = iree_hal_metal_device_queue_dealloca,
.queue_execute = iree_hal_metal_device_queue_execute,
.queue_flush = iree_hal_metal_device_queue_flush,
.wait_semaphores = iree_hal_metal_device_wait_semaphores,
.profiling_begin = iree_hal_metal_device_profiling_begin,
.profiling_end = iree_hal_metal_device_profiling_end,
};