# HG changeset patch
# User renatofilho
# Date 1176993709 -3600
# Node ID 00ecee7b96255d1b36a8df17172969cb113ac216
# Parent  644a526d408672bdd398af42798bbf657a8390aa
[svn r575] updated

diff -r 644a526d4086 -r 00ecee7b9625 gmyth-stream/server/0.2/plugins/transcoders/gstreamer.py
--- a/gmyth-stream/server/0.2/plugins/transcoders/gstreamer.py	Thu Apr 19 15:13:48 2007 +0100
+++ b/gmyth-stream/server/0.2/plugins/transcoders/gstreamer.py	Thu Apr 19 15:41:49 2007 +0100
@@ -42,6 +42,7 @@
 
     def __init__(self, params):
         server.Transcoder.__init__(self, params)
+        gobject.threads_init ()
         # set gstreamer basic options
         self.connection = None
         self.addr = None
@@ -56,7 +57,7 @@
         self.log.info("Opening Uri:" + uri)
         src = gst.element_make_from_uri(gst.URI_SRC, uri, "src")
         decode = gst.element_factory_make("decodebin", "decode")
-        mux = gst.element_factory_make("avimux", "mux")
+        mux = gst.element_factory_make("ffmux_mpeg", "mux")
         sink = gst.element_factory_make("fdsink", "sink")
 
         return [src, decode, mux, sink]
@@ -67,10 +68,13 @@
         vqueue = gst.element_factory_make("queue", "vqueue")
         colorspace = gst.element_factory_make("ffmpegcolorspace", "")
         vrate = gst.element_factory_make("videorate", "vrate")
-        vencode = gst.element_factory_make("ffenc_mpeg4", "vencode")
+        #vencode = gst.element_factory_make("ffenc_mpeg4", "vencode")
+        vencode = gst.element_factory_make("ffenc_mpeg1video", "vencode")
         vqueue_src = gst.element_factory_make("queue", "vqueue_src")
 
         vencode.set_property("bitrate", 200)
+        vencode.set_property ("pass", 2)
+        vencode.set_property ("quantizer", 5)
 
         if None in [vbin, vqueue, vrate, vencode, vqueue_src]:
             self.log.info("Fail to create video encode elements.")
@@ -122,22 +126,42 @@
     def _setup_audio_encode(self, abin):
         aqueue = gst.element_factory_make("queue", "aqueue")
         aconvert = gst.element_factory_make("audioconvert", "aconvert")
-        arate = gst.element_factory_make("audioresample", "arate")
-        aencode = gst.element_factory_make("queue", "aencode")
+        #aencode = gst.element_factory_make("queue", "aencode")
+        #aencode = gst.element_factory_make("ffenc_mp2", "aencode")
+        aencode = gst.element_factory_make("lame", "aencode")
         aqueue_src = gst.element_factory_make("queue", "aqueue_src")
-
-        if None in [abin, aqueue, arate, aencode, aqueue_src]:
+       
+        if None in [abin, aqueue, aencode, aqueue_src]:
             self.log.info("Fail to create video encode elements.")
             return False
 
-        abin.add(aqueue, aconvert, arate, aencode, aqueue_src)
+        #aencode.set_property ("bitrate", 32)            
+        #aencode.set_property ("vbr-quality", 2)
 
-        if not gst.element_link_many(aqueue,  aconvert, arate, aencode, aqueue_src):
+        abin.add(aqueue, aconvert, aencode, aqueue_src)
+
+        self.log.info ("Link queue -> aconvert")
+        if not aqueue.link (aconvert):
+            self.log.info("Fail to link queue video")
+            return False
+
+        self.log.info ("Link aconvert -> aencode")
+        if not aconvert.link (aencode):
             self.log.info("Fail to link video elements")
             return False
 
-        abin.add_pad(gst.GhostPad("sink", aqueue.get_pad("sink")))
-        abin.add_pad(gst.GhostPad("src", aqueue_src.get_pad("src")))
+        self.log.info ("Link aencode -> aqueue_src")
+        if not aencode.link (aqueue_src):
+            self.log.info("Fail to link aencode -> aqueue_src")
+            return False
+
+        self.log.info ("Link:OK")
+
+        ghost_sink = gst.GhostPad("sink", aqueue.get_pad("sink"))
+        ghost_src = gst.GhostPad("src", aqueue_src.get_pad("src"))
+        #ghost_src.set_caps (gst.caps_from_string ("audio/mpeg,mpegversion=(int)1,layer=(int)3,rate=(int)32000"))
+        abin.add_pad(ghost_sink)
+        abin.add_pad(ghost_src)
 
         return True
     # _setup_audio_encode()
@@ -208,6 +232,7 @@
     def __on_bus_message(self, bus, message, stream_data):
 
         t = message.type
+        self.log.info ("__on_bus_message")
 
         if t == gst.MESSAGE_STATE_CHANGED:
             oldstate = -1
@@ -230,14 +255,18 @@
 
         elif t == gst.MESSAGE_EOS:
             self.log.info("Pipe finished")
-            stream_data.Loop.quit()
-            self.quit = True
+            if stream_data.Ready:
+                self.stop()
+            else:
+                stream_data.Loop.quit()
 
         elif t == gst.MESSAGE_ERROR:
             err, debug = message.parse_error()
             self.log.error("Error: %s %s" %(err, debug))
-            stream_data.Loop.quit()
-            stream_data.Ready = False
+            if stream_data.Ready:
+                self.stop()
+            else:
+                stream_data.Loop.quit()
 
         return True
     # __on_bus_message()
@@ -270,7 +299,8 @@
     def start(self, outfd):
         params_first = self.params_first
 
-        self.setup(params_first("uri", ""), params_first("mux", "avi"),
+        uri = '%s://%s' % (params_first("uri_prefix", ""), params_first("uri_path", ""))
+        self.setup(uri, params_first("mux", "avi"),
                    params_first("vcodec", "ffenc_h263p"), params_first("vbitrate", 256000),
                    params_first("fps", 25),  params_first("acodec", "faac"),
                    params_first("abitrate", 192000),  params_first("width", 320),
@@ -282,12 +312,7 @@
         self.stream_data.Pipe.set_state(gst.STATE_PLAYING)
 
         # keep playing until EOS
-        self.log.info("QUIT: %s" % self.quit)
-
-        i = 0
-        loop = gobject.MainLoop()
-        loop.run()
-
+        self.stream_data.Loop.run()
         self.log.info("quit loop")
 
         return True
@@ -298,8 +323,9 @@
 
         if self.stream_data:
             self.stream_data.Pipe.set_state(gst.STATE_NULL)
-            self.quit = True
 
+        self.stream_data.Ready = False
+        self.stream_data.Loop.quit ()
         del self.stream_data
         self.stream_data = None
     # stop