diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2020-06-30 23:57:22 +0300 |
---|---|---|
committer | Sebastian Dröge <slomo@coaxion.net> | 2020-07-01 00:28:02 +0300 |
commit | a28455f0ce221558ce56ac0507cf437d8418db8a (patch) | |
tree | e5f6755c0d72d68696ce72ccbec7e963838ed76e /generic | |
parent | e2f27e77cefef85c767d8c3bc6817ee6c1596ba6 (diff) |
Update for Element::post_message() signature change
Diffstat (limited to 'generic')
-rw-r--r-- | generic/sodium/src/decrypter.rs | 2 | ||||
-rw-r--r-- | generic/sodium/src/encrypter.rs | 2 | ||||
-rw-r--r-- | generic/threadshare/src/appsrc.rs | 2 | ||||
-rw-r--r-- | generic/threadshare/src/inputselector.rs | 4 | ||||
-rw-r--r-- | generic/threadshare/src/jitterbuffer/jitterbuffer.rs | 5 | ||||
-rw-r--r-- | generic/threadshare/src/proxy.rs | 6 | ||||
-rw-r--r-- | generic/threadshare/src/queue.rs | 2 | ||||
-rw-r--r-- | generic/threadshare/src/tcpclientsrc.rs | 4 | ||||
-rw-r--r-- | generic/threadshare/src/udpsink.rs | 4 | ||||
-rw-r--r-- | generic/threadshare/src/udpsrc.rs | 2 | ||||
-rw-r--r-- | generic/threadshare/tests/pad.rs | 2 |
11 files changed, 17 insertions, 18 deletions
diff --git a/generic/sodium/src/decrypter.rs b/generic/sodium/src/decrypter.rs index 9d0078992..acbd568c8 100644 --- a/generic/sodium/src/decrypter.rs +++ b/generic/sodium/src/decrypter.rs @@ -696,7 +696,7 @@ impl ElementImpl for Decrypter { // Create an internal state struct from the provided properties or // refuse to change state let state_ = State::from_props(&props).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; diff --git a/generic/sodium/src/encrypter.rs b/generic/sodium/src/encrypter.rs index cdaded799..34611cbf8 100644 --- a/generic/sodium/src/encrypter.rs +++ b/generic/sodium/src/encrypter.rs @@ -537,7 +537,7 @@ impl ElementImpl for Encrypter { // Create an internal state struct from the provided properties or // refuse to change state let state_ = State::from_props(&props).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; diff --git a/generic/threadshare/src/appsrc.rs b/generic/threadshare/src/appsrc.rs index ea33a9bb6..4806152cf 100644 --- a/generic/threadshare/src/appsrc.rs +++ b/generic/threadshare/src/appsrc.rs @@ -703,7 +703,7 @@ impl ElementImpl for AppSrc { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/inputselector.rs b/generic/threadshare/src/inputselector.rs index 1822a1dda..9f9578b2e 100644 --- a/generic/threadshare/src/inputselector.rs +++ b/generic/threadshare/src/inputselector.rs @@ -614,7 +614,7 @@ impl ElementImpl for InputSelector { drop(pads); drop(state); - let _ = element.post_message(&gst::message::Latency::builder().src(element).build()); + let _ = element.post_message(gst::message::Latency::builder().src(element).build()); Some(ret) } @@ -626,7 +626,7 @@ impl ElementImpl for InputSelector { element.remove_pad(pad).unwrap(); drop(pads); - let _ = element.post_message(&gst::message::Latency::builder().src(element).build()); + let _ = element.post_message(gst::message::Latency::builder().src(element).build()); } fn provide_clock(&self, _element: &gst::Element) -> Option<gst::Clock> { diff --git a/generic/threadshare/src/jitterbuffer/jitterbuffer.rs b/generic/threadshare/src/jitterbuffer/jitterbuffer.rs index 8fe1173bc..1a08cefa3 100644 --- a/generic/threadshare/src/jitterbuffer/jitterbuffer.rs +++ b/generic/threadshare/src/jitterbuffer/jitterbuffer.rs @@ -1511,8 +1511,7 @@ impl ObjectImpl for JitterBuffer { state.jbuf.borrow().set_delay(latency_ms * gst::MSECOND); let element = obj.downcast_ref::<gst::Element>().unwrap(); - let _ = - element.post_message(&gst::message::Latency::builder().src(element).build()); + let _ = element.post_message(gst::message::Latency::builder().src(element).build()); } subclass::Property("do-lost", ..) => { let mut settings = self.settings.lock().unwrap(); @@ -1607,7 +1606,7 @@ impl ElementImpl for JitterBuffer { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/proxy.rs b/generic/threadshare/src/proxy.rs index da769072a..2042e0106 100644 --- a/generic/threadshare/src/proxy.rs +++ b/generic/threadshare/src/proxy.rs @@ -389,7 +389,7 @@ impl PadSinkHandler for ProxySinkPadHandler { match event.view() { EventView::Eos(..) => { let _ = - element.post_message(&gst::message::Eos::builder().src(&element).build()); + element.post_message(gst::message::Eos::builder().src(&element).build()); } EventView::FlushStop(..) => proxysink.start(&element), _ => (), @@ -741,7 +741,7 @@ impl ElementImpl for ProxySink { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } @@ -1287,7 +1287,7 @@ impl ElementImpl for ProxySrc { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/queue.rs b/generic/threadshare/src/queue.rs index e07c9cca2..2fc4ad824 100644 --- a/generic/threadshare/src/queue.rs +++ b/generic/threadshare/src/queue.rs @@ -871,7 +871,7 @@ impl ElementImpl for Queue { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/tcpclientsrc.rs b/generic/threadshare/src/tcpclientsrc.rs index 6d554dca6..0004e7040 100644 --- a/generic/threadshare/src/tcpclientsrc.rs +++ b/generic/threadshare/src/tcpclientsrc.rs @@ -399,7 +399,7 @@ impl TaskImpl for TcpClientSrcTask { match trigger { task::Trigger::Prepare => { gst_error!(CAT, "Task preparation failed: {:?}", err); - self.element.post_error_message(&err); + self.element.post_error_message(err); task::Trigger::Error } @@ -722,7 +722,7 @@ impl ElementImpl for TcpClientSrc { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/udpsink.rs b/generic/threadshare/src/udpsink.rs index ea7c0e01a..fe5189ee1 100644 --- a/generic/threadshare/src/udpsink.rs +++ b/generic/threadshare/src/udpsink.rs @@ -754,7 +754,7 @@ impl UdpSinkPadHandler { async fn handle_event(&self, element: &gst::Element, event: gst::Event) { match event.view() { EventView::Eos(_) => { - let _ = element.post_message(&gst::message::Eos::builder().src(element).build()); + let _ = element.post_message(gst::message::Eos::builder().src(element).build()); } EventView::Segment(e) => { self.0.write().unwrap().segment = Some(e.get_segment().clone()); @@ -1521,7 +1521,7 @@ impl ElementImpl for UdpSink { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/src/udpsrc.rs b/generic/threadshare/src/udpsrc.rs index 37ebee2f8..ac5a59bcd 100644 --- a/generic/threadshare/src/udpsrc.rs +++ b/generic/threadshare/src/udpsrc.rs @@ -929,7 +929,7 @@ impl ElementImpl for UdpSrc { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/generic/threadshare/tests/pad.rs b/generic/threadshare/tests/pad.rs index 6ffbb3a48..b751998d0 100644 --- a/generic/threadshare/tests/pad.rs +++ b/generic/threadshare/tests/pad.rs @@ -373,7 +373,7 @@ impl ElementImpl for ElementSrcTest { match transition { gst::StateChange::NullToReady => { self.prepare(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } |