Pass buffer in handoff signal

Original commit message from CVS:
Pass buffer in handoff signal

diff --git a/gst/elements/gstfakesink.c b/gst/elements/gstfakesink.c
index 11590c4..1d22865 100644 (file)
--- a/gst/elements/gstfakesink.c
+++ b/gst/elements/gstfakesink.c
@@ -97,7 +97,8 @@ gst_fakesink_class_init (GstFakeSinkClass *klass)
   gst_fakesink_signals[SIGNAL_HANDOFF] =
     gtk_signal_new ("handoff", GTK_RUN_LAST, gtkobject_class->type,
                     GTK_SIGNAL_OFFSET (GstFakeSinkClass, handoff),
-                    gtk_marshal_NONE__NONE, GTK_TYPE_NONE, 0);
+                    gtk_marshal_NONE__POINTER, GTK_TYPE_NONE, 1,
+                    GTK_TYPE_POINTER);
 
   gtk_object_class_add_signals (gtkobject_class, gst_fakesink_signals,
                                     LAST_SIGNAL);
@@ -194,9 +195,8 @@ gst_fakesink_chain (GstPad *pad, GstBuffer *buf)
   if (!fakesink->silent)
     g_print("fakesink: ******* (%s:%s)< (%d bytes) \n",GST_DEBUG_PAD_NAME(pad),GST_BUFFER_SIZE(buf));
   
-  gst_buffer_unref (buf);
-
   gtk_signal_emit (GTK_OBJECT (fakesink), gst_fakesink_signals[SIGNAL_HANDOFF],
-                             fakesink);
+                   buf);
 
+  gst_buffer_unref (buf);
 }

diff --git a/gst/elements/gstfakesrc.c b/gst/elements/gstfakesrc.c
index 23e75c8..5fa6af2 100644 (file)
--- a/gst/elements/gstfakesrc.c
+++ b/gst/elements/gstfakesrc.c
@@ -134,7 +134,8 @@ gst_fakesrc_class_init (GstFakeSrcClass *klass)
   gst_fakesrc_signals[SIGNAL_HANDOFF] =
     gtk_signal_new ("handoff", GTK_RUN_LAST, gtkobject_class->type,
                     GTK_SIGNAL_OFFSET (GstFakeSrcClass, handoff),
-                    gtk_marshal_NONE__NONE, GTK_TYPE_NONE, 0);
+                    gtk_marshal_NONE__POINTER, GTK_TYPE_NONE, 1,
+                    GTK_TYPE_POINTER);
 
   gtk_object_class_add_signals (gtkobject_class, gst_fakesrc_signals,
                                 LAST_SIGNAL);
@@ -299,7 +300,7 @@ gst_fakesrc_get(GstPad *pad)
   buf = gst_buffer_new();
 
   gtk_signal_emit (GTK_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF],
-                                  src);
+                   buf);
 
   return buf;
 }
@@ -343,7 +344,7 @@ gst_fakesrc_loop(GstElement *element)
         g_print("fakesrc: ******* (%s:%s)> \n",GST_DEBUG_PAD_NAME(pad));
 
       gtk_signal_emit (GTK_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF],
-                                  src);
+                       buf);
       gst_pad_push (pad, buf);
 
       pads = g_slist_next (pads);

diff --git a/plugins/elements/gstfakesink.c b/plugins/elements/gstfakesink.c
index 11590c4..1d22865 100644 (file)
--- a/plugins/elements/gstfakesink.c
+++ b/plugins/elements/gstfakesink.c
@@ -97,7 +97,8 @@ gst_fakesink_class_init (GstFakeSinkClass *klass)
   gst_fakesink_signals[SIGNAL_HANDOFF] =
     gtk_signal_new ("handoff", GTK_RUN_LAST, gtkobject_class->type,
                     GTK_SIGNAL_OFFSET (GstFakeSinkClass, handoff),
-                    gtk_marshal_NONE__NONE, GTK_TYPE_NONE, 0);
+                    gtk_marshal_NONE__POINTER, GTK_TYPE_NONE, 1,
+                    GTK_TYPE_POINTER);
 
   gtk_object_class_add_signals (gtkobject_class, gst_fakesink_signals,
                                     LAST_SIGNAL);
@@ -194,9 +195,8 @@ gst_fakesink_chain (GstPad *pad, GstBuffer *buf)
   if (!fakesink->silent)
     g_print("fakesink: ******* (%s:%s)< (%d bytes) \n",GST_DEBUG_PAD_NAME(pad),GST_BUFFER_SIZE(buf));
   
-  gst_buffer_unref (buf);
-
   gtk_signal_emit (GTK_OBJECT (fakesink), gst_fakesink_signals[SIGNAL_HANDOFF],
-                             fakesink);
+                   buf);
 
+  gst_buffer_unref (buf);
 }

diff --git a/plugins/elements/gstfakesrc.c b/plugins/elements/gstfakesrc.c
index 23e75c8..5fa6af2 100644 (file)
--- a/plugins/elements/gstfakesrc.c
+++ b/plugins/elements/gstfakesrc.c
@@ -134,7 +134,8 @@ gst_fakesrc_class_init (GstFakeSrcClass *klass)
   gst_fakesrc_signals[SIGNAL_HANDOFF] =
     gtk_signal_new ("handoff", GTK_RUN_LAST, gtkobject_class->type,
                     GTK_SIGNAL_OFFSET (GstFakeSrcClass, handoff),
-                    gtk_marshal_NONE__NONE, GTK_TYPE_NONE, 0);
+                    gtk_marshal_NONE__POINTER, GTK_TYPE_NONE, 1,
+                    GTK_TYPE_POINTER);
 
   gtk_object_class_add_signals (gtkobject_class, gst_fakesrc_signals,
                                 LAST_SIGNAL);
@@ -299,7 +300,7 @@ gst_fakesrc_get(GstPad *pad)
   buf = gst_buffer_new();
 
   gtk_signal_emit (GTK_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF],
-                                  src);
+                   buf);
 
   return buf;
 }
@@ -343,7 +344,7 @@ gst_fakesrc_loop(GstElement *element)
         g_print("fakesrc: ******* (%s:%s)> \n",GST_DEBUG_PAD_NAME(pad));
 
       gtk_signal_emit (GTK_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF],
-                                  src);
+                       buf);
       gst_pad_push (pad, buf);
 
       pads = g_slist_next (pads);

diff --git a/tests/sched/runxml.c b/tests/sched/runxml.c
index e701836..eb42490 100644 (file)
--- a/tests/sched/runxml.c
+++ b/tests/sched/runxml.c
@@ -5,7 +5,7 @@
 static guint outcount, incount;
 
 static void
-buffer_handoff_sink (GstElement *src, GstElement *bin)
+buffer_handoff_sink (GstElement *src, GstBuffer *buf, GstElement *bin)
 {
   g_print ("\n\n *** buffer arrived in sink ***\n\n");
   gst_element_set_state(bin, GST_STATE_NULL);
@@ -14,7 +14,7 @@ buffer_handoff_sink (GstElement *src, GstElement *bin)
 }
 
 static void
-buffer_handoff_src (GstElement *src, GstElement *bin)
+buffer_handoff_src (GstElement *src, GstBuffer *buf, GstElement *bin)
 {
   g_print ("\n\n *** buffer started in src ***\n\n");
   incount++;