Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/sdroege/gst-plugin-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrançois Laignel <fengalin@free.fr>2022-02-21 20:43:46 +0300
committerFrançois Laignel <fengalin@free.fr>2022-02-21 22:50:01 +0300
commit422ea740ca937c3d669b7c961a67a09d9b1baed0 (patch)
treed6b0333340dcb3621a2195d2b92ffb23e402d5b6 /audio/lewton
parent8263e19313df6af6bb9dc59bad94bec0769192fc (diff)
Update to gst::_log_macro_
See the details: https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/980
Diffstat (limited to 'audio/lewton')
-rw-r--r--audio/lewton/src/lewtondec/imp.rs37
1 files changed, 18 insertions, 19 deletions
diff --git a/audio/lewton/src/lewtondec/imp.rs b/audio/lewton/src/lewtondec/imp.rs
index 56e293f5..92abc8b2 100644
--- a/audio/lewton/src/lewtondec/imp.rs
+++ b/audio/lewton/src/lewtondec/imp.rs
@@ -10,7 +10,6 @@
use gst::glib;
use gst::subclass::prelude::*;
-use gst::{gst_debug, gst_error, gst_warning};
use gst_audio::audio_decoder_error;
use gst_audio::prelude::*;
use gst_audio::subclass::prelude::*;
@@ -123,7 +122,7 @@ impl AudioDecoderImpl for LewtonDec {
}
fn set_format(&self, element: &Self::Type, caps: &gst::Caps) -> Result<(), gst::LoggableError> {
- gst_debug!(CAT, obj: element, "Setting format {:?}", caps);
+ gst::debug!(CAT, obj: element, "Setting format {:?}", caps);
// When the caps are changing we require new headers
let mut state_guard = self.state.borrow_mut();
@@ -141,7 +140,7 @@ impl AudioDecoderImpl for LewtonDec {
if let Ok(Some(streamheaders)) = s.get_optional::<gst::ArrayRef>("streamheader") {
let streamheaders = streamheaders.as_slice();
if streamheaders.len() < 3 {
- gst_debug!(
+ gst::debug!(
CAT,
obj: element,
"Not enough streamheaders, trying in-band"
@@ -155,7 +154,7 @@ impl AudioDecoderImpl for LewtonDec {
if let (Ok(Some(ident_buf)), Ok(Some(comment_buf)), Ok(Some(setup_buf))) =
(ident_buf, comment_buf, setup_buf)
{
- gst_debug!(CAT, obj: element, "Got streamheader buffers");
+ gst::debug!(CAT, obj: element, "Got streamheader buffers");
state.header_bufs = (Some(ident_buf), Some(comment_buf), Some(setup_buf));
}
}
@@ -164,7 +163,7 @@ impl AudioDecoderImpl for LewtonDec {
}
fn flush(&self, element: &Self::Type, _hard: bool) {
- gst_debug!(CAT, obj: element, "Flushing");
+ gst::debug!(CAT, obj: element, "Flushing");
let mut state_guard = self.state.borrow_mut();
if let Some(ref mut state) = *state_guard {
@@ -177,7 +176,7 @@ impl AudioDecoderImpl for LewtonDec {
element: &Self::Type,
inbuf: Option<&gst::Buffer>,
) -> Result<gst::FlowSuccess, gst::FlowError> {
- gst_debug!(CAT, obj: element, "Handling buffer {:?}", inbuf);
+ gst::debug!(CAT, obj: element, "Handling buffer {:?}", inbuf);
let inbuf = match inbuf {
None => return Ok(gst::FlowSuccess::Ok),
@@ -185,7 +184,7 @@ impl AudioDecoderImpl for LewtonDec {
};
let inmap = inbuf.map_readable().map_err(|_| {
- gst_error!(CAT, obj: element, "Failed to buffer readable");
+ gst::error!(CAT, obj: element, "Failed to buffer readable");
gst::FlowError::Error
})?;
@@ -199,7 +198,7 @@ impl AudioDecoderImpl for LewtonDec {
if state.headerset.is_some() {
return Ok(gst::FlowSuccess::Ok);
} else {
- gst_error!(CAT, obj: element, "Got empty packet before all headers");
+ gst::error!(CAT, obj: element, "Got empty packet before all headers");
return Err(gst::FlowError::Error);
}
}
@@ -228,26 +227,26 @@ impl LewtonDec {
) -> Result<gst::FlowSuccess, gst::FlowError> {
// ident header
if indata[0] == 0x01 {
- gst_debug!(CAT, obj: element, "Got ident header buffer");
+ gst::debug!(CAT, obj: element, "Got ident header buffer");
state.header_bufs = (Some(inbuf.clone()), None, None);
} else if indata[0] == 0x03 {
// comment header
if state.header_bufs.0.is_none() {
- gst_warning!(CAT, obj: element, "Got comment header before ident header");
+ gst::warning!(CAT, obj: element, "Got comment header before ident header");
} else {
- gst_debug!(CAT, obj: element, "Got comment header buffer");
+ gst::debug!(CAT, obj: element, "Got comment header buffer");
state.header_bufs.1 = Some(inbuf.clone());
}
} else if indata[0] == 0x05 {
// setup header
if state.header_bufs.0.is_none() || state.header_bufs.1.is_none() {
- gst_warning!(
+ gst::warning!(
CAT,
obj: element,
"Got setup header before ident/comment header"
);
} else {
- gst_debug!(CAT, obj: element, "Got setup header buffer");
+ gst::debug!(CAT, obj: element, "Got setup header buffer");
state.header_bufs.2 = Some(inbuf.clone());
}
}
@@ -276,7 +275,7 @@ impl LewtonDec {
// First try to parse the headers
let ident_map = ident_buf.map_readable().map_err(|_| {
- gst_error!(CAT, obj: element, "Failed to map ident buffer readable");
+ gst::error!(CAT, obj: element, "Failed to map ident buffer readable");
gst::FlowError::Error
})?;
let ident = lewton::header::read_header_ident(ident_map.as_ref()).map_err(|err| {
@@ -289,7 +288,7 @@ impl LewtonDec {
})?;
let comment_map = comment_buf.map_readable().map_err(|_| {
- gst_error!(CAT, obj: element, "Failed to map comment buffer readable");
+ gst::error!(CAT, obj: element, "Failed to map comment buffer readable");
gst::FlowError::Error
})?;
let comment = lewton::header::read_header_comment(comment_map.as_ref()).map_err(|err| {
@@ -302,7 +301,7 @@ impl LewtonDec {
})?;
let setup_map = setup_buf.map_readable().map_err(|_| {
- gst_error!(CAT, obj: element, "Failed to map setup buffer readable");
+ gst::error!(CAT, obj: element, "Failed to map setup buffer readable");
gst::FlowError::Error
})?;
let setup = lewton::header::read_header_setup(
@@ -338,7 +337,7 @@ impl LewtonDec {
let mut map = [0; 8];
if gst_audio::channel_reorder_map(from, to, &mut map[..channels]).is_err() {
- gst_error!(
+ gst::error!(
CAT,
obj: element,
"Failed to generate channel reorder map from {:?} to {:?}",
@@ -354,7 +353,7 @@ impl LewtonDec {
}
let audio_info = audio_info.build().unwrap();
- gst_debug!(
+ gst::debug!(
CAT,
obj: element,
"Successfully parsed headers: {:?}",
@@ -410,7 +409,7 @@ impl LewtonDec {
}
let sample_count = decoded.samples.len() / audio_info.channels() as usize;
- gst_debug!(CAT, obj: element, "Got {} decoded samples", sample_count);
+ gst::debug!(CAT, obj: element, "Got {} decoded samples", sample_count);
if sample_count == 0 {
return element.finish_frame(None, 1);