aboutsummaryrefslogtreecommitdiff
path: root/plugins/rtp
diff options
context:
space:
mode:
authorMarvin W <git@larma.de>2021-12-18 21:47:50 +0100
committerMarvin W <git@larma.de>2021-12-18 21:47:50 +0100
commitb07c4187ef40295c17cc09fea6dc5ba4137fd73b (patch)
tree909bc35605c0929a719d51d956586f6eb2a1c54e /plugins/rtp
parent9aeff4bf9e00624187931c0d358c166f5a6860a1 (diff)
downloaddino-b07c4187ef40295c17cc09fea6dc5ba4137fd73b.tar.gz
dino-b07c4187ef40295c17cc09fea6dc5ba4137fd73b.zip
RTP: Less log spam
Diffstat (limited to 'plugins/rtp')
-rw-r--r--plugins/rtp/src/device.vala40
-rw-r--r--plugins/rtp/src/plugin.vala8
-rw-r--r--plugins/rtp/src/stream.vala40
3 files changed, 0 insertions, 88 deletions
diff --git a/plugins/rtp/src/device.vala b/plugins/rtp/src/device.vala
index de46bea4..368356ae 100644
--- a/plugins/rtp/src/device.vala
+++ b/plugins/rtp/src/device.vala
@@ -384,45 +384,6 @@ public class Dino.Plugins.Rtp.Device : MediaDevice, Object {
return target;
}
- private static Gst.PadProbeReturn log_probe(Gst.Pad pad, Gst.PadProbeInfo info) {
- if ((info.type & Gst.PadProbeType.EVENT_DOWNSTREAM) > 0) {
- debug("%s.%s probed downstream event %s", pad.get_parent_element().name, pad.name, info.get_event().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.EVENT_UPSTREAM) > 0) {
- var event = info.get_event();
- if (event.type == Gst.EventType.RECONFIGURE) return Gst.PadProbeReturn.DROP;
- if (event.type == Gst.EventType.QOS) {
- Gst.QOSType qos_type;
- double proportion;
- Gst.ClockTimeDiff diff;
- Gst.ClockTime timestamp;
- event.parse_qos(out qos_type, out proportion, out diff, out timestamp);
- debug("%s.%s probed qos event: type: %s, proportion: %f, diff: %lli, timestamp: %llu", pad.get_parent_element().name, pad.name, @"$qos_type", proportion, diff, timestamp);
- } else {
- debug("%s.%s probed upstream event %s", pad.get_parent_element().name, pad.name, event.type.get_name());
- }
- }
- if ((info.type & Gst.PadProbeType.QUERY_DOWNSTREAM) > 0) {
- debug("%s.%s probed downstream query %s", pad.get_parent_element().name, pad.name, info.get_query().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.QUERY_UPSTREAM) > 0) {
- debug("%s.%s probed upstream query %s", pad.get_parent_element().name, pad.name, info.get_query().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.BUFFER) > 0) {
- uint id = pad.get_data("no_buffer_probe_timeout");
- if (id != 0) {
- Source.remove(id);
- }
- string name = @"$(pad.get_parent_element().name).$(pad.name)";
- id = Timeout.add_seconds(1, () => {
- debug("%s probed no buffer for 1 second", name);
- return Source.REMOVE;
- });
- pad.set_data("no_buffer_probe_timeout", id);
- }
- return Gst.PadProbeReturn.PASS;
- }
-
private void create() {
debug("Creating device %s", id);
plugin.pause();
@@ -437,7 +398,6 @@ public class Dino.Plugins.Rtp.Device : MediaDevice, Object {
element.@set("do-timestamp", true);
filter = Gst.ElementFactory.make("capsfilter", @"caps_filter_$id");
filter.@set("caps", device_caps);
- filter.get_static_pad("src").add_probe(Gst.PadProbeType.BLOCK, log_probe);
pipe.add(filter);
element.link(filter);
#if WITH_VOICE_PROCESSOR
diff --git a/plugins/rtp/src/plugin.vala b/plugins/rtp/src/plugin.vala
index d10303a6..6d6da79a 100644
--- a/plugins/rtp/src/plugin.vala
+++ b/plugins/rtp/src/plugin.vala
@@ -155,14 +155,6 @@ public class Dino.Plugins.Rtp.Plugin : RootInterface, VideoCallPlugin, Object {
break;
case Gst.MessageType.STATE_CHANGED:
// Ignore
- {
- unowned Gst.Structure struc = message.get_structure();
- if (struc != null && message.src is Gst.Element) {
- Gst.State oldState, newState, pendingState;
- message.parse_state_changed(out oldState, out newState, out pendingState);
- debug("State of %s changed. Old: %s, New: %s, Pending; %s", ((Gst.Element)message.src).name, @"$oldState", @"$newState", @"$pendingState");
- }
- }
break;
case Gst.MessageType.STREAM_STATUS:
Gst.StreamStatusType status;
diff --git a/plugins/rtp/src/stream.vala b/plugins/rtp/src/stream.vala
index 2c8b6356..385a590c 100644
--- a/plugins/rtp/src/stream.vala
+++ b/plugins/rtp/src/stream.vala
@@ -81,45 +81,6 @@ public class Dino.Plugins.Rtp.Stream : Xmpp.Xep.JingleRtp.Stream {
}
}
- private static Gst.PadProbeReturn log_probe(Gst.Pad pad, Gst.PadProbeInfo info) {
- if ((info.type & Gst.PadProbeType.EVENT_DOWNSTREAM) > 0) {
- debug("%s.%s probed downstream event %s", pad.get_parent_element().name, pad.name, info.get_event().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.EVENT_UPSTREAM) > 0) {
- var event = info.get_event();
- if (event.type == Gst.EventType.RECONFIGURE) return Gst.PadProbeReturn.DROP;
- if (event.type == Gst.EventType.QOS) {
- Gst.QOSType qos_type;
- double proportion;
- Gst.ClockTimeDiff diff;
- Gst.ClockTime timestamp;
- event.parse_qos(out qos_type, out proportion, out diff, out timestamp);
- debug("%s.%s probed qos event: type: %s, proportion: %f, diff: %lli, timestamp: %llu", pad.get_parent_element().name, pad.name, @"$qos_type", proportion, diff, timestamp);
- } else {
- debug("%s.%s probed upstream event %s", pad.get_parent_element().name, pad.name, event.type.get_name());
- }
- }
- if ((info.type & Gst.PadProbeType.QUERY_DOWNSTREAM) > 0) {
- debug("%s.%s probed downstream query %s", pad.get_parent_element().name, pad.name, info.get_query().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.QUERY_UPSTREAM) > 0) {
- debug("%s.%s probed upstream query %s", pad.get_parent_element().name, pad.name, info.get_query().type.get_name());
- }
- if ((info.type & Gst.PadProbeType.BUFFER) > 0) {
- uint id = pad.steal_data("no_buffer_probe_timeout");
- if (id != 0) {
- Source.remove(id);
- }
- string name = @"$(pad.get_parent_element().name).$(pad.name)";
- id = Timeout.add_seconds(1, () => {
- debug("%s probed no buffer for 1 second", name);
- return Source.REMOVE;
- });
- pad.set_data("no_buffer_probe_timeout", id);
- }
- return Gst.PadProbeReturn.PASS;
- }
-
public override void create() {
plugin.pause();
@@ -160,7 +121,6 @@ public class Dino.Plugins.Rtp.Stream : Xmpp.Xep.JingleRtp.Stream {
recv_rtp.do_timestamp = true;
recv_rtp.format = Gst.Format.TIME;
recv_rtp.is_live = true;
- recv_rtp.get_static_pad("src").add_probe(Gst.PadProbeType.BLOCK, log_probe);
pipe.add(recv_rtp);
recv_rtcp = Gst.ElementFactory.make("appsrc", @"rtcp_src_$rtpid") as Gst.App.Src;