diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2022-10-23 23:03:22 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2022-10-23 23:08:46 +0300 |
commit | 9a68f6e221576f94e153f5f20e499b22745621ec (patch) | |
tree | 776a587d54578bc7dff1fe432bf3008308bffb79 /net/raptorq | |
parent | 86776be58c5d7e8607653edcd719ac1f0ba8d992 (diff) |
Move from `imp.instance()` to `imp.obj()`
It's doing the same thing and is shorter.
Diffstat (limited to 'net/raptorq')
-rw-r--r-- | net/raptorq/src/raptorqdec/imp.rs | 10 | ||||
-rw-r--r-- | net/raptorq/src/raptorqenc/imp.rs | 10 |
2 files changed, 10 insertions, 10 deletions
diff --git a/net/raptorq/src/raptorqdec/imp.rs b/net/raptorq/src/raptorqdec/imp.rs index 84e682f1..2118f012 100644 --- a/net/raptorq/src/raptorqdec/imp.rs +++ b/net/raptorq/src/raptorqdec/imp.rs @@ -497,7 +497,7 @@ impl RaptorqDec { self.reset(); } - gst::Pad::event_default(pad, Some(&*self.instance()), event) + gst::Pad::event_default(pad, Some(&*self.obj()), event) } fn fec_sink_event(&self, pad: &gst::Pad, event: gst::Event) -> bool { @@ -516,7 +516,7 @@ impl RaptorqDec { } } - gst::Pad::event_default(pad, Some(&*self.instance()), event) + gst::Pad::event_default(pad, Some(&*self.obj()), event) } fn iterate_internal_links(&self, pad: &gst::Pad) -> gst::Iterator<gst::Pad> { @@ -719,7 +719,7 @@ impl ObjectImpl for RaptorqDec { fn constructed(&self) { self.parent_constructed(); - let obj = self.instance(); + let obj = self.obj(); obj.add_pad(&self.sinkpad).unwrap(); obj.add_pad(&self.srcpad).unwrap(); } @@ -850,7 +850,7 @@ impl ElementImpl for RaptorqDec { drop(sinkpad_fec_guard); - self.instance().add_pad(&sinkpad_fec).unwrap(); + self.obj().add_pad(&sinkpad_fec).unwrap(); Some(sinkpad_fec) } @@ -861,7 +861,7 @@ impl ElementImpl for RaptorqDec { if let Some(pad) = pad_guard.take() { drop(pad_guard); pad.set_active(false).unwrap(); - self.instance().remove_pad(&pad).unwrap(); + self.obj().remove_pad(&pad).unwrap(); } } } diff --git a/net/raptorq/src/raptorqenc/imp.rs b/net/raptorq/src/raptorqenc/imp.rs index f1bf9e8f..85faad78 100644 --- a/net/raptorq/src/raptorqenc/imp.rs +++ b/net/raptorq/src/raptorqenc/imp.rs @@ -180,7 +180,7 @@ impl RaptorqEnc { .map(|n| ((n * delay_step) as u64).mseconds()) .collect::<Vec<_>>(); - let base_time = self.instance().base_time(); + let base_time = self.obj().base_time(); let running_time = state.segment.to_running_time(now_pts); for (target_time, repair_packet) in Iterator::zip( @@ -313,7 +313,7 @@ impl RaptorqEnc { } }; - let clock = match self_.instance().clock() { + let clock = match self_.obj().clock() { Some(clock) => clock, None => { // No clock provided, push buffer immediately @@ -505,7 +505,7 @@ impl RaptorqEnc { // Push stream events on FEC srcpad as well let stream_id = self .srcpad_fec - .create_stream_id(&*self.instance(), Some("fec")) + .create_stream_id(&*self.obj(), Some("fec")) .to_string(); let kmax = extended_source_block_symbols(state.symbols_per_block as u32); @@ -543,7 +543,7 @@ impl RaptorqEnc { _ => (), } - gst::Pad::event_default(pad, Some(&*self.instance()), event) + gst::Pad::event_default(pad, Some(&*self.obj()), event) } fn iterate_internal_links(&self, pad: &gst::Pad) -> gst::Iterator<gst::Pad> { @@ -846,7 +846,7 @@ impl ObjectImpl for RaptorqEnc { fn constructed(&self) { self.parent_constructed(); - let obj = self.instance(); + let obj = self.obj(); obj.add_pad(&self.sinkpad).unwrap(); obj.add_pad(&self.srcpad).unwrap(); obj.add_pad(&self.srcpad_fec).unwrap(); |