Method create_queue_internal

src/device/vulkan/vulkan_context.cpp:3176–3204

}

std::shared_ptr<device_queue> vulkan_context::create_queue_internal(const device& dev, const uint32_t family_index,
																const device_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 std::string queue_name = (family_index == vulkan_dev.all_queue_family_index ?
							   "queue:" + (next_queue_index == 0 ? "default" : std::to_string(next_queue_index)) :
							   "device_queue:" + (next_queue_index == 0 ? "default" : std::to_string(next_queue_index)));
	set_vulkan_debug_label(vulkan_dev, VK_OBJECT_TYPE_QUEUE, uint64_t(queue_obj), queue_name);
	
	auto ret = std::make_shared<vulkan_queue>(dev, queue_obj, family_index, next_queue_index, queue_type);
	queues.push_back(ret);
	return ret;
}

std::shared_ptr<device_queue> vulkan_context::create_queue(const device& dev) const {
	const auto& vulkan_dev = (const vulkan_device&)dev;