From a3fd3ad4d7044f99c224fbdf6164d8f00041172a Mon Sep 17 00:00:00 2001
From: Seungha Yang <seungha@centricular.com>
Date: Wed, 12 Apr 2023 02:46:15 +0900
Subject: [PATCH] cea608mux: Implement GstAggregator::clip

Drop buffers if it's outside of segment

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/4398>
---
 .../ext/closedcaption/gstcea608mux.c          | 22 +++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git a/subprojects/gst-plugins-bad/ext/closedcaption/gstcea608mux.c b/subprojects/gst-plugins-bad/ext/closedcaption/gstcea608mux.c
index 368e7b82a0..b65060cecc 100644
--- a/subprojects/gst-plugins-bad/ext/closedcaption/gstcea608mux.c
+++ b/subprojects/gst-plugins-bad/ext/closedcaption/gstcea608mux.c
@@ -380,6 +380,27 @@ gst_cea608_mux_negotiated_src_caps (GstAggregator * agg, GstCaps * caps)
   return TRUE;
 }
 
+static GstBuffer *
+gst_cea608_mux_clip (GstAggregator * aggregator, GstAggregatorPad * pad,
+    GstBuffer * buffer)
+{
+  GstClockTime time;
+
+  if (!GST_BUFFER_PTS_IS_VALID (buffer))
+    return buffer;
+
+  time = gst_segment_to_running_time (&pad->segment, GST_FORMAT_TIME,
+      GST_BUFFER_PTS (buffer));
+  if (!GST_CLOCK_TIME_IS_VALID (time)) {
+    GST_DEBUG_OBJECT (pad, "Dropping buffer on pad outside segment %"
+        GST_TIME_FORMAT, GST_TIME_ARGS (GST_BUFFER_PTS (buffer)));
+    gst_buffer_unref (buffer);
+    return NULL;
+  }
+
+  return buffer;
+}
+
 static void
 gst_cea608_mux_class_init (GstCea608MuxClass * klass)
 {
@@ -411,6 +432,7 @@ gst_cea608_mux_class_init (GstCea608MuxClass * klass)
   aggregator_class->flush = gst_cea608_mux_flush;
   aggregator_class->negotiated_src_caps = gst_cea608_mux_negotiated_src_caps;
   aggregator_class->get_next_time = gst_aggregator_simple_get_next_time;
+  aggregator_class->clip = gst_cea608_mux_clip;
 
   GST_DEBUG_CATEGORY_INIT (gst_cea608_mux_debug, "cea608mux",
       0, "Closed Caption muxer");