diff options
| author | François Laignel <fengalin@free.fr> | 2022-10-23 21:46:18 +0300 |
|---|---|---|
| committer | François Laignel <fengalin@free.fr> | 2022-10-23 22:22:31 +0300 |
| commit | 86776be58c5d7e8607653edcd719ac1f0ba8d992 (patch) | |
| tree | 64deeda8be7e7b4850157a1e306425f1ce8f965d /generic/threadshare/src/jitterbuffer | |
| parent | fe8e0a8bf8cdb67d913318f63b621370c45aedda (diff) | |
Remove `&` for `obj` in log macros
This is no longer necessary.
See https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1137
Diffstat (limited to 'generic/threadshare/src/jitterbuffer')
| -rw-r--r-- | generic/threadshare/src/jitterbuffer/imp.rs | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/generic/threadshare/src/jitterbuffer/imp.rs b/generic/threadshare/src/jitterbuffer/imp.rs index b736aa98d..5614aae92 100644 --- a/generic/threadshare/src/jitterbuffer/imp.rs +++ b/generic/threadshare/src/jitterbuffer/imp.rs @@ -1033,7 +1033,7 @@ impl TaskImpl for JitterBufferTask { fn start(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { async move { - gst::log!(CAT, obj: &self.element, "Starting task"); + gst::log!(CAT, obj: self.element, "Starting task"); self.src_pad_handler.clear(); self.sink_pad_handler.clear(); @@ -1046,7 +1046,7 @@ impl TaskImpl for JitterBufferTask { state.jbuf.set_delay(latency); *jb.state.lock().unwrap() = state; - gst::log!(CAT, obj: &self.element, "Task started"); + gst::log!(CAT, obj: self.element, "Task started"); Ok(()) } .boxed() @@ -1106,9 +1106,9 @@ impl TaskImpl for JitterBufferTask { // Got aborted, reschedule if needed if let Some(delay_fut) = delay_fut { - gst::debug!(CAT, obj: &self.element, "Waiting"); + gst::debug!(CAT, obj: self.element, "Waiting"); if let Err(Aborted) = delay_fut.await { - gst::debug!(CAT, obj: &self.element, "Waiting aborted"); + gst::debug!(CAT, obj: self.element, "Waiting aborted"); return Ok(()); } } @@ -1126,7 +1126,7 @@ impl TaskImpl for JitterBufferTask { gst::debug!( CAT, - obj: &self.element, + obj: self.element, "Woke up at {}, earliest_pts {}", now.display(), state.earliest_pts.display() @@ -1182,13 +1182,13 @@ impl TaskImpl for JitterBufferTask { if let Err(err) = res { match err { gst::FlowError::Eos => { - gst::debug!(CAT, obj: &self.element, "Pushing EOS event"); + gst::debug!(CAT, obj: self.element, "Pushing EOS event"); let _ = jb.src_pad.push_event(gst::event::Eos::new()).await; } gst::FlowError::Flushing => { - gst::debug!(CAT, obj: &self.element, "Flushing") + gst::debug!(CAT, obj: self.element, "Flushing") } - err => gst::error!(CAT, obj: &self.element, "Error {}", err), + err => gst::error!(CAT, obj: self.element, "Error {}", err), } return Err(err); @@ -1204,7 +1204,7 @@ impl TaskImpl for JitterBufferTask { fn stop(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { async move { - gst::log!(CAT, obj: &self.element, "Stopping task"); + gst::log!(CAT, obj: self.element, "Stopping task"); let jb = self.element.imp(); let mut jb_state = jb.state.lock().unwrap(); @@ -1218,7 +1218,7 @@ impl TaskImpl for JitterBufferTask { *jb_state = State::default(); - gst::log!(CAT, obj: &self.element, "Task stopped"); + gst::log!(CAT, obj: self.element, "Task stopped"); Ok(()) } .boxed() |