| // Copyright 2019 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| // |
| // |
| // |
| |
| #include "queue_pool.h" |
| |
| #include "common/macros.h" |
| #include "common/vk/assert.h" |
| |
| // |
| // |
| // |
| void |
| spinel_queue_pool_create(struct spinel_queue_pool * queue_pool, |
| VkDevice d, |
| spinel_vk_context_create_info_vk_queue_t const * create_info) |
| { |
| uint32_t const qc_clamp = MIN_MACRO(uint32_t, SPN_QUEUE_POOL_MAX_QUEUES, create_info->count); |
| |
| *queue_pool = (struct spinel_queue_pool){ |
| .create_info = *create_info, |
| .queue_next = 0, |
| }; |
| |
| VkDeviceQueueInfo2 dqi2 = { |
| .sType = VK_STRUCTURE_TYPE_DEVICE_QUEUE_INFO_2, |
| .pNext = NULL, |
| .flags = create_info->flags, |
| .queueFamilyIndex = create_info->family_index, |
| /* .queueIndex = [0, qc_clamp) */ |
| }; |
| |
| for (uint32_t ii = 0; ii < qc_clamp; ii++) |
| { |
| dqi2.queueIndex = ii; |
| |
| vkGetDeviceQueue2(d, &dqi2, queue_pool->queues + ii); |
| } |
| } |
| |
| // |
| // |
| // |
| void |
| spinel_queue_pool_dispose(struct spinel_queue_pool * queue_pool) |
| { |
| ; // Nothing to do |
| } |
| |
| // |
| // |
| // |
| VkQueue |
| spinel_queue_pool_get_next(struct spinel_queue_pool * queue_pool) |
| { |
| assert(queue_pool->create_info.count > 0); |
| |
| return queue_pool->queues[queue_pool->queue_next++ % queue_pool->create_info.count]; |
| } |
| |
| // |
| // |
| // |
