mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-30 13:41:48 +00:00
Code Issues 1 Projects Releases Wiki Activity

segmentclip: port to 0.11

Browse source
This commit is contained in:
Mark Nauwelaerts 2012-03-18 18:32:46 +01:00
parent 0abb7fb3f4
commit b12ac89da0
4 changed files with 137 additions and 185 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
configure.ac
View file

@ -307,7 +307,7 @@ GST_PLUGINS_NONPORTED=" aiff asfmux \
kate liveadder legacyresample librfb mpegtsmux \ kate liveadder legacyresample librfb mpegtsmux \
mpegpsmux mve mxf mythtv nsf nuvdemux \ mpegpsmux mve mxf mythtv nsf nuvdemux \
patchdetect pnm rawparse real scaletempo \ patchdetect pnm rawparse real scaletempo \
sdi segmentclip siren speed subenc stereo tta videofilters \ sdi siren speed subenc stereo tta videofilters \
videomeasure videosignal vmnc \ videomeasure videosignal vmnc \
decklink fbdev linsys shm vcd \ decklink fbdev linsys shm vcd \
apexsink cdaudio cog curl dc1394 dirac directfb resindvd \ apexsink cdaudio cog curl dc1394 dirac directfb resindvd \

71
gst/segmentclip/gstaudiosegmentclip.c
View file

