2005-11-04 Edward Hervey <edward@fluendo.com>
+ * gst/gstpad.override:
+ Use proper GValue <-> MiniObject conversion function
+ * examples/Makefile.am:
+ * examples/sinkelement.py:
+ New example showing how to create a sink element in python.
+
+2005-11-04 Edward Hervey <edward@fluendo.com>
+
* examples/play.py:
Fixed the play example to work with 0.9.4 API
--- /dev/null
+# sinkelement.py
+# (c) 2005 Edward Hervey <edward@fluendo.com>
+# Licensed under LGPL
+#
+# Small test application to show how to write a sink element
+# in 20 lines in python
+#
+# Run this script with GST_DEBUG=python:5 to see the debug
+# messages
+
+import pygst
+pygst.require('0.9')
+import gst
+import gobject
+
+#
+# Simple Sink element created entirely in python
+#
+
+class MySink(gst.Element):
+
+ _sinkpadtemplate = gst.PadTemplate ("sinkpadtemplate",
+ gst.PAD_SINK,
+ gst.PAD_ALWAYS,
+ gst.caps_new_any())
+
+ def __init__(self):
+ gst.Element.__init__(self)
+ gst.info('creating sinkpad')
+ self.sinkpad = gst.Pad(self._sinkpadtemplate, "sink")
+ gst.info('adding sinkpad to self')
+ self.add_pad(self.sinkpad)
+
+ gst.info('setting chain/event functions')
+ self.sinkpad.set_chain_function(self.chainfunc)
+ self.sinkpad.set_event_function(self.eventfunc)
+
+ def chainfunc(self, pad, buffer):
+ self.info("%s timestamp(buffer):%d" % (pad, buffer.timestamp))
+ return gst.FLOW_OK
+
+ def eventfunc(self, pad, event):
+ self.info("%s event:%r" % (pad, event.type))
+ return True
+
+gobject.type_register(MySink)
+
+#
+# Code to test the MySink class
+#
+
+src = gst.element_factory_make('fakesrc')
+gst.info('About to create MySink')
+sink = MySink()
+
+pipeline = gst.Pipeline()
+pipeline.add(src, sink)
+
+src.link(sink)
+
+pipeline.set_state(gst.STATE_PLAYING)
+
+gobject.MainLoop().run()
g_value_init (&args[0], GST_TYPE_PAD);
g_value_init (&args[1], GST_TYPE_EVENT);
g_value_set_object (&args[0], pad);
- g_value_set_boxed (&args[1], event);
+ gst_value_set_mini_object (&args[1], GST_MINI_OBJECT (event));
closure = pad_private(pad)->event_function;
g_closure_invoke (closure, &ret, 2, args, NULL);