Use mem::ManuallyDrop instead of mem::forget() everywhere

It makes the intentions clearer and potentially results in simpler
assembly, at least in debug builds.

gstreamer-check/src/harness.rs

@@ -128,9 +128,8 @@ impl Harness {
 
     pub fn add_sink_harness(&mut self, sink_harness: Harness) {
         unsafe {
+            let sink_harness = mem::ManuallyDrop::new(sink_harness);
             gst_check_sys::gst_harness_add_sink_harness(self.0.as_ptr(), sink_harness.0.as_ptr());
-
-            mem::forget(sink_harness);
         }
     }
 
@@ -152,13 +151,12 @@ impl Harness {
 
     pub fn add_src_harness(&mut self, src_harness: Harness, has_clock_wait: bool) {
         unsafe {
+            let src_harness = mem::ManuallyDrop::new(src_harness);
             gst_check_sys::gst_harness_add_src_harness(
                 self.0.as_ptr(),
                 src_harness.0.as_ptr(),
                 has_clock_wait.to_glib(),
             );
-
-            mem::forget(src_harness);
         }
     }
 

gstreamer-player/src/config.rs

@@ -96,9 +96,9 @@ impl PlayerConfig {
         }
     }
 
-    pub unsafe fn into_ptr(mut self) -> *mut gst_sys::GstStructure {
+    pub unsafe fn into_ptr(self) -> *mut gst_sys::GstStructure {
-        let ptr = self.0.to_glib_none_mut().0;
+        let mut s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let ptr = s.0.to_glib_none_mut().0;
         ptr
     }
 }

gstreamer-rtsp-server/src/subclass/rtsp_client.rs

@@ -11,6 +11,8 @@ use gst_rtsp_server_sys;
 use glib::subclass::prelude::*;
 use glib::translate::*;
 
+use std::mem;
+
 use RTSPClient;
 use RTSPClientClass;
 
@@ -841,9 +843,8 @@ where
     let imp = instance.get_impl();
     let wrap: Borrowed<RTSPClient> = from_glib_borrow(ptr);
 
-    let sdp = imp.create_sdp(&wrap, &from_glib_borrow(media));
+    let sdp = mem::ManuallyDrop::new(imp.create_sdp(&wrap, &from_glib_borrow(media)));
     let ptr = sdp.to_glib_none().0;
-    std::mem::forget(sdp);
 
     ptr as *mut _
 }

gstreamer-sdp/src/sdp_media.rs

@@ -386,7 +386,7 @@ impl SDPMediaRef {
         }
     }
 
