5 files changed, 21 insertions, 12 deletions
diff --git a/ext/mpeg2enc/gstmpeg2enc.cc b/ext/mpeg2enc/gstmpeg2enc.cc
index 71a41ade..bee6a9b0 100644
--- a/ext/mpeg2enc/gstmpeg2enc.cc
+++ b/ext/mpeg2enc/gstmpeg2enc.cc
@@ -89,7 +89,7 @@ src_templ (void)
 				NULL);
     add_fps (caps);
 
-    templ = gst_pad_template_new ("sink", GST_PAD_SINK,
+    templ = gst_pad_template_new ("src", GST_PAD_SRC,
 				  GST_PAD_ALWAYS, caps);
   }
 
@@ -205,14 +205,15 @@ static void
 gst_mpeg2enc_init (GstMpeg2enc *enc)
 {
   GstElement *element = GST_ELEMENT (enc);
+  GstElementClass *klass = GST_ELEMENT_GET_CLASS (element);
 
   enc->sinkpad = gst_pad_new_from_template (
-	gst_element_get_pad_template (element, "sink"), "sink");
+	gst_element_class_get_pad_template (klass, "sink"), "sink");
   gst_pad_set_link_function (enc->sinkpad, gst_mpeg2enc_sink_link);
   gst_element_add_pad (element, enc->sinkpad);
 
   enc->srcpad = gst_pad_new_from_template (
-	gst_element_get_pad_template (element, "src"), "src");
+	gst_element_class_get_pad_template (klass, "src"), "src");
   gst_pad_set_getcaps_function (enc->srcpad, gst_mpeg2enc_src_getcaps);
   gst_element_add_pad (element, enc->srcpad);
 
@@ -229,7 +230,12 @@ gst_mpeg2enc_loop (GstElement *element)
   GstMpeg2enc *enc = GST_MPEG2ENC (element);
 
   if (!enc->encoder) {
-    GstCaps *caps;
+    const GstCaps *caps;
+    GstData *data;
+
+    /* make sure we've had data */
+    data = gst_pad_pull (enc->sinkpad);
+    gst_pad_set_element_private (enc->sinkpad, data);
 
     if (!(caps = GST_PAD_CAPS (enc->sinkpad))) {
       gst_element_error (element,
@@ -281,8 +287,8 @@ gst_mpeg2enc_src_getcaps (GstPad *pad)
     return enc->encoder->getFormat ();
   }
 
-  return (GstCaps* ) gst_pad_template_get_caps (
-	gst_element_get_pad_template (gst_pad_get_parent (pad), "src"));
+  return gst_caps_copy (gst_pad_template_get_caps (
+	gst_element_get_pad_template (gst_pad_get_parent (pad), "src")));
 }
 
 static void
diff --git a/ext/mpeg2enc/gstmpeg2encoder.cc b/ext/mpeg2enc/gstmpeg2encoder.cc
index b1c2b8ef..f5b2ee4b 100644
--- a/ext/mpeg2enc/gstmpeg2encoder.cc
+++ b/ext/mpeg2enc/gstmpeg2encoder.cc
@@ -37,7 +37,7 @@
 
 GstMpeg2Encoder::GstMpeg2Encoder (GstMpeg2EncOptions *options,
 				  GstPad             *sinkpad,
-				  GstCaps            *caps,
+				  const GstCaps      *caps,
 				  GstPad             *srcpad) :
   MPEG2Encoder (*options)
 {
diff --git a/ext/mpeg2enc/gstmpeg2encoder.hh b/ext/mpeg2enc/gstmpeg2encoder.hh
index ebe29692..df034e6b 100644
--- a/ext/mpeg2enc/gstmpeg2encoder.hh
+++ b/ext/mpeg2enc/gstmpeg2encoder.hh
@@ -31,7 +31,7 @@ class GstMpeg2Encoder : public MPEG2Encoder {
 public:
   GstMpeg2Encoder (GstMpeg2EncOptions *options,
 		   GstPad             *sinkpad,
-		   GstCaps            *caps,
+		   const GstCaps      *caps,
 		   GstPad             *srcpad);
 
   /* one image */
diff --git a/ext/mpeg2enc/gstmpeg2encpicturereader.cc b/ext/mpeg2enc/gstmpeg2encpicturereader.cc
index 1c8e9f4c..004495e7 100644
--- a/ext/mpeg2enc/gstmpeg2encpicturereader.cc
+++ b/ext/mpeg2enc/gstmpeg2encpicturereader.cc
@@ -32,7 +32,7 @@
  */
 
 GstMpeg2EncPictureReader::GstMpeg2EncPictureReader (GstPad        *in_pad,
-						    GstCaps       *in_caps,
+						    const GstCaps *in_caps,
 						    EncoderParams *params) :
   PictureReader (*params)
 {
@@ -91,9 +91,12 @@ GstMpeg2EncPictureReader::LoadFrame ()
   guint8 *frame;
 
   do {
-    if (!(data = gst_pad_pull (pad))) {
+    if ((data = (GstData *) gst_pad_get_element_private (pad))) {
+      gst_pad_set_element_private (pad, NULL);
+    } else if (!(data = gst_pad_pull (pad))) {
       return true;
-    } else if (GST_IS_EVENT (data)) {
+    }
+    if (GST_IS_EVENT (data)) {
       if (GST_EVENT_TYPE (data) == GST_EVENT_EOS) {
         gst_pad_event_default (pad, GST_EVENT (data));
         return true;
diff --git a/ext/mpeg2enc/gstmpeg2encpicturereader.hh b/ext/mpeg2enc/gstmpeg2encpicturereader.hh
index 93ed8bdc..92d01f6d 100644
--- a/ext/mpeg2enc/gstmpeg2encpicturereader.hh
+++ b/ext/mpeg2enc/gstmpeg2encpicturereader.hh
@@ -30,7 +30,7 @@
 class GstMpeg2EncPictureReader : public PictureReader {
 public:
   GstMpeg2EncPictureReader (GstPad        *pad,
-			    GstCaps       *caps,
+			    const GstCaps *caps,
 			    EncoderParams *params);
   ~GstMpeg2EncPictureReader ();