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-01-25 10:28:09 +00:00
Code Issues Projects Releases Wiki Activity

rtpav1: Remove some unneeded lifetime annotations

Browse source
This commit is contained in:
Sebastian Dröge 2022-09-12 17:49:51 +03:00
parent 8d73b5008a
commit f9a8e121e1
2 changed files with 7 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
net/rtpav1/src/depay/imp.rs
View file

@ -21,7 +21,7 @@ use gst_rtp::{
use std::{ use std::{
cmp::Ordering, cmp::Ordering,
io::{Cursor, Read, Seek, SeekFrom}, io::{Cursor, Read, Seek, SeekFrom},
sync::{Mutex, MutexGuard}, sync::Mutex,
}; };
use bitstream_io::{BitReader, BitWriter}; use bitstream_io::{BitReader, BitWriter};
@ -62,14 +62,10 @@ static CAT: Lazy<DebugCategory> = Lazy::new(|| {
static TEMPORAL_DELIMITER: Lazy<Memory> = Lazy::new(|| Memory::from_slice(&[0b0001_0010, 0])); static TEMPORAL_DELIMITER: Lazy<Memory> = Lazy::new(|| Memory::from_slice(&[0b0001_0010, 0]));
impl RTPAv1Depay { impl RTPAv1Depay {
fn reset<'s>( fn reset(&self, element: &<Self as ObjectSubclass>::Type, state: &mut State) {
&'s self,
element: &<Self as ObjectSubclass>::Type,
state: &mut MutexGuard<'s, State>,
) {
gst::debug!(CAT, obj: element, "resetting state"); gst::debug!(CAT, obj: element, "resetting state");
**state = State::default() *state = State::default()
} }
} }

12
net/rtpav1/src/pay/imp.rs
View file

@ -101,11 +101,7 @@ impl Default for State {
} }
impl RTPAv1Pay { impl RTPAv1Pay {
fn reset<'s>( fn reset(&self, element: &<Self as ObjectSubclass>::Type, state: &mut State) {
&'s self,
element: &<Self as ObjectSubclass>::Type,
state: &mut MutexGuard<'s, State>,
) {
gst::debug!(CAT, obj: element, "resetting state"); gst::debug!(CAT, obj: element, "resetting state");
state.obus.clear(); state.obus.clear();
@ -205,10 +201,10 @@ impl RTPAv1Pay {
/// ///
/// If `true` is passed for `force`, packets of any size will be accepted, /// If `true` is passed for `force`, packets of any size will be accepted,
/// which is used in flushing the last OBUs after receiving an EOS for example. /// which is used in flushing the last OBUs after receiving an EOS for example.
fn consider_new_packet<'s>( fn consider_new_packet(
&'s self, &self,
element: &<Self as ObjectSubclass>::Type, element: &<Self as ObjectSubclass>::Type,
state: &mut MutexGuard<'s, State>, state: &mut State,
force: bool, force: bool,
) -> Option<PacketOBUData> { ) -> Option<PacketOBUData> {
gst::trace!( gst::trace!(