@ -27,14 +27,12 @@
#include "gstaudiosegmentclip.h" #include "gstaudiosegmentclip.h"
static GstStaticPadTemplate sink_pad_template = static GstStaticPadTemplate sink_pad_template =
GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS, GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS,
GST_STATIC_CAPS GST_STATIC_CAPS (GST_AUDIO_CAPS_MAKE (GST_AUDIO_FORMATS_ALL)));
("audio/x-raw-int, width=(int)[1,MAX], channels=(int)[1,MAX],rate=(int)[1,MAX]; audio/x-raw-float, width=(int)[1,MAX], channels=(int)[1,MAX],rate=(int)[1,MAX]"));
static GstStaticPadTemplate src_pad_template = static GstStaticPadTemplate src_pad_template =
GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS, GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS,
GST_STATIC_CAPS GST_STATIC_CAPS (GST_AUDIO_CAPS_MAKE (GST_AUDIO_FORMATS_ALL)));
("audio/x-raw-int, width=(int)[1,MAX], channels=(int)[1,MAX],rate=(int)[1,MAX]; audio/x-raw-float, width=(int)[1,MAX], channels=(int)[1,MAX],rate=(int)[1,MAX]"));
static void gst_audio_segment_clip_reset (GstSegmentClip * self); static void gst_audio_segment_clip_reset (GstSegmentClip * self);
static GstFlowReturn gst_audio_segment_clip_clip_buffer (GstSegmentClip * self, static GstFlowReturn gst_audio_segment_clip_clip_buffer (GstSegmentClip * self,
@ -45,13 +43,23 @@ static gboolean gst_audio_segment_clip_set_caps (GstSegmentClip * self,
GST_DEBUG_CATEGORY_STATIC (gst_audio_segment_clip_debug); GST_DEBUG_CATEGORY_STATIC (gst_audio_segment_clip_debug);
#define GST_CAT_DEFAULT gst_audio_segment_clip_debug #define GST_CAT_DEFAULT gst_audio_segment_clip_debug
GST_BOILERPLATE (GstAudioSegmentClip, gst_audio_segment_clip, GstSegmentClip, G_DEFINE_TYPE (GstAudioSegmentClip, gst_audio_segment_clip,
GST_TYPE_SEGMENT_CLIP); GST_TYPE_SEGMENT_CLIP);
static void static void
gst_audio_segment_clip_base_init (gpointer g_class) gst_audio_segment_clip_class_init (GstAudioSegmentClipClass * klass)
{ {
GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
GstSegmentClipClass *segment_clip_klass = GST_SEGMENT_CLIP_CLASS (klass);
GST_DEBUG_CATEGORY_INIT (gst_audio_segment_clip_debug, "audiosegmentclip", 0,
"audiosegmentclip element");
segment_clip_klass->reset = GST_DEBUG_FUNCPTR (gst_audio_segment_clip_reset);
segment_clip_klass->set_caps =
GST_DEBUG_FUNCPTR (gst_audio_segment_clip_set_caps);
segment_clip_klass->clip_buffer =
GST_DEBUG_FUNCPTR (gst_audio_segment_clip_clip_buffer);
gst_element_class_set_details_simple (element_class, gst_element_class_set_details_simple (element_class,
"Audio buffer segment clipper", "Audio buffer segment clipper",
@ -66,23 +74,7 @@ gst_audio_segment_clip_base_init (gpointer g_class)
} }
static void static void
gst_audio_segment_clip_class_init (GstAudioSegmentClipClass * klass) gst_audio_segment_clip_init (GstAudioSegmentClip * self)
{
GstSegmentClipClass *segment_clip_klass = GST_SEGMENT_CLIP_CLASS (klass);
GST_DEBUG_CATEGORY_INIT (gst_audio_segment_clip_debug, "audiosegmentclip", 0,
"audiosegmentclip element");
segment_clip_klass->reset = GST_DEBUG_FUNCPTR (gst_audio_segment_clip_reset);
segment_clip_klass->set_caps =
GST_DEBUG_FUNCPTR (gst_audio_segment_clip_set_caps);
segment_clip_klass->clip_buffer =
GST_DEBUG_FUNCPTR (gst_audio_segment_clip_clip_buffer);
}
static void
gst_audio_segment_clip_init (GstAudioSegmentClip * self,
GstAudioSegmentClipClass * g_class)
{ {
} }
@ -107,7 +99,7 @@ gst_audio_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
GstClockTime duration = GST_BUFFER_DURATION (buffer); GstClockTime duration = GST_BUFFER_DURATION (buffer);
guint64 offset = GST_BUFFER_OFFSET (buffer); guint64 offset = GST_BUFFER_OFFSET (buffer);
guint64 offset_end = GST_BUFFER_OFFSET_END (buffer); guint64 offset_end = GST_BUFFER_OFFSET_END (buffer);
guint size = GST_BUFFER_SIZE (buffer); guint size = gst_buffer_get_size (buffer);
if (!self->rate || !self->framesize) { if (!self->rate || !self->framesize) {
GST_ERROR_OBJECT (self, "Not negotiated yet"); GST_ERROR_OBJECT (self, "Not negotiated yet");
@ -139,7 +131,7 @@ gst_audio_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
if (segment->format == GST_FORMAT_TIME) { if (segment->format == GST_FORMAT_TIME) {
if (segment->rate >= 0) { if (segment->rate >= 0) {
if (segment->stop != -1 && timestamp >= segment->stop) if (segment->stop != -1 && timestamp >= segment->stop)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} else { } else {
if (!GST_CLOCK_TIME_IS_VALID (duration)) if (!GST_CLOCK_TIME_IS_VALID (duration))
duration = duration =
@ -147,18 +139,18 @@ gst_audio_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
self->framesize * self->rate); self->framesize * self->rate);
if (segment->start != -1 && timestamp + duration <= segment->start) if (segment->start != -1 && timestamp + duration <= segment->start)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} }
} else { } else {
if (segment->rate >= 0) { if (segment->rate >= 0) {
if (segment->stop != -1 && offset != -1 && offset >= segment->stop) if (segment->stop != -1 && offset != -1 && offset >= segment->stop)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} else if (offset != -1 || offset_end != -1) { } else if (offset != -1 || offset_end != -1) {
if (offset_end == -1) if (offset_end == -1)
offset_end = offset + size / self->framesize; offset_end = offset + size / self->framesize;
if (segment->start != -1 && offset_end <= segment->start) if (segment->start != -1 && offset_end <= segment->start)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} }
} }
} }
@ -171,18 +163,19 @@ gst_audio_segment_clip_set_caps (GstSegmentClip * base, GstCaps * caps)
{ {
GstAudioSegmentClip *self = GST_AUDIO_SEGMENT_CLIP (base); GstAudioSegmentClip *self = GST_AUDIO_SEGMENT_CLIP (base);
gboolean ret; gboolean ret;
GstStructure *s; GstAudioInfo info;
gint rate, channels, width; gint rate, channels, width;
s = gst_caps_get_structure (caps, 0); gst_audio_info_init (&info);
ret = gst_audio_info_from_caps (&info, caps);
ret = gst_structure_get_int (s, "rate", &rate);
ret = ret && gst_structure_get_int (s, "channels", &channels);
ret = ret && gst_structure_get_int (s, "width", &width);
if (ret) { if (ret) {
GST_DEBUG_OBJECT (self, "Configured: rate %d channels %d width %d", rate, rate = GST_AUDIO_INFO_RATE (&info);
channels, width); channels = GST_AUDIO_INFO_CHANNELS (&info);
width = GST_AUDIO_INFO_WIDTH (&info);
GST_DEBUG_OBJECT (self, "Configured: rate %d channels %d width %d",
rate, channels, width);
self->rate = rate; self->rate = rate;
self->framesize = (width / 8) * channels; self->framesize = (width / 8) * channels;
} }

204
gst/segmentclip/gstsegmentclip.c
View file

@ -31,25 +31,44 @@ static GstStateChangeReturn gst_segment_clip_change_state (GstElement * element,
GstStateChange transition); GstStateChange transition);
static GstFlowReturn gst_segment_clip_sink_chain (GstPad * pad, static GstFlowReturn gst_segment_clip_sink_chain (GstPad * pad,
GstBuffer * buffer); GstObject * parent, GstBuffer * buffer);
static gboolean gst_segment_clip_sink_setcaps (GstPad * pad, GstCaps * caps); static gboolean gst_segment_clip_sink_setcaps (GstSegmentClip * self,
static GstFlowReturn gst_segment_clip_sink_bufferalloc (GstPad * pad, GstCaps * caps);
guint64 offset, guint size, GstCaps * caps, GstBuffer ** buf);
static gboolean gst_segment_clip_event (GstPad * pad, GstEvent * event); static gboolean gst_segment_clip_event (GstPad * pad, GstObject * parent,
static GstCaps *gst_segment_clip_getcaps (GstPad * pad); GstEvent * event);
static gboolean gst_segment_clip_query (GstPad * pad, GstQuery * query); static GstCaps *gst_segment_clip_getcaps (GstSegmentClip * self, GstPad * pad,
static const GstQueryType *gst_segment_clip_query_type (GstPad * pad); GstCaps * filter);
static gboolean gst_segment_clip_query (GstPad * pad, GstObject * parent,
GstQuery * query);
GST_DEBUG_CATEGORY_STATIC (gst_segment_clip_debug); GST_DEBUG_CATEGORY_STATIC (gst_segment_clip_debug);
#define GST_CAT_DEFAULT gst_segment_clip_debug #define GST_CAT_DEFAULT gst_segment_clip_debug
GST_BOILERPLATE (GstSegmentClip, gst_segment_clip, GstElement, static void gst_segment_clip_class_init (GstSegmentClipClass * klass);
GST_TYPE_ELEMENT); static void gst_segment_clip_init (GstSegmentClip * clip,
GstSegmentClipClass * g_class);
static void static GstElementClass *parent_class;
gst_segment_clip_base_init (gpointer g_class)
/* we can't use G_DEFINE_ABSTRACT_TYPE because we need the klass in the _init
* method to get to the padtemplates */
GType
gst_segment_clip_get_type (void)
{ {
static volatile gsize segment_clip_type = 0;
if (g_once_init_enter (&segment_clip_type)) {
GType _type;
_type = g_type_register_static_simple (GST_TYPE_ELEMENT,
"GstSegmentClip", sizeof (GstSegmentClipClass),
(GClassInitFunc) gst_segment_clip_class_init, sizeof (GstSegmentClip),
(GInstanceInitFunc) gst_segment_clip_init, G_TYPE_FLAG_ABSTRACT);
g_once_init_leave (&segment_clip_type, _type);
}
return segment_clip_type;
} }
static void static void
@ -57,6 +76,8 @@ gst_segment_clip_class_init (GstSegmentClipClass * klass)
{ {
GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass); GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
parent_class = g_type_class_peek_parent (klass);
GST_DEBUG_CATEGORY_INIT (gst_segment_clip_debug, "segmentclip", 0, GST_DEBUG_CATEGORY_INIT (gst_segment_clip_debug, "segmentclip", 0,
"segmentclip base class"); "segmentclip base class");
@ -78,16 +99,9 @@ gst_segment_clip_init (GstSegmentClip * self, GstSegmentClipClass * g_class)
GST_DEBUG_FUNCPTR (gst_segment_clip_sink_chain)); GST_DEBUG_FUNCPTR (gst_segment_clip_sink_chain));
gst_pad_set_event_function (self->sinkpad, gst_pad_set_event_function (self->sinkpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_event)); GST_DEBUG_FUNCPTR (gst_segment_clip_event));
gst_pad_set_setcaps_function (self->sinkpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_sink_setcaps));
gst_pad_set_getcaps_function (self->sinkpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_getcaps));
gst_pad_set_bufferalloc_function (self->sinkpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_sink_bufferalloc));
gst_pad_set_query_function (self->sinkpad, gst_pad_set_query_function (self->sinkpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_query)); GST_DEBUG_FUNCPTR (gst_segment_clip_query));
gst_pad_set_query_type_function (self->sinkpad, GST_PAD_SET_PROXY_ALLOCATION (self->sinkpad);
GST_DEBUG_FUNCPTR (gst_segment_clip_query_type));
gst_element_add_pad (GST_ELEMENT (self), self->sinkpad); gst_element_add_pad (GST_ELEMENT (self), self->sinkpad);
gst_object_unref (templ); gst_object_unref (templ);
@ -98,12 +112,8 @@ gst_segment_clip_init (GstSegmentClip * self, GstSegmentClipClass * g_class)
self->srcpad = gst_pad_new_from_template (templ, "src"); self->srcpad = gst_pad_new_from_template (templ, "src");
gst_pad_set_event_function (self->srcpad, gst_pad_set_event_function (self->srcpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_event)); GST_DEBUG_FUNCPTR (gst_segment_clip_event));
gst_pad_set_getcaps_function (self->srcpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_getcaps));
gst_pad_set_query_function (self->srcpad, gst_pad_set_query_function (self->srcpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_query)); GST_DEBUG_FUNCPTR (gst_segment_clip_query));
gst_pad_set_query_type_function (self->srcpad,
GST_DEBUG_FUNCPTR (gst_segment_clip_query_type));
gst_element_add_pad (GST_ELEMENT (self), self->srcpad); gst_element_add_pad (GST_ELEMENT (self), self->srcpad);
gst_segment_clip_reset (self); gst_segment_clip_reset (self);
@ -121,53 +131,31 @@ gst_segment_clip_reset (GstSegmentClip * self)
klass->reset (self); klass->reset (self);
} }
static GstFlowReturn
gst_segment_clip_sink_bufferalloc (GstPad * pad, guint64 offset, guint size,
GstCaps * caps, GstBuffer ** buf)
{
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad));
GstFlowReturn ret = GST_FLOW_OK;
GST_LOG_OBJECT (pad, "Allocating buffer with offset 0x%" G_GINT64_MODIFIER
"x and size %u with caps: %" GST_PTR_FORMAT, offset, size, caps);
*buf = NULL;
ret = gst_pad_alloc_buffer (self->srcpad, offset, size, caps, buf);
if (G_UNLIKELY (ret != GST_FLOW_OK))
GST_ERROR_OBJECT (pad, "Allocating buffer failed: %s",
gst_flow_get_name (ret));
gst_object_unref (self);
return ret;
}
static gboolean static gboolean
gst_segment_clip_sink_setcaps (GstPad * pad, GstCaps * caps) gst_segment_clip_sink_setcaps (GstSegmentClip * self, GstCaps * caps)
{ {
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad));
GstSegmentClipClass *klass = GST_SEGMENT_CLIP_GET_CLASS (self); GstSegmentClipClass *klass = GST_SEGMENT_CLIP_GET_CLASS (self);
gboolean ret; gboolean ret;
GST_DEBUG_OBJECT (pad, "Setting caps: %" GST_PTR_FORMAT, caps); GST_DEBUG_OBJECT (self, "Setting caps: %" GST_PTR_FORMAT, caps);
ret = klass->set_caps (self, caps); ret = klass->set_caps (self, caps);
gst_object_unref (self); /* pass along caps* */
if (ret)
ret = gst_pad_set_caps (self->srcpad, caps);
return ret; return ret;
} }
static GstCaps * static GstCaps *
gst_segment_clip_getcaps (GstPad * pad) gst_segment_clip_getcaps (GstSegmentClip * self, GstPad * pad, GstCaps * filter)
{ {
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad));
GstPad *otherpad; GstPad *otherpad;
GstCaps *tmp, *ret; GstCaps *tmp, *ret;
otherpad = (pad == self->srcpad) ? self->sinkpad : self->srcpad; otherpad = (pad == self->srcpad) ? self->sinkpad : self->srcpad;
tmp = gst_pad_peer_get_caps (otherpad); tmp = gst_pad_peer_query_caps (otherpad, filter);
if (tmp) { if (tmp) {
ret = gst_caps_intersect (tmp, gst_pad_get_pad_template_caps (pad)); ret = gst_caps_intersect (tmp, gst_pad_get_pad_template_caps (pad));
gst_caps_unref (tmp); gst_caps_unref (tmp);
@ -175,55 +163,40 @@ gst_segment_clip_getcaps (GstPad * pad)
ret = gst_caps_copy (gst_pad_get_pad_template_caps (pad)); ret = gst_caps_copy (gst_pad_get_pad_template_caps (pad));
} }
gst_object_unref (self);
GST_LOG_OBJECT (pad, "Returning caps: %" GST_PTR_FORMAT, ret); GST_LOG_OBJECT (pad, "Returning caps: %" GST_PTR_FORMAT, ret);
return ret; return ret;
} }
static gboolean static gboolean
gst_segment_clip_query (GstPad * pad, GstQuery * query) gst_segment_clip_query (GstPad * pad, GstObject * parent, GstQuery * query)
{ {
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad)); GstSegmentClip *self = GST_SEGMENT_CLIP (parent);
gboolean ret; gboolean ret;
GstPad *otherpad;
otherpad = (pad == self->srcpad) ? self->sinkpad : self->srcpad;
GST_LOG_OBJECT (pad, "Handling query of type '%s'", GST_LOG_OBJECT (pad, "Handling query of type '%s'",
gst_query_type_get_name (GST_QUERY_TYPE (query))); gst_query_type_get_name (GST_QUERY_TYPE (query)));
ret = gst_pad_peer_query (otherpad, query); if (GST_QUERY_TYPE (query) == GST_QUERY_CAPS) {
GstCaps *caps;
gst_query_parse_caps (query, &caps);
caps = gst_segment_clip_getcaps (self, pad, caps);
gst_query_set_caps_result (query, caps);
gst_caps_unref (caps);
ret = TRUE;
} else {
ret = gst_pad_query_default (pad, parent, query);
}
gst_object_unref (self);
return ret; return ret;
} }
static const GstQueryType *
gst_segment_clip_query_type (GstPad * pad)
{
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad));
GstPad *otherpad, *peer;
const GstQueryType *types = NULL;
otherpad = (pad == self->srcpad) ? self->sinkpad : self->srcpad;
peer = gst_pad_get_peer (otherpad);
if (peer) {
types = gst_pad_get_query_types (peer);
gst_object_unref (peer);
}
gst_object_unref (self);
return types;
}
static GstFlowReturn static GstFlowReturn
gst_segment_clip_sink_chain (GstPad * pad, GstBuffer * buffer) gst_segment_clip_sink_chain (GstPad * pad, GstObject * parent,
GstBuffer * buffer)
{ {
GstSegmentClip *self = GST_SEGMENT_CLIP (GST_PAD_PARENT (pad)); GstSegmentClip *self = GST_SEGMENT_CLIP (parent);
GstFlowReturn ret; GstFlowReturn ret;
GstSegmentClipClass *klass = GST_SEGMENT_CLIP_GET_CLASS (self); GstSegmentClipClass *klass = GST_SEGMENT_CLIP_GET_CLASS (self);
GstBuffer *outbuf = NULL; GstBuffer *outbuf = NULL;
@ -262,46 +235,45 @@ gst_segment_clip_change_state (GstElement * element, GstStateChange transition)
} }
static gboolean static gboolean
gst_segment_clip_event (GstPad * pad, GstEvent * event) gst_segment_clip_event (GstPad * pad, GstObject * parent, GstEvent * event)
{ {
GstSegmentClip *self = GST_SEGMENT_CLIP (gst_pad_get_parent (pad)); GstSegmentClip *self = GST_SEGMENT_CLIP (parent);
GstPad *otherpad; gboolean ret = TRUE;
gboolean ret;
GST_LOG_OBJECT (pad, "Got %s event", GST_EVENT_TYPE_NAME (event)); GST_LOG_OBJECT (pad, "Got %s event", GST_EVENT_TYPE_NAME (event));
otherpad = (pad == self->srcpad) ? self->sinkpad : self->srcpad; switch (GST_EVENT_TYPE (event)) {
ret = gst_pad_push_event (otherpad, gst_event_ref (event)); case GST_EVENT_CAPS:
{
GstCaps *caps;
if (ret) { /* should be only downstream */
switch (GST_EVENT_TYPE (event)) { g_assert (pad == self->sinkpad);
case GST_EVENT_NEWSEGMENT:{ gst_event_parse_caps (event, &caps);
GstFormat fmt; ret = gst_segment_clip_sink_setcaps (self, caps);
gboolean is_update; break;
gint64 start, end, base;
gdouble rate;
gst_event_parse_new_segment (event, &is_update, &rate, &fmt, &start,
&end, &base);
GST_DEBUG_OBJECT (pad,
"Got NEWSEGMENT event in %s format, passing on (%"
GST_TIME_FORMAT " - %" GST_TIME_FORMAT ")",
gst_format_get_name (fmt), GST_TIME_ARGS (start),
GST_TIME_ARGS (end));
gst_segment_set_newsegment (&self->segment, is_update, rate, fmt, start,
end, base);
break;
}
case GST_EVENT_FLUSH_STOP:
gst_segment_clip_reset (self);
break;
default:
break;
} }
case GST_EVENT_SEGMENT:
{
const GstSegment *segment;
gst_event_parse_segment (event, &segment);
GST_DEBUG_OBJECT (pad, "Got NEWSEGMENT event %" GST_SEGMENT_FORMAT,
segment);
gst_segment_copy_into (segment, &self->segment);
break;
}
case GST_EVENT_FLUSH_STOP:
gst_segment_clip_reset (self);
break;
default:
break;
} }
gst_event_unref (event); if (ret)
ret = gst_pad_event_default (pad, parent, event);
else
gst_event_unref (event);
gst_object_unref (self);
return ret; return ret;
} }

