diff options
| author | Sebastian Dröge <sebastian@centricular.com> | 2022-01-17 21:09:18 +0300 |
|---|---|---|
| committer | Sebastian Dröge <sebastian@centricular.com> | 2022-01-18 16:48:34 +0300 |
| commit | 07a7420561659b1d8f3a308fb6941b6369fa1f3e (patch) | |
| tree | b7760990daa3fc51d08924ad0c16f1d9371c2894 /utils | |
| parent | 81a571bd8bc8933ae9d16f1aac5d20dab2aa90bd (diff) | |
Rename `self_` variables to `imp` for consistency
Diffstat (limited to 'utils')
| -rw-r--r-- | utils/uriplaylistbin/src/uriplaylistbin/imp.rs | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs index 05a12e73c..e4f4091e3 100644 --- a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs +++ b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs @@ -840,8 +840,8 @@ impl BinImpl for UriPlaylistBin { } gst::MessageView::Error(error) => { // find item which raised the error - let self_ = element.imp(); - let mut state_guard = self_.state.lock().unwrap(); + let imp = element.imp(); + let mut state_guard = imp.state.lock().unwrap(); let state = state_guard.as_mut().unwrap(); let src = error.src().unwrap(); @@ -1050,10 +1050,10 @@ impl UriPlaylistBin { Some(element) => element, None => return, }; - let self_ = element.imp(); + let imp = element.imp(); let item = { - let mut state_guard = self_.state.lock().unwrap(); + let mut state_guard = imp.state.lock().unwrap(); let state = state_guard.as_mut().unwrap(); state.waiting_for_ss_eos.as_ref().cloned() }; @@ -1092,7 +1092,7 @@ impl UriPlaylistBin { item.add_blocked_pad(src_pad.clone()); } else { - self_.process_decodebin_pad(src_pad); + imp.process_decodebin_pad(src_pad); } }); @@ -1289,10 +1289,10 @@ impl UriPlaylistBin { Some(element) => element, None => return gst::PadProbeReturn::Remove, }; - let self_ = element.imp(); + let imp = element.imp(); let item = { - let mut state_guard = self_.state.lock().unwrap(); + let mut state_guard = imp.state.lock().unwrap(); let state = state_guard.as_mut().unwrap(); state.waiting_for_ss_eos.as_ref().cloned() }; @@ -1300,7 +1300,7 @@ impl UriPlaylistBin { if let Some(item) = item { if item.dec_waiting_eos_ss() { gst_debug!(CAT, obj: &element, "streamsynchronizer has been flushed, reorganize pipeline to fit new streams topology and unblock item"); - self_.handle_topology_change(&element); + imp.handle_topology_change(&element); gst::PadProbeReturn::Drop } else { gst::PadProbeReturn::Drop @@ -1427,9 +1427,9 @@ impl UriPlaylistBin { item.index() ); - let self_ = element.imp(); + let imp = element.imp(); { - let mut state_guard = self_.state.lock().unwrap(); + let mut state_guard = imp.state.lock().unwrap(); let state = state_guard.as_mut().unwrap(); let index = item.index(); @@ -1446,8 +1446,8 @@ impl UriPlaylistBin { } } - if let Err(e) = self_.start_next_item(&element) { - self_.failed(&element, e); + if let Err(e) = imp.start_next_item(&element) { + imp.failed(&element, e); } } |