WIP queue2request-configuration

2 files changed, 21 insertions, 0 deletions

diff --git a/plugins/elements/gstqueue2.c b/plugins/elements/gstqueue2.c
index 53896818c..aa07868cc 100644
--- a/plugins/elements/gstqueue2.c
+++ b/plugins/elements/gstqueue2.c
@@ -2280,6 +2280,25 @@ gst_queue2_handle_sink_event (GstPad * pad, GstObject * parent,
       }
       break;
     }
+    case GST_EVENT_REQUEST_CONFIGURATION:{
+      const GstStructure *s = gst_event_get_structure (event);
+
+      if (gst_structure_has_name (s, "GstEventRequestConfiguration-buffering")) {
+        GST_QUEUE2_MUTEX_LOCK (queue);
+        if (queue->use_buffering) {
+          GstFormat format;
+          gint64 value;
+
+          if (gst_structure_get_enum (s, "format", GST_TYPE_FORMAT, &format) &&
+              gst_structure_get_int64 (s, "value", G_TYPE_INT64, &value)) {
+
+          }
+        }
+        GST_QUEUE2_MUTEX_UNLOCK (queue);
+        break;
+      }
+      /* fall through */
+    }
     default:
       if (GST_EVENT_IS_SERIALIZED (event)) {
         /* serialized events go in the queue */
diff --git a/plugins/elements/gstqueue2.h b/plugins/elements/gstqueue2.h
index 3fe5fc45d..45f53177c 100644
--- a/plugins/elements/gstqueue2.h
+++ b/plugins/elements/gstqueue2.h
@@ -108,6 +108,8 @@ struct _GstQueue2
   gint low_percent;             /* low/high watermarks for buffering */
   gint high_percent;
 
+  GstQueue2Size buffering_level; /* amount of buffering as requested by upstream */
+
   /* current buffering state */
   gboolean is_buffering;
   gint buffering_percent;