From f0e6959bba888bee26b855d78905f58352c8f927 Mon Sep 17 00:00:00 2001 From: Philippe Normand Date: Sun, 2 Jan 2022 09:38:43 +0000 Subject: [PATCH] webrtcdatachannel: Notify buffered-amount property updates Part-of: --- subprojects/gst-plugins-bad/ext/webrtc/webrtcdatachannel.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/subprojects/gst-plugins-bad/ext/webrtc/webrtcdatachannel.c b/subprojects/gst-plugins-bad/ext/webrtc/webrtcdatachannel.c index e3877f8..9ad73c9 100644 --- a/subprojects/gst-plugins-bad/ext/webrtc/webrtcdatachannel.c +++ b/subprojects/gst-plugins-bad/ext/webrtc/webrtcdatachannel.c @@ -705,6 +705,7 @@ webrtc_data_channel_start_negotiation (WebRTCDataChannel * channel) GST_WEBRTC_DATA_CHANNEL_LOCK (channel); channel->parent.buffered_amount += gst_buffer_get_size (buffer); GST_WEBRTC_DATA_CHANNEL_UNLOCK (channel); + g_object_notify (G_OBJECT (&channel->parent), "buffered-amount"); if (gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer) == GST_FLOW_OK) { @@ -788,6 +789,7 @@ webrtc_data_channel_send_data (GstWebRTCDataChannel * base_channel, GST_WEBRTC_DATA_CHANNEL_LOCK (channel); channel->parent.buffered_amount += gst_buffer_get_size (buffer); GST_WEBRTC_DATA_CHANNEL_UNLOCK (channel); + g_object_notify (G_OBJECT (&channel->parent), "buffered-amount"); ret = gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer); @@ -849,6 +851,7 @@ webrtc_data_channel_send_string (GstWebRTCDataChannel * base_channel, GST_WEBRTC_DATA_CHANNEL_LOCK (channel); channel->parent.buffered_amount += gst_buffer_get_size (buffer); GST_WEBRTC_DATA_CHANNEL_UNLOCK (channel); + g_object_notify (G_OBJECT (&channel->parent), "buffered-amount"); ret = gst_app_src_push_buffer (GST_APP_SRC (channel->appsrc), buffer); @@ -927,6 +930,7 @@ on_appsrc_data (GstPad * pad, GstPadProbeInfo * info, gpointer user_data) NULL); } GST_WEBRTC_DATA_CHANNEL_UNLOCK (channel); + g_object_notify (G_OBJECT (&channel->parent), "buffered-amount"); } return GST_PAD_PROBE_OK; -- 2.7.4