2011-09-15 21 views
1

我正尝试使用gstreamer和icecast投射电脑生成的视频,但无法使gstreamer appsrc正常工作。如果我使用xvimagesink作为接收器,我的应用程序按预期工作(请参阅下面的注释代码)。但是,一旦我将它输入到theoraenc它不会运行。gstreamer appsrc适用于xvimagesink,但不适用于theoraenc! oggmux

我使用filesink交换了shout2send以检查问题是否是icecast,结果是没有数据写入文件。将appsrc替换为testvideosrc将按预期工作。任何建议?

#!/usr/bin/env python 
import sys, os, pygtk, gtk, gobject 
import pygst 
pygst.require("0.10") 
import gst 
import numpy as np 

class GTK_Main: 
    def __init__(self): 
     window = gtk.Window(gtk.WINDOW_TOPLEVEL) 
     window.connect("destroy", gtk.main_quit, "WM destroy") 
     vbox = gtk.VBox() 
     window.add(vbox) 
     self.button = gtk.Button("Start") 
     self.button.connect("clicked", self.start_stop) 
     vbox.add(self.button) 
     window.show_all() 

     self.player = gst.Pipeline("player") 
     source = gst.element_factory_make("appsrc", "source") 
     caps = gst.Caps("video/x-raw-gray,bpp=16,endianness=1234,width=320,height=240,framerate=(fraction)10/1") 
     source.set_property('caps',caps) 
     source.set_property('blocksize',320*240*2) 
     source.connect('need-data', self.needdata) 
     colorspace = gst.element_factory_make('ffmpegcolorspace') 
     enc = gst.element_factory_make('theoraenc') 
     mux = gst.element_factory_make('oggmux') 
     shout = gst.element_factory_make('shout2send') 
     shout.set_property("ip","localhost") 
     shout.set_property("password","hackme") 
     shout.set_property("mount","/stream") 
     caps = gst.Caps("video/x-raw-yuv,width=320,height=240,framerate=(fraction)10/1,format=(fourcc)I420") 
     enc.caps = caps 
     videosink = gst.element_factory_make('xvimagesink') 
     videosink.caps = caps 

     self.player.add(source, colorspace, enc, mux, shout) 
     gst.element_link_many(source, colorspace, enc, mux, shout) 
     #self.player.add(source, colorspace, videosink) 
     #gst.element_link_many(source, colorspace, videosink) 

    def start_stop(self, w): 
     if self.button.get_label() == "Start": 
      self.button.set_label("Stop") 
      self.player.set_state(gst.STATE_PLAYING) 
     else: 
      self.player.set_state(gst.STATE_NULL) 
      self.button.set_label("Start") 

    def needdata(self, src, length): 
     bytes = np.int16(np.random.rand(length/2)*30000).data 
     src.emit('push-buffer', gst.Buffer(bytes)) 

GTK_Main() 
gtk.gdk.threads_init() 
gtk.main() 
+0

如果您为了调试目的而将代码提取到gst管道中,可能会更容易。 – Dejan

+0

也请告诉您如何连接到流。我试过了: gst-launch-0.10 souphttpsrc location =“http:// source:[email protected]:8000/stream”! decodebin2! xvimagesink 但是propit在libproxy中遇到了一个问题:/ 也许你可以看一下调试日志(使用GST_DEBUG =“*:3”运行你的应用程序,适合初学者。 – ensonic

回答

1

我认为你的问题最有可能与缓冲区的时间戳有关。我做了一些快速测试,使用该代码并用oggdemux,theoradec,ffmpegcolorspace和ximagesink替换了shout元素。起初,我没有输出,但是在完全省去了多路复用/解复用之后,我得到了一个静态图像以及一些关于时间戳的调试消息。在appsrc上将is-live和do-timestamp属性设置为true后,我得到了正确的输出结果。

我认为它应该可以直接设置缓存中的时间戳,你正在推出appsrc,但唉,我还没有发现如何做到这一点。

相关问题