wgpu_hal/dynamic/
queue.rs

1use crate::{
2    DeviceError, DynCommandBuffer, DynFence, DynResource, DynSurface, DynSurfaceTexture,
3    FenceValue, Queue, SurfaceError,
4};
5
6use super::DynResourceExt as _;
7
8pub trait DynQueue: DynResource {
9    unsafe fn submit(
10        &self,
11        command_buffers: &[&dyn DynCommandBuffer],
12        surface_textures: &[&dyn DynSurfaceTexture],
13        signal_fence: (&mut dyn DynFence, FenceValue),
14    ) -> Result<(), DeviceError>;
15    unsafe fn present(
16        &self,
17        surface: &dyn DynSurface,
18        texture: Box<dyn DynSurfaceTexture>,
19    ) -> Result<(), SurfaceError>;
20    unsafe fn get_timestamp_period(&self) -> f32;
21}
22
23impl<Q: Queue + DynResource> DynQueue for Q {
24    unsafe fn submit(
25        &self,
26        command_buffers: &[&dyn DynCommandBuffer],
27        surface_textures: &[&dyn DynSurfaceTexture],
28        signal_fence: (&mut dyn DynFence, FenceValue),
29    ) -> Result<(), DeviceError> {
30        let command_buffers = command_buffers
31            .iter()
32            .map(|cb| (*cb).expect_downcast_ref())
33            .collect::<Vec<_>>();
34        let surface_textures = surface_textures
35            .iter()
36            .map(|surface| (*surface).expect_downcast_ref())
37            .collect::<Vec<_>>();
38        let signal_fence = (signal_fence.0.expect_downcast_mut(), signal_fence.1);
39        unsafe { Q::submit(self, &command_buffers, &surface_textures, signal_fence) }
40    }
41
42    unsafe fn present(
43        &self,
44        surface: &dyn DynSurface,
45        texture: Box<dyn DynSurfaceTexture>,
46    ) -> Result<(), SurfaceError> {
47        let surface = surface.expect_downcast_ref();
48        unsafe { Q::present(self, surface, texture.unbox()) }
49    }
50
51    unsafe fn get_timestamp_period(&self) -> f32 {
52        unsafe { Q::get_timestamp_period(self) }
53    }
54}