mp3parse->sinkpad = gst_pad_new_from_template(sink_temp, "sink");
gst_element_add_pad(GST_ELEMENT(mp3parse),mp3parse->sinkpad);
+ gst_element_set_loop_function (GST_ELEMENT(mp3parse),gst_mp3parse_loop);
#if 1 /* set this to one to use the old chaining code */
gst_pad_set_chain_function(mp3parse->sinkpad,gst_mp3parse_chain);
-#else /* else you get the new loop-based code, which isn't complete yet */
- gst_element_set_loop_function (GST_ELEMENT(mp3parse),gst_mp3parse_loop);
+ gst_element_set_loop_function (GST_ELEMENT(mp3parse),NULL);
#endif
mp3parse->srcpad = gst_pad_new_from_template(src_temp, "src");
return TRUE;
}
-static void
-_queue_discontinuous (GstPad *pad, gpointer ign)
-{
- /* ugh, GstBuffer cast is wrong here */
- gst_pad_push (pad, (GstBuffer*) gst_event_new (GST_EVENT_DISCONTINUOUS));
-}
-
-static void
-_queue_eos (GstPad *pad, gpointer ign)
-{
- /* ugh, GstBuffer cast is wrong here */
- gst_pad_push (pad, (GstBuffer*) gst_event_new (GST_EVENT_EOS));
-}
-
-static void
-_forall_pads (GstMPEGDemux *mpeg_demux, GFunc fun, gpointer user_data)
-{
- GstPad *pad;
- gint i;
-
- /* events should be refcnt'd XXX */
-
- for (i=0;i<NUM_PRIVATE_1_PADS;i++)
- {
- pad = mpeg_demux->private_1_pad[i];
- if (pad && GST_PAD_IS_CONNECTED(pad))
- (*fun) (pad, user_data);
- }
- for (i=0;i<NUM_SUBTITLE_PADS;i++)
- {
- pad = mpeg_demux->subtitle_pad[i];
- if (pad && GST_PAD_IS_CONNECTED(pad))
- (*fun) (pad, user_data);
- }
-
- pad = mpeg_demux->private_2_pad;
- if (pad && GST_PAD_IS_CONNECTED(pad))
- (*fun) (pad, user_data);
-
- for (i=0;i<NUM_VIDEO_PADS;i++)
- {
- pad = mpeg_demux->video_pad[i];
- if (pad && GST_PAD_IS_CONNECTED(pad))
- (*fun) (pad, user_data);
- }
- for (i=0;i<NUM_AUDIO_PADS;i++)
- {
- pad = mpeg_demux->audio_pad[i];
- if (pad && GST_PAD_IS_CONNECTED(pad))
- (*fun) (pad, user_data);
- }
-}
-
static GstElementStateReturn
gst_mpeg_demux_change_state (GstElement *element)
{
static GstElementStateReturn
gst_rfc2250_enc_change_state (GstElement *element);
-static gboolean gst_rfc2250_enc_parse_packhead (GstRFC2250Enc *rfc2250_enc, GstBuffer *buffer);
-static void gst_rfc2250_enc_send_data (GstRFC2250Enc *rfc2250_enc, GstData *data);
-
static void gst_rfc2250_enc_loop (GstElement *element);
static void gst_rfc2250_enc_get_property (GObject *object, guint prop_id,