vulkan: Add guard struct for command pool lock

gstreamer-vulkan/Gir.toml

@@ -23,7 +23,6 @@ generate = [
     "GstVulkan.VulkanBufferMemoryAllocator",
     "GstVulkan.VulkanBufferPool",
     "GstVulkan.VulkanCommandBuffer",
-    "GstVulkan.VulkanCommandPool",
     #"GstVulkan.VulkanDecoder",
     "GstVulkan.VulkanDescriptorSet",
     "GstVulkan.VulkanDevice",
@@ -92,6 +91,16 @@ name = "Gst.Structure"
 status = "manual"
 ref_mode = "ref"
 
+[[object]]
+name = "GstVulkan.VulkanCommandPool"
+status = "generate"
+    [[object.function]]
+    name = "lock"
+    manual = true
+    [[object.function]]
+    name = "unlock"
+    manual = true
+
 [[object]]
 name = "GstVulkan.VulkanDescriptorCache"
 status = "generate"

gstreamer-vulkan/src/auto/vulkan_command_pool.rs

@@ -46,20 +46,6 @@ pub trait VulkanCommandPoolExt: IsA<VulkanCommandPool> + 'static {
             ))
         }
     }
-
-    #[doc(alias = "gst_vulkan_command_pool_lock")]
-    fn lock(&self) {
-        unsafe {
-            ffi::gst_vulkan_command_pool_lock(self.as_ref().to_glib_none().0);
-        }
-    }
-
-    #[doc(alias = "gst_vulkan_command_pool_unlock")]
-    fn unlock(&self) {
-        unsafe {
-            ffi::gst_vulkan_command_pool_unlock(self.as_ref().to_glib_none().0);
-        }
-    }
 }
 
 impl<O: IsA<VulkanCommandPool>> VulkanCommandPoolExt for O {}

gstreamer-vulkan/src/lib.rs

@@ -25,6 +25,7 @@ macro_rules! skip_assert_initialized {
 mod auto;
 pub use crate::auto::*;
 
+mod vulkan_command_pool;
 mod vulkan_device;
 mod vulkan_full_screen_quad;
 mod vulkan_queue;
@@ -36,6 +37,7 @@ pub mod prelude {
     #[doc(hidden)]
     pub use gst_video::prelude::*;
 
+    pub use super::vulkan_command_pool::VulkanCommandPoolExtManual;
     pub use super::vulkan_device::VulkanDeviceExtManual;
     pub use super::vulkan_full_screen_quad::VulkanFullScreenQuadExtManual;
     pub use super::vulkan_queue::VulkanQueueExtManual;

gstreamer-vulkan/src/vulkan_command_pool.rs

@@ -0,0 +1,42 @@
+use crate::VulkanCommandPool;
+
+use glib::{prelude::*, translate::*};
+
+mod sealed {
+    pub trait Sealed {}
+    impl<T: super::IsA<super::VulkanCommandPool>> Sealed for T {}
+}
+
+/// Represents a locked VulkanCommandPool. The command pool is unlocked when this struct is dropped.
+#[derive(Debug)]
+pub struct VulkanCommandPoolGuard<'a> {
+    obj: &'a VulkanCommandPool,
+}
+
+impl Drop for VulkanCommandPoolGuard<'_> {
+    fn drop(&mut self) {
+        unsafe {
+            ffi::gst_vulkan_command_pool_unlock(self.obj.to_glib_none().0);
+        }
+    }
+}
+impl PartialEq for VulkanCommandPoolGuard<'_> {
+    fn eq(&self, other: &Self) -> bool {
+        self.obj == other.obj
+    }
+}
+impl Eq for VulkanCommandPoolGuard<'_> {}
+
+pub trait VulkanCommandPoolExtManual: sealed::Sealed + IsA<VulkanCommandPool> + 'static {
+    /// Locks the command pool. A struct similar to `MutexGuard` is retured that unlocks the command pool once dropped.
+    #[doc(alias = "gst_vulkan_command_pool_lock")]
+    fn lock<'a>(&'a self) -> VulkanCommandPoolGuard<'a> {
+        unsafe {
+            ffi::gst_vulkan_command_pool_lock(self.as_ref().to_glib_none().0);
+        }
+        VulkanCommandPoolGuard {
+            obj: self.upcast_ref(),
+        }
+    }
+}
+impl<O: IsA<VulkanCommandPool>> VulkanCommandPoolExtManual for O {}