diff options
author | François Laignel <fengalin@free.fr> | 2022-02-21 20:43:46 +0300 |
---|---|---|
committer | François Laignel <fengalin@free.fr> | 2022-02-21 22:50:01 +0300 |
commit | 422ea740ca937c3d669b7c961a67a09d9b1baed0 (patch) | |
tree | d6b0333340dcb3621a2195d2b92ffb23e402d5b6 /audio/spotify/src | |
parent | 8263e19313df6af6bb9dc59bad94bec0769192fc (diff) |
Update to gst::_log_macro_
See the details:
https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/980
Diffstat (limited to 'audio/spotify/src')
-rw-r--r-- | audio/spotify/src/spotifyaudiosrc/imp.rs | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/audio/spotify/src/spotifyaudiosrc/imp.rs b/audio/spotify/src/spotifyaudiosrc/imp.rs index 1d55f936..caadd381 100644 --- a/audio/spotify/src/spotifyaudiosrc/imp.rs +++ b/audio/spotify/src/spotifyaudiosrc/imp.rs @@ -15,7 +15,6 @@ use tokio::{runtime, task::JoinHandle}; use gst::glib; use gst::prelude::*; use gst::subclass::prelude::*; -use gst::{gst_debug, gst_error, gst_log}; use gst_base::subclass::{base_src::CreateSuccess, prelude::*}; use librespot::core::{ @@ -250,7 +249,7 @@ impl BaseSrcImpl for SpotifyAudioSrc { if let Err(err) = RUNTIME.block_on(async move { self.setup().await }) { let details = format!("{:?}", err); - gst_error!(CAT, obj: src, "failed to start: {}", details); + gst::error!(CAT, obj: src, "failed to start: {}", details); gst::element_error!(src, gst::ResourceError::Settings, [&details]); return Err(gst::error_msg!(gst::ResourceError::Settings, [&details])); } @@ -260,7 +259,7 @@ impl BaseSrcImpl for SpotifyAudioSrc { fn stop(&self, src: &Self::Type) -> Result<(), gst::ErrorMessage> { if let Some(state) = self.state.lock().unwrap().take() { - gst_debug!(CAT, obj: src, "stopping"); + gst::debug!(CAT, obj: src, "stopping"); state.player.stop(); state.player_channel_handle.abort(); // FIXME: not sure why this is needed to unblock BufferSink::write(), dropping State should drop the receiver @@ -282,15 +281,15 @@ impl BaseSrcImpl for SpotifyAudioSrc { match state.receiver.recv().unwrap() { Message::Buffer(buffer) => { - gst_log!(CAT, obj: src, "got buffer of size {}", buffer.size()); + gst::log!(CAT, obj: src, "got buffer of size {}", buffer.size()); Ok(CreateSuccess::NewBuffer(buffer)) } Message::Eos => { - gst_debug!(CAT, obj: src, "eos"); + gst::debug!(CAT, obj: src, "eos"); Err(gst::FlowError::Eos) } Message::Unavailable => { - gst_error!(CAT, obj: src, "track is not available"); + gst::error!(CAT, obj: src, "track is not available"); gst::element_error!( src, gst::ResourceError::NotFound, @@ -331,11 +330,11 @@ impl SpotifyAudioSrc { let credentials = match cache.credentials() { Some(cached_cred) => { - gst_debug!(CAT, obj: &src, "reuse credentials from cache",); + gst::debug!(CAT, obj: &src, "reuse credentials from cache",); cached_cred } None => { - gst_debug!(CAT, obj: &src, "credentials not in cache",); + gst::debug!(CAT, obj: &src, "credentials not in cache",); if settings.username.is_empty() { bail!("username is not set and credentials are not in cache"); |