-    pub fn insert_attribute(&mut self, idx: Option<u32>, mut attr: SDPAttribute) -> Result<(), ()> {
+    pub fn insert_attribute(&mut self, idx: Option<u32>, attr: SDPAttribute) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.attributes_len() {
                 return Err(());
@@ -394,16 +394,16 @@ impl SDPMediaRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut attr = mem::ManuallyDrop::new(attr);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_insert_attribute(&mut self.0, idx, &mut attr.0) };
-        mem::forget(attr);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn insert_bandwidth(&mut self, idx: Option<u32>, mut bw: SDPBandwidth) -> Result<(), ()> {
+    pub fn insert_bandwidth(&mut self, idx: Option<u32>, bw: SDPBandwidth) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.bandwidths_len() {
                 return Err(());
@@ -411,20 +411,16 @@ impl SDPMediaRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut bw = mem::ManuallyDrop::new(bw);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_insert_bandwidth(&mut self.0, idx, &mut bw.0) };
-        mem::forget(bw);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn insert_connection(
+    pub fn insert_connection(&mut self, idx: Option<u32>, conn: SDPConnection) -> Result<(), ()> {
-        &mut self,
-        idx: Option<u32>,
-        mut conn: SDPConnection,
-    ) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.connections_len() {
                 return Err(());
@@ -432,9 +428,9 @@ impl SDPMediaRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut conn = mem::ManuallyDrop::new(conn);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_insert_connection(&mut self.0, idx, &mut conn.0) };
-        mem::forget(conn);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
@@ -506,42 +502,42 @@ impl SDPMediaRef {
         }
     }
 
-    pub fn replace_attribute(&mut self, idx: u32, mut attr: SDPAttribute) -> Result<(), ()> {
+    pub fn replace_attribute(&mut self, idx: u32, attr: SDPAttribute) -> Result<(), ()> {
         if idx >= self.attributes_len() {
             return Err(());
         }
 
+        let mut attr = mem::ManuallyDrop::new(attr);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_replace_attribute(&mut self.0, idx, &mut attr.0) };
-        mem::forget(attr);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn replace_bandwidth(&mut self, idx: u32, mut bw: SDPBandwidth) -> Result<(), ()> {
+    pub fn replace_bandwidth(&mut self, idx: u32, bw: SDPBandwidth) -> Result<(), ()> {
         if idx >= self.bandwidths_len() {
             return Err(());
         }
 
+        let mut bw = mem::ManuallyDrop::new(bw);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_replace_bandwidth(&mut self.0, idx, &mut bw.0) };
-        mem::forget(bw);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn replace_connection(&mut self, idx: u32, mut conn: SDPConnection) -> Result<(), ()> {
+    pub fn replace_connection(&mut self, idx: u32, conn: SDPConnection) -> Result<(), ()> {
         if idx >= self.connections_len() {
             return Err(());
         }
 
+        let mut conn = mem::ManuallyDrop::new(conn);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_media_replace_connection(&mut self.0, idx, &mut conn.0) };
-        mem::forget(conn);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),

gstreamer-sdp/src/sdp_message.rs

@@ -508,7 +508,7 @@ impl SDPMessageRef {
         }
     }
 
-    pub fn insert_attribute(&mut self, idx: Option<u32>, mut attr: SDPAttribute) -> Result<(), ()> {
+    pub fn insert_attribute(&mut self, idx: Option<u32>, attr: SDPAttribute) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.attributes_len() {
                 return Err(());
@@ -516,16 +516,16 @@ impl SDPMessageRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut attr = mem::ManuallyDrop::new(attr);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_insert_attribute(&mut self.0, idx, &mut attr.0) };
-        mem::forget(attr);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn insert_bandwidth(&mut self, idx: Option<u32>, mut bw: SDPBandwidth) -> Result<(), ()> {
+    pub fn insert_bandwidth(&mut self, idx: Option<u32>, bw: SDPBandwidth) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.bandwidths_len() {
                 return Err(());
@@ -533,9 +533,9 @@ impl SDPMessageRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut bw = mem::ManuallyDrop::new(bw);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_insert_bandwidth(&mut self.0, idx, &mut bw.0) };
-        mem::forget(bw);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
@@ -576,7 +576,7 @@ impl SDPMessageRef {
         }
     }
 
-    pub fn insert_time(&mut self, idx: Option<u32>, mut time: SDPTime) -> Result<(), ()> {
+    pub fn insert_time(&mut self, idx: Option<u32>, time: SDPTime) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.times_len() {
                 return Err(());
@@ -584,16 +584,16 @@ impl SDPMessageRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut time = mem::ManuallyDrop::new(time);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_insert_time(&mut self.0, idx, &mut time.0) };
-        mem::forget(time);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn insert_zone(&mut self, idx: Option<u32>, mut zone: SDPZone) -> Result<(), ()> {
+    pub fn insert_zone(&mut self, idx: Option<u32>, zone: SDPZone) -> Result<(), ()> {
         if let Some(idx) = idx {
             if idx >= self.zones_len() {
                 return Err(());
@@ -601,9 +601,9 @@ impl SDPMessageRef {
         }
 
         let idx = idx.map(|idx| idx as i32).unwrap_or(-1);
+        let mut zone = mem::ManuallyDrop::new(zone);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_insert_zone(&mut self.0, idx, &mut zone.0) };
-        mem::forget(zone);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
@@ -690,29 +690,29 @@ impl SDPMessageRef {
         }
     }
 
-    pub fn replace_attribute(&mut self, idx: u32, mut attr: SDPAttribute) -> Result<(), ()> {
+    pub fn replace_attribute(&mut self, idx: u32, attr: SDPAttribute) -> Result<(), ()> {
         if idx >= self.attributes_len() {
             return Err(());
         }
 
+        let mut attr = mem::ManuallyDrop::new(attr);
         let result = unsafe {
             gst_sdp_sys::gst_sdp_message_replace_attribute(&mut self.0, idx, &mut attr.0)
         };
-        mem::forget(attr);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn replace_bandwidth(&mut self, idx: u32, mut bw: SDPBandwidth) -> Result<(), ()> {
+    pub fn replace_bandwidth(&mut self, idx: u32, bw: SDPBandwidth) -> Result<(), ()> {
         if idx >= self.bandwidths_len() {
             return Err(());
         }
 
+        let mut bw = mem::ManuallyDrop::new(bw);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_replace_bandwidth(&mut self.0, idx, &mut bw.0) };
-        mem::forget(bw);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
@@ -747,28 +747,28 @@ impl SDPMessageRef {
         }
     }
 
-    pub fn replace_time(&mut self, idx: u32, mut time: SDPTime) -> Result<(), ()> {
+    pub fn replace_time(&mut self, idx: u32, time: SDPTime) -> Result<(), ()> {
         if idx >= self.times_len() {
             return Err(());
         }
 
+        let mut time = mem::ManuallyDrop::new(time);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_replace_time(&mut self.0, idx, &mut time.0) };
-        mem::forget(time);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),
         }
     }
 
-    pub fn replace_zone(&mut self, idx: u32, mut zone: SDPZone) -> Result<(), ()> {
+    pub fn replace_zone(&mut self, idx: u32, zone: SDPZone) -> Result<(), ()> {
         if idx >= self.zones_len() {
             return Err(());
         }
 
+        let mut zone = mem::ManuallyDrop::new(zone);
         let result =
             unsafe { gst_sdp_sys::gst_sdp_message_replace_zone(&mut self.0, idx, &mut zone.0) };
-        mem::forget(zone);
         match result {
             gst_sdp_sys::GST_SDP_OK => Ok(()),
             _ => Err(()),

gstreamer-video/src/video_codec_frame.rs

@@ -198,8 +198,8 @@ impl<'a> VideoCodecFrame<'a> {
         let stream_lock = self.element.get_stream_lock();
         glib_sys::g_rec_mutex_unlock(stream_lock);
 
-        let ptr = self.to_glib_none().0;
+        let s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let ptr = s.to_glib_none().0;
 
         ptr
     }

gstreamer-webrtc/src/web_rtc_session_description.rs

@@ -14,14 +14,14 @@ use WebRTCSDPType;
 use WebRTCSessionDescription;
 
 impl WebRTCSessionDescription {
-    pub fn new(type_: WebRTCSDPType, mut sdp: gst_sdp::SDPMessage) -> WebRTCSessionDescription {
+    pub fn new(type_: WebRTCSDPType, sdp: gst_sdp::SDPMessage) -> WebRTCSessionDescription {
         assert_initialized_main_thread!();
         unsafe {
+            let mut sdp = mem::ManuallyDrop::new(sdp);
             let desc = from_glib_full(gst_web_rtc_sys::gst_webrtc_session_description_new(
                 type_.to_glib(),
                 sdp.to_glib_none_mut().0,
             ));
-            mem::forget(sdp);
             desc
         }
     }

gstreamer/src/caps_features.rs

@@ -66,8 +66,8 @@ impl CapsFeatures {
     }
 
     pub unsafe fn into_ptr(self) -> *mut gst_sys::GstCapsFeatures {
-        let ptr = self.0.as_ptr() as *mut CapsFeaturesRef as *mut gst_sys::GstCapsFeatures;
+        let s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let ptr = s.0.as_ptr() as *mut CapsFeaturesRef as *mut gst_sys::GstCapsFeatures;
 
         ptr
     }

gstreamer/src/iterator.rs

@@ -43,8 +43,8 @@ where
     for<'a> T: FromValueOptional<'a> + 'static,
 {
     pub unsafe fn into_ptr(self) -> *mut gst_sys::GstIterator {
-        let it = self.to_glib_none().0;
+        let s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let it = s.to_glib_none().0;
         it as *mut _
     }
 

gstreamer/src/miniobject.rs

@@ -91,8 +91,8 @@ impl<T: MiniObject> GstRc<T> {
     }
 
     pub unsafe fn into_ptr(self) -> *mut T::GstType {
-        let ptr = self.as_mut_ptr();
+        let s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let ptr = s.as_mut_ptr();
 
         ptr
     }

gstreamer/src/structure.rs

@@ -110,8 +110,8 @@ impl Structure {
     }
 
     pub unsafe fn into_ptr(self) -> *mut gst_sys::GstStructure {
-        let ptr = self.0.as_ptr() as *mut StructureRef as *mut gst_sys::GstStructure;
+        let s = mem::ManuallyDrop::new(self);
-        mem::forget(self);
+        let ptr = s.0.as_ptr() as *mut StructureRef as *mut gst_sys::GstStructure;
 
         ptr
     }