FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Some continuation fixes

Browse Source 
Original commit message from CVS:
Some continuation fixes
This commit is contained in:
Ronald S. Bultje 2003-03-30 19:20:26 +00:00
parent f5954e2f72
commit a09ea72813
1 changed files with 45 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
gst/synaesthesia/gstsynaesthesia.c
View File

@ -130,6 +130,9 @@ static void gst_synaesthesia_get_property (GObject *object, guint prop_id,
static void gst_synaesthesia_chain (GstPad *pad, GstBuffer *buf); static void gst_synaesthesia_chain (GstPad *pad, GstBuffer *buf);
static GstElementStateReturn
gst_synaesthesia_change_state (GstElement *element);
static GstPadLinkReturn static GstPadLinkReturn
gst_synaesthesia_sinkconnect (GstPad *pad, GstCaps *caps); gst_synaesthesia_sinkconnect (GstPad *pad, GstCaps *caps);
@ -180,6 +183,8 @@ gst_synaesthesia_class_init(GstSynaesthesiaClass *klass)
gobject_class->set_property = gst_synaesthesia_set_property; gobject_class->set_property = gst_synaesthesia_set_property;
gobject_class->get_property = gst_synaesthesia_get_property; gobject_class->get_property = gst_synaesthesia_get_property;
gstelement_class->change_state = gst_synaesthesia_change_state;
} }
static void static void
@ -196,11 +201,9 @@ gst_synaesthesia_init (GstSynaesthesia *synaesthesia)
gst_pad_set_chain_function (synaesthesia->sinkpad, gst_synaesthesia_chain); gst_pad_set_chain_function (synaesthesia->sinkpad, gst_synaesthesia_chain);
gst_pad_set_link_function (synaesthesia->sinkpad, gst_synaesthesia_sinkconnect); gst_pad_set_link_function (synaesthesia->sinkpad, gst_synaesthesia_sinkconnect);
synaesthesia->next_time = 0; GST_FLAG_SET (synaesthesia, GST_ELEMENT_EVENT_AWARE);
synaesthesia->peerpool = NULL;
/* reset the initial video state */ /* reset the initial video state */
synaesthesia->first_buffer = TRUE;
synaesthesia->width = 320; synaesthesia->width = 320;
synaesthesia->height = 200; synaesthesia->height = 200;
synaesthesia->fps = 25; /* desired frame rate */ synaesthesia->fps = 25; /* desired frame rate */
@ -233,6 +236,23 @@ gst_synaesthesia_chain (GstPad *pad, GstBuffer *bufin)
GST_DEBUG (0, "Synaesthesia: chainfunc called"); GST_DEBUG (0, "Synaesthesia: chainfunc called");
if (GST_IS_EVENT (bufin)) {
GstEvent *event = GST_EVENT (bufin);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_DISCONTINUOUS:
{
gint64 value = 0;
gst_event_discont_get_value (event, GST_FORMAT_TIME, &value);
synaesthesia->next_time = value;
}
default:
gst_pad_event_default (pad, event);
break;
}
return;
}
samples_in = GST_BUFFER_SIZE (bufin) / sizeof (gint16); samples_in = GST_BUFFER_SIZE (bufin) / sizeof (gint16);
GST_DEBUG (0, "input buffer has %d samples", samples_in); GST_DEBUG (0, "input buffer has %d samples", samples_in);
@ -342,6 +362,28 @@ gst_synaesthesia_get_property (GObject *object, guint prop_id, GValue *value, GP
} }
} }
static GstElementStateReturn
gst_synaesthesia_change_state (GstElement *element)
{
GstSynaesthesia *synaesthesia;
synaesthesia = GST_SYNAESTHESIA (element);
switch (GST_STATE_TRANSITION (element)) {
case GST_STATE_READY_TO_PAUSED:
synaesthesia->next_time = 0;
synaesthesia->peerpool = NULL;
synaesthesia->first_buffer = TRUE;
break;
}
if (GST_ELEMENT_CLASS (parent_class)->change_state)
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
return GST_STATE_SUCCESS;
}
static gboolean static gboolean
plugin_init (GModule *module, GstPlugin *plugin) plugin_init (GModule *module, GstPlugin *plugin)
{ {