| // 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, |
| }; |