use utils::c_bindings::*;
use utils::vk_traits::*;
use utils::vk_ptr::*;
use utils::vk_convert::*;
use std::os::raw::c_char;
use std::ops::Drop;
use std::ptr;
use std::mem;
use std::cmp;
use std::slice;
use vulkan::*;
use vulkan::vk::*;
#[doc(hidden)]
pub type RawVkQueue = u64;
#[derive(Debug, Clone, Copy)]
pub struct VkQueue {
_handle: RawVkQueue,
_fn_table: *mut VkFunctionTable
}
impl VkRawType<VkQueue> for RawVkQueue {
fn vk_to_wrapped(src: &RawVkQueue) -> VkQueue {
VkQueue {
_handle: *src,
_fn_table: ptr::null_mut()
}
}
}
impl VkWrappedType<RawVkQueue> for VkQueue {
fn vk_to_raw(src: &VkQueue, dst: &mut RawVkQueue) {
*dst = src._handle
}
}
impl Default for VkQueue {
fn default() -> VkQueue {
VkQueue {
_handle: 0,
_fn_table: ptr::null_mut()
}
}
}
impl PartialEq for VkQueue {
fn eq(&self, other: &VkQueue) -> bool {
self._handle == other._handle
}
}
impl VkSetup for VkQueue {
fn vk_setup(&mut self, fn_table: *mut VkFunctionTable) {
self._fn_table = fn_table;
}
}
impl VkQueue {
pub fn vk_handle(&self) -> u64 {
self._handle
}
pub fn is_null(&self) -> bool {
self._handle == 0
}
pub fn null() -> Self {
Self {
_handle: 0,
_fn_table: ptr::null_mut()
}
}
pub fn submit(&self, submits: Vec<VkSubmitInfo>, fence: Option<VkFence>) -> LavaResult<()> {
unsafe {
let raw_submit_count = submits.len() as u32;
let raw_submits = new_ptr_vk_array(&submits);
let raw_fence = vk_to_raw_value_checked(&fence);
let vk_result = ((&*self._fn_table).vkQueueSubmit)(self._handle, raw_submit_count, raw_submits, raw_fence);
free_vk_ptr_array(raw_submit_count as usize, raw_submits);
if vk_result == 0 { Ok(()) } else { Err((RawVkResult::vk_to_wrapped(&vk_result), ())) }
}
}
pub fn wait_idle(&self) -> LavaResult<()> {
unsafe {
let vk_result = ((&*self._fn_table).vkQueueWaitIdle)(self._handle);
if vk_result == 0 { Ok(()) } else { Err((RawVkResult::vk_to_wrapped(&vk_result), ())) }
}
}
pub fn bind_sparse(&self, bind_info: Vec<VkBindSparseInfo>, fence: Option<VkFence>) -> LavaResult<()> {
unsafe {
let raw_bind_info_count = bind_info.len() as u32;
let raw_bind_info = new_ptr_vk_array(&bind_info);
let raw_fence = vk_to_raw_value_checked(&fence);
let vk_result = ((&*self._fn_table).vkQueueBindSparse)(self._handle, raw_bind_info_count, raw_bind_info, raw_fence);
free_vk_ptr_array(raw_bind_info_count as usize, raw_bind_info);
if vk_result == 0 { Ok(()) } else { Err((RawVkResult::vk_to_wrapped(&vk_result), ())) }
}
}
pub fn present(&self, present_info: khr::VkPresentInfo) -> LavaResult<Vec<VkResult>> {
unsafe {
let raw_present_info = new_ptr_vk_value(&present_info);
let vk_result = ((&*self._fn_table).vkQueuePresentKHR)(self._handle, raw_present_info);
let vk_results : Vec<VkResult> = if (*raw_present_info).results.is_null() { Vec::new() } else { new_vk_array((*raw_present_info).swapchain_count, (*raw_present_info).results) };
free_vk_ptr(raw_present_info);
if vk_result == 0 { Ok(vk_results) } else { Err((RawVkResult::vk_to_wrapped(&vk_result), vk_results)) }
}
}
pub fn begin_debug_utils_label(&self, label_info: ext::VkDebugUtilsLabel) {
unsafe {
let raw_label_info = new_ptr_vk_value(&label_info);
((&*self._fn_table).vkQueueBeginDebugUtilsLabelEXT)(self._handle, raw_label_info);
free_vk_ptr(raw_label_info);
}
}
pub fn end_debug_utils_label(&self) {
unsafe {
((&*self._fn_table).vkQueueEndDebugUtilsLabelEXT)(self._handle);
}
}
pub fn insert_debug_utils_label(&self, label_info: ext::VkDebugUtilsLabel) {
unsafe {
let raw_label_info = new_ptr_vk_value(&label_info);
((&*self._fn_table).vkQueueInsertDebugUtilsLabelEXT)(self._handle, raw_label_info);
free_vk_ptr(raw_label_info);
}
}
pub fn get_checkpoint_data(&self) -> Vec<nv::VkCheckpointData> {
unsafe {
let mut raw_checkpoint_data : *mut nv::RawVkCheckpointData = ptr::null_mut();
let raw_checkpoint_data_count = &mut mem::zeroed() as *mut u32;
((&*self._fn_table).vkGetQueueCheckpointDataNV)(self._handle, raw_checkpoint_data_count, raw_checkpoint_data);
raw_checkpoint_data = calloc(*raw_checkpoint_data_count as usize, mem::size_of::<nv::RawVkCheckpointData>()) as *mut nv::RawVkCheckpointData;
((&*self._fn_table).vkGetQueueCheckpointDataNV)(self._handle, raw_checkpoint_data_count, raw_checkpoint_data);
let mut checkpoint_data = new_vk_array(*raw_checkpoint_data_count, raw_checkpoint_data);
for elt in &mut checkpoint_data { VkSetup::vk_setup(elt, self._fn_table); }
free(raw_checkpoint_data as *mut u8);
checkpoint_data
}
}
pub fn set_performance_configuration(&self, configuration: intel::VkPerformanceConfiguration) -> LavaResult<()> {
unsafe {
let raw_configuration = vk_to_raw_value(&configuration);
let vk_result = ((&*self._fn_table).vkQueueSetPerformanceConfigurationINTEL)(self._handle, raw_configuration);
if vk_result == 0 { Ok(()) } else { Err((RawVkResult::vk_to_wrapped(&vk_result), ())) }
}
}
}