mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-04-29 13:05:00 +00:00
Code Issues Projects Releases Wiki Activity

Update for Element::post_message() signature change

Browse source
This commit is contained in:
Sebastian Dröge 2020-06-30 23:57:22 +03:00 committed by Sebastian Dröge
parent e2f27e77ce
commit a28455f0ce
18 changed files with 41 additions and 43 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
generic/sodium/src/decrypter.rs
View file

@ -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
})?;

2
generic/sodium/src/encrypter.rs
View file

@ -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
})?;

2
generic/threadshare/src/appsrc.rs
View file

@ -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
})?;
}

4
generic/threadshare/src/inputselector.rs
View file

@ -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> {

5
generic/threadshare/src/jitterbuffer/jitterbuffer.rs
View file

@ -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
})?;
}

6
generic/threadshare/src/proxy.rs
View file

@ -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
})?;
}

2
generic/threadshare/src/queue.rs
View file

@ -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
})?;
}

4
generic/threadshare/src/tcpclientsrc.rs
View file

@ -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
})?;
}

4
generic/threadshare/src/udpsink.rs
View file

@ -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
})?;
}

2
generic/threadshare/src/udpsrc.rs
View file

@ -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
})?;
}

2
generic/threadshare/tests/pad.rs
View file

@ -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
})?;
}

8
net/reqwest/src/reqwesthttpsrc.rs
View file

