mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-01 21:18:52 +00:00
Code Issues 1 Projects Releases Wiki Activity

validate-pad-monitor: Post GstBaseSink SEGMENT on the bus

Browse source 
Allows higher-level bin or app (like validate-scenario) to know
what each sink currently has in terms of SEGMENT.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-devtools/-/merge_requests/174>
This commit is contained in:
Edward Hervey 2018-06-05 17:55:29 +02:00 committed by Thibault Saunier
parent 854826501c
commit e05d4ac8f5
1 changed files with 41 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
validate/gst/validate/gst-validate-pad-monitor.c
View file

@ -82,6 +82,12 @@ G_DEFINE_TYPE_WITH_CODE (GstValidatePadMonitor, gst_validate_pad_monitor,
GST_VALIDATE_MONITOR_GET_PARENT(m)) : \ GST_VALIDATE_MONITOR_GET_PARENT(m)) : \
FALSE) FALSE)
#define PAD_PARENT_IS_SINK(m) \
(GST_VALIDATE_MONITOR_GET_PARENT(m) ? \
GST_VALIDATE_ELEMENT_MONITOR_ELEMENT_IS_SINK ( \
GST_VALIDATE_MONITOR_GET_PARENT(m)) : \
FALSE)
/* /*
* Locking the parent should always be done before locking the * Locking the parent should always be done before locking the
@ -1895,6 +1901,39 @@ gst_validate_monitor_find_next_buffer (GstValidatePadMonitor * pad_monitor)
pad_monitor->current_buf = tmp; pad_monitor->current_buf = tmp;
} }
static void
post_segment_message (GstValidatePadMonitor * pad_monitor, GstPad * pad,
const GstSegment * segment, guint32 seqnum)
{
GstValidateMonitor *element_monitor =
GST_VALIDATE_MONITOR_GET_PARENT (pad_monitor);
GstElement *element;
GstStructure *structure;
GstMessage *msg;
if (element_monitor == NULL)
return;
element = gst_validate_monitor_get_element (element_monitor);
if (element == NULL)
return;
GST_DEBUG_OBJECT (pad,
"Posting application message for seqnum:%" G_GUINT32_FORMAT " %"
GST_SEGMENT_FORMAT, seqnum, segment);
structure =
gst_structure_new ("validate-segment", "segment", GST_TYPE_SEGMENT,
segment, NULL);
msg = gst_message_new_application ((GstObject *) element, structure);
gst_message_set_seqnum (msg, seqnum);
gst_element_post_message (element, msg);
gst_object_unref (element);
return;
}
/* Checks whether a segment is just an update of another, /* Checks whether a segment is just an update of another,
* That is to say that only the base and offset field differ and all * That is to say that only the base and offset field differ and all
* other fields are identical */ * other fields are identical */
@ -2091,6 +2130,8 @@ gst_validate_pad_monitor_downstream_event_check (GstValidatePadMonitor *
gst_segment_copy_into (segment, &pad_monitor->segment); gst_segment_copy_into (segment, &pad_monitor->segment);
pad_monitor->has_segment = TRUE; pad_monitor->has_segment = TRUE;
gst_validate_monitor_find_next_buffer (pad_monitor); gst_validate_monitor_find_next_buffer (pad_monitor);
if (PAD_PARENT_IS_SINK (pad_monitor))
post_segment_message (pad_monitor, pad, segment, seqnum);
} }
break; break;
case GST_EVENT_CAPS:{ case GST_EVENT_CAPS:{