gstreamer: Move initialization panic into a separate function

This keeps the number of duplicated panics all over the codebase lower
and reduces generated code size.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1184>

gstreamer-allocators/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-app/src/lib.rs

@@ -10,6 +10,14 @@ pub use glib;
 pub use gst;
 pub use gst_base;
 
+macro_rules! assert_initialized_main_thread {
+    () => {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
+            gst::assert_initialized();
+        }
+    };
+}
+
 macro_rules! skip_assert_initialized {
     () => {};
 }

gstreamer-audio/src/lib.rs

@@ -13,12 +13,7 @@ pub use gst_base;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-base/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-check/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-controller/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-editing-services/src/lib.rs

@@ -39,12 +39,7 @@ pub unsafe fn deinit() {
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
         crate::GES_INIT.call_once(|| {
             unsafe { ffi::ges_init() };

gstreamer-gl/egl/src/lib.rs

@@ -15,8 +15,8 @@ pub use gst_gl;
 
 macro_rules! assert_initialized_main_thread {
     () => {
-        if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            panic!("GStreamer has not been initialized. Call `gst::init` first.");
+            gst::assert_initialized();
         }
     };
 }

gstreamer-gl/src/lib.rs

@@ -14,12 +14,7 @@ pub use gst_video;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-gl/wayland/src/lib.rs

@@ -15,8 +15,8 @@ pub use gst_gl;
 
 macro_rules! assert_initialized_main_thread {
     () => {
-        if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            panic!("GStreamer has not been initialized. Call `gst::init` first.");
+            gst::assert_initialized();
         }
     };
 }

gstreamer-gl/x11/src/lib.rs

@@ -15,8 +15,8 @@ pub use gst_gl;
 
 macro_rules! assert_initialized_main_thread {
     () => {
-        if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            panic!("GStreamer has not been initialized. Call `gst::init` first.");
+            gst::assert_initialized();
         }
     };
 }

gstreamer-mpegts/src/lib.rs

@@ -13,12 +13,7 @@ static MPEGTS_INIT: Once = Once::new();
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
         crate::MPEGTS_INIT.call_once(|| unsafe { ffi::gst_mpegts_initialize() });
     };

gstreamer-net/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-pbutils/src/lib.rs

@@ -16,12 +16,7 @@ static PBUTILS_INIT: Once = Once::new();
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
         crate::PBUTILS_INIT.call_once(|| {
             unsafe { ffi::gst_pb_utils_init() };

gstreamer-play/src/lib.rs

@@ -16,12 +16,7 @@ macro_rules! skip_assert_initialized {
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-player/src/lib.rs

@@ -16,12 +16,7 @@ macro_rules! skip_assert_initialized {
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-rtp/src/lib.rs

@@ -13,12 +13,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-rtsp-server/src/lib.rs

@@ -16,12 +16,7 @@ pub use gst_sdp;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-rtsp/src/lib.rs

@@ -13,12 +13,7 @@ pub use gst_sdp;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-sdp/src/lib.rs

@@ -12,12 +12,7 @@ pub use gst;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-validate/src/lib.rs

@@ -8,25 +8,25 @@
 #[doc(hidden)]
 pub static INITIALIZED: std::sync::atomic::AtomicBool = std::sync::atomic::AtomicBool::new(false);
 
+#[cold]
+#[inline(never)]
+#[track_caller]
+pub fn assert_initialized() {
+    if unsafe { ffi::gst_validate_is_initialized() } != glib::ffi::GTRUE {
+        panic!("GStreamer Validate has not been initialized. Call `gst_validate::init` first.");
+    } else {
+        crate::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
+    }
+}
+
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
 
         if !crate::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            if unsafe { ffi::gst_validate_is_initialized() } != glib::ffi::GTRUE {
+            $crate::assert_initialized();
-                panic!(
-                    "GStreamer Validate has not been initialized. Call `gst_validate::init` first."
-                );
-            } else {
-                crate::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-video/src/lib.rs

@@ -13,12 +13,7 @@ pub use gst_base;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer-webrtc/src/lib.rs

@@ -13,12 +13,7 @@ pub use gst_sdp;
 macro_rules! assert_initialized_main_thread {
     () => {
         if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            gst::assert_initialized();
-            if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                gst::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }

gstreamer/src/lib.rs

@@ -15,15 +15,22 @@ pub use paste;
 #[doc(hidden)]
 pub static INITIALIZED: std::sync::atomic::AtomicBool = std::sync::atomic::AtomicBool::new(false);
 
+#[cold]
+#[inline(never)]
+#[track_caller]
+pub fn assert_initialized() {
+    #[allow(unused_unsafe)]
+    if unsafe { ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+        panic!("GStreamer has not been initialized. Call `gst::init` first.");
+    } else {
+        crate::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
+    }
+}
+
 macro_rules! assert_initialized_main_thread {
     () => {
         if !crate::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            #[allow(unused_unsafe)]
+            $crate::assert_initialized();
-            if unsafe { ffi::gst_is_initialized() } != glib::ffi::GTRUE {
-                panic!("GStreamer has not been initialized. Call `gst::init` first.");
-            } else {
-                crate::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
-            }
         }
     };
 }