archive-gh-me/wgpu
1
0
Fork 0
mirror of https://github.com/gfx-rs/wgpu.git synced 2025-12-08 21:26:17 +00:00
Code Issues Projects Releases Wiki Activity

add device validity checks to Queue methods

Browse Source
This commit is contained in:
teoxoy 2025-03-31 16:44:01 +02:00 committed by Teodor Tanasoaia
parent 1c071b14af
commit c49620d1a2
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
wgpu-core/src/device/queue.rs
View File

@ -463,6 +463,8 @@ impl Queue {
profiling::scope!("Queue::write_buffer");
api_log!("Queue::write_buffer");
self.device.check_is_valid()?;
let buffer = buffer.get()?;
let data_size = data.len() as wgt::BufferAddress;
@ -509,6 +511,8 @@ impl Queue {
profiling::scope!("Queue::create_staging_buffer");
resource_log!("Queue::create_staging_buffer");
self.device.check_is_valid()?;
let staging_buffer = StagingBuffer::new(&self.device, buffer_size)?;
let ptr = unsafe { staging_buffer.ptr() };
@ -523,6 +527,8 @@ impl Queue {
) -> Result<(), QueueWriteError> {
profiling::scope!("Queue::write_staging_buffer");
self.device.check_is_valid()?;
let buffer = buffer.get()?;
let snatch_guard = self.device.snatchable_lock.read();
@ -554,6 +560,8 @@ impl Queue {
) -> Result<(), QueueWriteError> {
profiling::scope!("Queue::validate_write_buffer");
self.device.check_is_valid()?;
let buffer = buffer.get()?;
self.validate_write_buffer_impl(&buffer, buffer_offset, buffer_size)?;
@ -594,6 +602,8 @@ impl Queue {
buffer: Arc<Buffer>,
buffer_offset: u64,
) -> Result<(), QueueWriteError> {
self.device.check_is_valid()?;
let transition = {
let mut trackers = self.device.trackers.lock();
trackers
@ -651,6 +661,8 @@ impl Queue {
profiling::scope!("Queue::write_texture");
api_log!("Queue::write_texture");
self.device.check_is_valid()?;
if size.width == 0 || size.height == 0 || size.depth_or_array_layers == 0 {
log::trace!("Ignoring write_texture of size 0");
return Ok(());
@ -873,6 +885,8 @@ impl Queue {
) -> Result<(), QueueWriteError> {
profiling::scope!("Queue::copy_external_image_to_texture");
self.device.check_is_valid()?;
if size.width == 0 || size.height == 0 || size.depth_or_array_layers == 0 {
log::trace!("Ignoring write_texture of size 0");
return Ok(());
@ -1076,6 +1090,11 @@ impl Queue {
let mut command_index_guard = self.device.command_indices.write();
command_index_guard.active_submission_index += 1;
submit_index = command_index_guard.active_submission_index;
if let Err(e) = self.device.check_is_valid() {
break 'error Err(e.into());
}
let mut active_executions = Vec::new();
let mut used_surface_textures = track::TextureUsageScope::default();