mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-11-25 04:51:26 +00:00
Code Issues Projects Releases Wiki Activity

Fix various new clippy warnings due to MSRV bump

Browse source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1864>
This commit is contained in:
Sebastian Dröge 2024-10-19 14:34:16 +03:00 committed by GStreamer Marge Bot
parent d8a912a952
commit ec8759ae44
15 changed files with 26 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
generic/sodium/src/decrypter/imp.rs
View file

@ -461,7 +461,7 @@ impl Decrypter {
self.sinkpad
.pull_range(pull_offset, total_size)
.map_err(|err| {
.inspect_err(|&err| {
match err {
gst::FlowError::Flushing => {
gst::debug!(
@ -482,8 +482,6 @@ impl Decrypter {
);
}
};
err
})
}

3
generic/sodium/src/encrypter/imp.rs
View file

@ -192,9 +192,8 @@ impl Encrypter {
drop(state_guard);
for buffer in buffers {
self.srcpad.push(buffer).map_err(|err| {
self.srcpad.push(buffer).inspect_err(|&err| {
gst::error!(CAT, imp = self, "Failed to push buffer {:?}", err);
err
})?;
}

3
generic/threadshare/examples/standalone/src/imp.rs
View file

@ -194,9 +194,8 @@ impl TaskImpl for SrcTask {
}
buffer
})
.map_err(|err| {
.inspect_err(|&err| {
gst::error!(CAT, obj = self.elem, "Failed to acquire buffer {err}");
err
})?;
debug_or_trace!(CAT, self.is_main_elem, obj = self.elem, "Forwarding buffer");

4
generic/threadshare/src/runtime/executor/scheduler.rs
View file

@ -218,14 +218,12 @@ impl Scheduler {
tasks_checked = 0;
while tasks_checked < Self::MAX_SUCCESSIVE_TASKS {
if let Ok(runnable) = self.tasks.pop_runnable() {
panic::catch_unwind(|| runnable.run()).map_err(|err| {
panic::catch_unwind(|| runnable.run()).inspect_err(|_err| {
gst::error!(
RUNTIME_CAT,
"A task has panicked within Context {}",
self.context_name
);
err
})?;
tasks_checked += 1;

6
generic/threadshare/src/runtime/pad.rs
View file

@ -224,14 +224,13 @@ impl PadSrcInner {
pub async fn push(&self, buffer: gst::Buffer) -> Result<FlowSuccess, FlowError> {
gst::log!(RUNTIME_CAT, obj = self.gst_pad, "Pushing {:?}", buffer);
let success = self.gst_pad.push(buffer).map_err(|err| {
let success = self.gst_pad.push(buffer).inspect_err(|&err| {
gst::error!(
RUNTIME_CAT,
obj = self.gst_pad,
"Failed to push Buffer to PadSrc: {:?}",
err,
);
err
})?;
gst::log!(
@ -247,14 +246,13 @@ impl PadSrcInner {
pub async fn push_list(&self, list: gst::BufferList) -> Result<FlowSuccess, FlowError> {
gst::log!(RUNTIME_CAT, obj = self.gst_pad, "Pushing {:?}", list);
let success = self.gst_pad.push_list(list).map_err(|err| {
let success = self.gst_pad.push_list(list).inspect_err(|&err| {
gst::error!(
RUNTIME_CAT,
obj = self.gst_pad,
"Failed to push BufferList to PadSrc: {:?}",
err,
);
err
})?;
gst::log!(

6
generic/threadshare/src/runtime/task.rs
View file

@ -1139,16 +1139,14 @@ impl<Item: Send + 'static> StateMachine<Item> {
self.pending_triggering_evt = Some(triggering_evt);
return Ok(());
}
try_next_res = try_next_fut => try_next_res.map_err(|err| {
try_next_res = try_next_fut => try_next_res.inspect_err(|&err| {
gst::debug!(RUNTIME_CAT, "TaskImpl::try_next returned {:?}", err);
err
})?,
}
};
self.task_impl.handle_item(item).await.map_err(|err| {
self.task_impl.handle_item(item).await.inspect_err(|&err| {
gst::debug!(RUNTIME_CAT, "TaskImpl::handle_item returned {:?}", err);
err
})?;
}
}

4
net/hlssink3/src/hlsbasesink.rs
View file

@ -438,15 +438,13 @@ impl HlsBaseSink {
context.old_segment_locations.push(location.to_string());
}
self.write_playlist(context).map(|res| {
self.write_playlist(context).inspect(|_res| {
let s = gst::Structure::builder("hls-segment-added")
.field("location", location)
.field("running-time", running_time.unwrap())
.field("duration", duration)
.build();
self.post_message(gst::message::Element::builder(s).src(&*self.obj()).build());
res
})
}

3
net/rtsp/src/rtspsrc/imp.rs
View file

@ -1085,9 +1085,8 @@ impl RtspSrc {
return Err(RtspError::InvalidMessage("Can't PLAY, no SETUP").into());
};
self.post_start("request", "PLAY request sent");
let cseq = state.play(s).await.map_err(|err| {
let cseq = state.play(s).await.inspect_err(|_err| {
self.post_cancelled("request", "PLAY request cancelled");
err
})?;
expected_response = Some((Method::Play, cseq));
},

3
text/json/src/jsongstparse/imp.rs
View file

@ -274,11 +274,10 @@ impl JsonGstParse {
self.srcpad.push_event(event);
}
self.srcpad.push(buffer).map_err(|err| {
self.srcpad.push(buffer).inspect_err(|&err| {
if err != gst::FlowError::Flushing {
gst::error!(CAT, imp = self, "Pushing buffer returned {:?}", err);
}
err
})?;
if send_eos {

4
utils/fallbackswitch/src/fallbacksrc/imp.rs
View file

@ -768,15 +768,13 @@ impl ElementImpl for FallbackSrc {
_ => (),
}
self.parent_change_state(transition).map_err(|err| {
self.parent_change_state(transition).inspect_err(|_err| {
gst::error!(
CAT,
imp = self,
"Parent state change transition {:?} failed",
transition
);
err
})?;
// Change the source state manually here to be able to catch errors. State changes always

3
video/closedcaption/src/mcc_parse/imp.rs
View file

@ -531,11 +531,10 @@ impl MccParse {
self.srcpad.push_event(event);
}
self.srcpad.push(buffer).map_err(|err| {
self.srcpad.push(buffer).inspect_err(|&err| {
if err != gst::FlowError::Flushing && err != gst::FlowError::Eos {
gst::error!(CAT, imp = self, "Pushing buffer returned {:?}", err);
}
err
})?;
if send_eos {

18
video/closedcaption/src/mcc_parse/parser.rs
View file

@ -291,18 +291,16 @@ impl MccParser {
match self.state {
State::Header => header(&mut line)
.map(|v| {
.inspect(|_v| {
self.state = State::EmptyAfterHeader;
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),
winnow::error::ErrMode::Backtrack(e) | winnow::error::ErrMode::Cut(e) => e,
}),
State::EmptyAfterHeader => empty_line(&mut line)
.map(|v| {
.inspect(|_v| {
self.state = State::Comments;
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),
@ -310,12 +308,10 @@ impl MccParser {
}),
State::Comments => alt((empty_line, comment))
.parse_next(&mut line)
.map(|v| {
if v == MccLine::Empty {
.inspect(|v| {
if *v == MccLine::Empty {
self.state = State::Metadata;
}
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),
@ -323,12 +319,10 @@ impl MccParser {
}),
State::Metadata => alt((empty_line, uuid, time_code_rate, metadata))
.parse_next(&mut line)
.map(|v| {
if v == MccLine::Empty {
.inspect(|v| {
if *v == MccLine::Empty {
self.state = State::Captions;
}
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),

3
video/closedcaption/src/scc_parse/imp.rs
View file

@ -444,11 +444,10 @@ impl SccParse {
self.srcpad.push_event(event);
}
self.srcpad.push_list(buffers).map_err(|err| {
self.srcpad.push_list(buffers).inspect_err(|&err| {
if err != gst::FlowError::Flushing && err != gst::FlowError::Eos {
gst::error!(CAT, imp = self, "Pushing buffer returned {:?}", err);
}
err
})?;
if send_eos {

6
video/closedcaption/src/scc_parse/parser.rs
View file

@ -137,18 +137,16 @@ impl SccParser {
match self.state {
State::Header => header(&mut line)
.map(|v| {
.inspect(|_v| {
self.state = State::Empty;
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),
winnow::error::ErrMode::Backtrack(e) | winnow::error::ErrMode::Cut(e) => e,
}),
State::Empty => empty_line(&mut line)
.map(|v| {
.inspect(|_v| {
self.state = State::CaptionOrEmpty;
v
})
.map_err(|err| match err {
winnow::error::ErrMode::Incomplete(_) => unreachable!(),

8
video/gtk4/src/sink/imp.rs
View file

@ -675,11 +675,11 @@ impl VideoSinkImpl for PaintableSink {
}
}
};
let frame =
Frame::new(buffer, info, orientation, wrapped_context.as_ref()).map_err(|err| {
let frame = Frame::new(buffer, info, orientation, wrapped_context.as_ref()).inspect_err(
|_err| {
gst::error!(CAT, imp = self, "Failed to map video frame");
err
})?;
},
)?;
self.pending_frame.lock().unwrap().replace(frame);
let sender = self.sender.lock().unwrap();