Store whether GStreamer was initialized in an AtomicBool

Avoids a function call in the normal case.

gstreamer-allocators/src/lib.rs

@@ -11,9 +11,13 @@ pub use gst;
 
 macro_rules! assert_initialized_main_thread {
     () => {
-        #[allow(unused_unsafe)]
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-        if unsafe { gst::ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+            #[allow(unused_unsafe)]
-            panic!("GStreamer has not been initialized. Call `gst::init` first.");
+            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-audio/src/lib.rs

@@ -12,8 +12,13 @@ pub use gst_base;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -11,8 +11,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -11,8 +11,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -11,8 +11,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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,8 +39,13 @@ pub unsafe fn deinit() {
 
 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.");
+            #[allow(unused_unsafe)]
+            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/src/lib.rs

@@ -13,8 +13,13 @@ pub use gst_video;
 
 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.");
+            #[allow(unused_unsafe)]
+            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-net/src/lib.rs

@@ -11,8 +11,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -15,8 +15,13 @@ static PBUTILS_INIT: Once = Once::new();
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -14,7 +14,16 @@ macro_rules! skip_assert_initialized {
 }
 
 macro_rules! assert_initialized_main_thread {
-    () => {};
+    () => {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
+            #[allow(unused_unsafe)]
+            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);
+            }
+        }
+    };
 }
 
 #[allow(clippy::needless_borrow)]

gstreamer-player/src/lib.rs

@@ -14,7 +14,16 @@ macro_rules! skip_assert_initialized {
 }
 
 macro_rules! assert_initialized_main_thread {
-    () => {};
+    () => {
+        if !gst::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
+            #[allow(unused_unsafe)]
+            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);
+            }
+        }
+    };
 }
 
 #[allow(clippy::unreadable_literal)]

gstreamer-rtp/src/lib.rs

@@ -12,8 +12,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -15,8 +15,13 @@ pub use gst_sdp;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -12,8 +12,13 @@ pub use gst_sdp;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -11,8 +11,13 @@ pub use gst;
 
 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.");
+            #[allow(unused_unsafe)]
+            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-video/src/lib.rs

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

@@ -12,8 +12,13 @@ pub use gst_sdp;
 
 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.");
+            #[allow(unused_unsafe)]
+            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

@@ -14,10 +14,18 @@ pub use paste;
 
 use glib::translate::{from_glib, from_glib_full};
 
+#[doc(hidden)]
+pub static INITIALIZED: std::sync::atomic::AtomicBool = std::sync::atomic::AtomicBool::new(false);
+
 macro_rules! assert_initialized_main_thread {
     () => {
-        if unsafe { ffi::gst_is_initialized() } != glib::ffi::GTRUE {
+        if !crate::INITIALIZED.load(std::sync::atomic::Ordering::SeqCst) {
-            panic!("GStreamer has not been initialized. Call `gst::init` first.");
+            #[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);
+            }
         }
     };
 }
@@ -263,6 +271,7 @@ pub fn init() -> Result<(), glib::Error> {
             ptr::null_mut(),
             &mut error,
         )) {
+            crate::INITIALIZED.store(true, std::sync::atomic::Ordering::SeqCst);
             Ok(())
         } else {
             Err(from_glib_full(error))
@@ -278,6 +287,7 @@ pub fn init() -> Result<(), glib::Error> {
 /// This must only be called once during the lifetime of the process, once no GStreamer threads
 /// are running anymore and all GStreamer resources are released.
 pub unsafe fn deinit() {
+    crate::INITIALIZED.store(false, std::sync::atomic::Ordering::SeqCst);
     ffi::gst_deinit();
 }