@ -283,7 +283,7 @@ impl ReqwestHttpSrc {
}
} else {
let _ = src.post_message(
&gst::message::NeedContext::builder(REQWEST_CLIENT_CONTEXT)
gst::message::NeedContext::builder(REQWEST_CLIENT_CONTEXT)
.src(src)
.build(),
);
@ -325,7 +325,7 @@ impl ReqwestHttpSrc {
s.set("client", &client);
}
src.set_context(&context);
let _ = src.post_message(&gst::message::HaveContext::builder(context).src(src).build());
let _ = src.post_message(gst::message::HaveContext::builder(context).src(src).build());
*client_guard = Some(client.clone());
@ -944,7 +944,7 @@ impl BaseSrcImpl for ReqwestHttpSrc {
true
}
Err(Some(err)) => {
src.post_error_message(&err);
src.post_error_message(err);
false
}
Err(None) => false,
@ -1013,7 +1013,7 @@ impl PushSrcImpl for ReqwestHttpSrc {
Ok(res) => res,
Err(Some(err)) => {
gst_debug!(CAT, obj: src, "Error {:?}", err);
src.post_error_message(&err);
src.post_error_message(err);
return Err(gst::FlowError::Error);
}
Err(None) => {

4
net/rusoto/src/aws_transcribe_parse.rs
View file

@ -681,7 +681,7 @@ impl Transcriber {
gst_info!(CAT, obj: element, "Received flush start, disconnecting");
match self.disconnect(element) {
Err(err) => {
element.post_error_message(&err);
element.post_error_message(err);
false
}
Ok(_) => {
@ -1149,7 +1149,7 @@ impl ElementImpl for Transcriber {
match transition {
gst::StateChange::PausedToReady => {
self.disconnect(element).map_err(|err| {
element.post_error_message(&err);
element.post_error_message(err);
gst::StateChangeError
})?;
}

2
net/rusoto/src/s3sink.rs
View file

@ -502,7 +502,7 @@ impl BaseSinkImpl for S3Sink {
"Multipart upload failed: {}",
error_message
);
element.post_error_message(&error_message);
element.post_error_message(error_message);
Err(gst::FlowError::Error)
}
_ => {

5
tutorial/src/sinesrc.rs
View file

@ -315,8 +315,7 @@ impl ObjectImpl for SineSrc {
settings.samples_per_buffer = samples_per_buffer;
drop(settings);
let _ =
basesrc.post_message(&gst::message::Latency::builder().src(basesrc).build());
let _ = basesrc.post_message(gst::message::Latency::builder().src(basesrc).build());
}
subclass::Property("freq", ..) => {
let mut settings = self.settings.lock().unwrap();
@ -483,7 +482,7 @@ impl BaseSrcImpl for SineSrc {
drop(state);
let _ = element.post_message(&gst::message::Latency::builder().src(element).build());
let _ = element.post_message(gst::message::Latency::builder().src(element).build());
Ok(())
}

4
utils/fallbackswitch/src/base/subclass/aggregator.rs
View file

@ -867,7 +867,7 @@ where
match imp.start(&wrap) {
Ok(()) => true,
Err(err) => {
wrap.post_error_message(&err);
wrap.post_error_message(err);
false
}
}
@ -890,7 +890,7 @@ where
match imp.stop(&wrap) {
Ok(()) => true,
Err(err) => {
wrap.post_error_message(&err);
wrap.post_error_message(err);
false
}
}

20
utils/fallbackswitch/src/fallbacksrc.rs
View file

@ -555,7 +555,7 @@ impl FallbackSrc {
let src = FallbackSrc::from_instance(&element);
if let Err(msg) = src.handle_source_pad_added(&element, pad) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
});
let element_weak = element.downgrade();
@ -567,7 +567,7 @@ impl FallbackSrc {
let src = FallbackSrc::from_instance(&element);
if let Err(msg) = src.handle_source_pad_removed(&element, pad) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
});
@ -1147,7 +1147,7 @@ impl FallbackSrc {
let src = FallbackSrc::from_instance(&element);
if let Err(msg) = src.handle_pad_blocked(&element, pad, pts) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
gst::PadProbeReturn::Ok
@ -2103,7 +2103,7 @@ mod custom_source {
// one here so that fallbacksrc can know about our streams. It is never
// forwarded.
if let Err(msg) = self.handle_source_no_more_pads(&bin) {
bin.post_error_message(&msg);
bin.post_error_message(msg);
}
}
_ => self.parent_handle_message(bin, msg),
@ -2141,14 +2141,14 @@ mod custom_source {
// Handle all source pads that already exist
for pad in source.get_src_pads() {
if let Err(msg) = self.handle_source_pad_added(&element, &pad) {
element.post_error_message(&msg);
element.post_error_message(msg);
return Err(gst::StateChangeError);
}
}
if !has_sometimes_pads {
if let Err(msg) = self.handle_source_no_more_pads(&element) {
element.post_error_message(&msg);
element.post_error_message(msg);
return Err(gst::StateChangeError);
}
} else {
@ -2163,7 +2163,7 @@ mod custom_source {
let src = CustomSource::from_instance(&element);
if let Err(msg) = src.handle_source_pad_added(&element, pad) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
});
let element_weak = element.downgrade();
@ -2175,7 +2175,7 @@ mod custom_source {
let src = CustomSource::from_instance(&element);
if let Err(msg) = src.handle_source_pad_removed(&element, pad) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
});
@ -2188,7 +2188,7 @@ mod custom_source {
let src = CustomSource::from_instance(&element);
if let Err(msg) = src.handle_source_no_more_pads(&element) {
element.post_error_message(&msg);
element.post_error_message(msg);
}
});
}
@ -2314,7 +2314,7 @@ mod custom_source {
element.no_more_pads();
let _ = element.post_message(
&gst::message::StreamsSelected::builder(&collection)
gst::message::StreamsSelected::builder(&collection)
.src(element)
.build(),
);

6
video/flavors/src/flvdemux.rs
View file

@ -325,7 +325,7 @@ impl FlvDemux {
) -> Result<(), gst::LoggableError> {
if active {
self.start(element, mode).map_err(|err| {
element.post_error_message(&err);
element.post_error_message(err);
gst_loggable_error!(CAT, "Failed to start element with mode {:?}", mode)
})?;
@ -340,7 +340,7 @@ impl FlvDemux {
}
self.stop(element).map_err(|err| {
element.post_error_message(&err);
element.post_error_message(err);
gst_loggable_error!(CAT, "Failed to stop element")
})?;
}
@ -532,7 +532,7 @@ impl FlvDemux {
state = self.state.lock().unwrap();
}
Err(err) => {
element.post_error_message(&err);
element.post_error_message(err);
return Err(gst::FlowError::Error);
}
}