mirrors/gstreamer-rs
mirrors/gstreamer-rs
1
1
Fork 1
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git synced 2024-11-29 13:01:05 +00:00
Code Issues Projects Releases Wiki Activity

utils/streamproducer: Improve debug output a bit

Browse source
This commit is contained in:
Sebastian Dröge 2022-05-12 10:37:14 +03:00
parent e82d388410
commit d6095900e9
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
gstreamer-utils/src/streamproducer.rs
View file

@ -57,11 +57,11 @@ impl StreamProducer {
pub fn add_consumer(&self, consumer: &gst_app::AppSrc) { pub fn add_consumer(&self, consumer: &gst_app::AppSrc) {
let mut consumers = self.consumers.lock().unwrap(); let mut consumers = self.consumers.lock().unwrap();
if consumers.consumers.contains_key(consumer) { if consumers.consumers.contains_key(consumer) {
gst::error!(CAT, obj: &self.appsink, "Consumer already added"); gst::error!(CAT, obj: &self.appsink, "Consumer {} ({:?}) already added", consumer.name(), consumer);
return; return;
} }
gst::debug!(CAT, obj: &self.appsink, "Adding consumer"); gst::debug!(CAT, obj: &self.appsink, "Adding consumer {} ({:?})", consumer.name(), consumer);
Self::configure_consumer(consumer); Self::configure_consumer(consumer);
@ -101,9 +101,9 @@ impl StreamProducer {
.remove(consumer) .remove(consumer)
.is_some() .is_some()
{ {
gst::debug!(CAT, obj: &self.appsink, "Removed consumer {}", name); gst::debug!(CAT, obj: &self.appsink, "Removed consumer {} ({:?})", name, consumer);
} else { } else {
gst::debug!(CAT, obj: &self.appsink, "Consumer {} not found", name); gst::debug!(CAT, obj: &self.appsink, "Consumer {} ({:?}) not found", name, consumer);
} }
} }
@ -299,7 +299,9 @@ impl StreamConsumer {
gst::debug!( gst::debug!(
CAT, CAT,
obj: appsrc, obj: appsrc,
"consumer is not consuming fast enough, old samples are getting dropped", "consumer {} ({:?}) is not consuming fast enough, old samples are getting dropped",
appsrc.name(),
appsrc,
); );
}) })
.build(), .build(),