Method create_queue_internal

compute/vulkan/vulkan_compute.cpp:2545–2573

}

shared_ptr<compute_queue> vulkan_compute::create_queue_internal(const compute_device& dev, const uint32_t family_index,
																const compute_queue::QUEUE_TYPE queue_type,
																uint32_t& queue_index) const {
	const auto& vulkan_dev = (const vulkan_device&)dev;
	
	// can only create a certain amount of queues per device with Vulkan, so handle this + handle the queue index
	if (queue_index >= vulkan_dev.queue_counts[family_index]) {
		log_warn("too many queues were created for family $ (max: $), wrapping around to #0 again",
				 family_index, vulkan_dev.queue_counts[family_index]);
		queue_index = 0;
	}
	const auto next_queue_index = queue_index++;
	
	VkQueue queue_obj;
	vkGetDeviceQueue(vulkan_dev.device, family_index, next_queue_index, &queue_obj);
	if (queue_obj == nullptr) {
		log_error("failed to retrieve Vulkan device queue");
		return {};
	}
	
	const string queue_name = (family_index == vulkan_dev.all_queue_family_index ?
							   "queue:" + (next_queue_index == 0 ? "default" : to_string(next_queue_index)) :
							   "compute_queue:" + (next_queue_index == 0 ? "default" : to_string(next_queue_index)));
	set_vulkan_debug_label(vulkan_dev, VK_OBJECT_TYPE_QUEUE, uint64_t(queue_obj), queue_name);
	
	auto ret = make_shared<vulkan_queue>(dev, queue_obj, family_index, next_queue_index, queue_type);
	queues.push_back(ret);
	return ret;
}

shared_ptr<compute_queue> vulkan_compute::create_queue(const compute_device& dev) const {
	const auto& vulkan_dev = (const vulkan_device&)dev;