45
gst/segmentclip/gstvideosegmentclip.c
View file

@ -27,19 +27,12 @@
#include "gstvideosegmentclip.h" #include "gstvideosegmentclip.h"
static GstStaticPadTemplate sink_pad_template = static GstStaticPadTemplate sink_pad_template =
GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS, GST_STATIC_PAD_TEMPLATE ("sink", GST_PAD_SINK, GST_PAD_ALWAYS,
GST_STATIC_CAPS GST_STATIC_CAPS ("video/x-raw, framerate=" GST_VIDEO_FPS_RANGE));
("video/x-raw-yuv, framerate=" GST_VIDEO_FPS_RANGE "; "
"video/x-raw-rgb, framerate=" GST_VIDEO_FPS_RANGE "; "
"video/x-raw-grey, framerate=" GST_VIDEO_FPS_RANGE));
static GstStaticPadTemplate src_pad_template = static GstStaticPadTemplate src_pad_template =
GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS, GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS,
GST_STATIC_CAPS GST_STATIC_CAPS ("video/x-raw, framerate=" GST_VIDEO_FPS_RANGE));
("video/x-raw-yuv, framerate=" GST_VIDEO_FPS_RANGE "; "
"video/x-raw-rgb, framerate=" GST_VIDEO_FPS_RANGE "; "
"video/x-raw-grey, framerate=" GST_VIDEO_FPS_RANGE));
static void gst_video_segment_clip_reset (GstSegmentClip * self); static void gst_video_segment_clip_reset (GstSegmentClip * self);
static GstFlowReturn gst_video_segment_clip_clip_buffer (GstSegmentClip * self, static GstFlowReturn gst_video_segment_clip_clip_buffer (GstSegmentClip * self,
@ -50,13 +43,17 @@ static gboolean gst_video_segment_clip_set_caps (GstSegmentClip * self,
GST_DEBUG_CATEGORY_STATIC (gst_video_segment_clip_debug); GST_DEBUG_CATEGORY_STATIC (gst_video_segment_clip_debug);
#define GST_CAT_DEFAULT gst_video_segment_clip_debug #define GST_CAT_DEFAULT gst_video_segment_clip_debug
GST_BOILERPLATE (GstVideoSegmentClip, gst_video_segment_clip, GstSegmentClip, G_DEFINE_TYPE (GstVideoSegmentClip, gst_video_segment_clip,
GST_TYPE_SEGMENT_CLIP); GST_TYPE_SEGMENT_CLIP);
static void static void
gst_video_segment_clip_base_init (gpointer g_class) gst_video_segment_clip_class_init (GstVideoSegmentClipClass * klass)
{ {
GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
GstSegmentClipClass *segment_clip_klass = GST_SEGMENT_CLIP_CLASS (klass);
GST_DEBUG_CATEGORY_INIT (gst_video_segment_clip_debug, "videosegmentclip", 0,
"videosegmentclip element");
gst_element_class_set_details_simple (element_class, gst_element_class_set_details_simple (element_class,
"Video buffer segment clipper", "Video buffer segment clipper",
@ -68,15 +65,6 @@ gst_video_segment_clip_base_init (gpointer g_class)
gst_static_pad_template_get (&sink_pad_template)); gst_static_pad_template_get (&sink_pad_template));
gst_element_class_add_pad_template (element_class, gst_element_class_add_pad_template (element_class,
gst_static_pad_template_get (&src_pad_template)); gst_static_pad_template_get (&src_pad_template));
}
static void
gst_video_segment_clip_class_init (GstVideoSegmentClipClass * klass)
{
GstSegmentClipClass *segment_clip_klass = GST_SEGMENT_CLIP_CLASS (klass);
GST_DEBUG_CATEGORY_INIT (gst_video_segment_clip_debug, "videosegmentclip", 0,
"videosegmentclip element");
segment_clip_klass->reset = GST_DEBUG_FUNCPTR (gst_video_segment_clip_reset); segment_clip_klass->reset = GST_DEBUG_FUNCPTR (gst_video_segment_clip_reset);
segment_clip_klass->set_caps = segment_clip_klass->set_caps =
@ -86,8 +74,7 @@ gst_video_segment_clip_class_init (GstVideoSegmentClipClass * klass)
} }
static void static void
gst_video_segment_clip_init (GstVideoSegmentClip * self, gst_video_segment_clip_init (GstVideoSegmentClip * self)
GstVideoSegmentClipClass * g_class)
{ {
} }
@ -109,7 +96,7 @@ gst_video_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
GstVideoSegmentClip *self = GST_VIDEO_SEGMENT_CLIP (base); GstVideoSegmentClip *self = GST_VIDEO_SEGMENT_CLIP (base);
GstSegment *segment = &base->segment; GstSegment *segment = &base->segment;
GstClockTime timestamp, duration; GstClockTime timestamp, duration;
gint64 cstart, cstop; guint64 cstart, cstop;
gboolean in_seg; gboolean in_seg;
if (!self->fps_d) { if (!self->fps_d) {
@ -146,7 +133,7 @@ gst_video_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
timestamp + duration, &cstart, &cstop); timestamp + duration, &cstart, &cstop);
if (in_seg) { if (in_seg) {
if (timestamp != cstart || timestamp + duration != cstop) { if (timestamp != cstart || timestamp + duration != cstop) {
*outbuf = gst_buffer_make_metadata_writable (buffer); *outbuf = gst_buffer_make_writable (buffer);
GST_BUFFER_TIMESTAMP (*outbuf) = cstart; GST_BUFFER_TIMESTAMP (*outbuf) = cstart;
GST_BUFFER_DURATION (*outbuf) = cstop - cstart; GST_BUFFER_DURATION (*outbuf) = cstop - cstart;
@ -158,10 +145,10 @@ gst_video_segment_clip_clip_buffer (GstSegmentClip * base, GstBuffer * buffer,
if (segment->rate >= 0) { if (segment->rate >= 0) {
if (segment->stop != -1 && timestamp >= segment->stop) if (segment->stop != -1 && timestamp >= segment->stop)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} else { } else {
if (segment->start != -1 && timestamp + duration <= segment->start) if (segment->start != -1 && timestamp + duration <= segment->start)
return GST_FLOW_UNEXPECTED; return GST_FLOW_EOS;
} }
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
} }