cam

from PyQt4 import QtCore
import gst

class camThread(QtCore.QThread):

    def __init__(self,windowId):
        QtCore.QThread.__init__(self)
        self.windowId =windowId
        self.player = gst.parse_launch("udpsrc port=5000 !  application/x-rtp, encoding-name=H264, payload=96 !  rtph264depay ! h264parse ! ffdec_h264 ! autovideosink")
        bus = self.player.get_bus()
        bus.add_signal_watch()
        bus.enable_sync_message_emission()

        bus.connect("sync-message::element", self.on_sync_message)
        self.bus = bus



    def on_sync_message(self, bus, message):
        print "akash 123"
        if message.structure is None:
            return
        message_name = message.structure.get_name()
        if message_name == "prepare-xwindow-id":
            win_id = self.windowId
            assert win_id
            imagesink = message.src
            imagesink.set_property("force-aspect-ratio", True)
            imagesink.set_xwindow_id(win_id)

    def run(self):
        self.player.set_state(gst.STATE_PLAYING)
        msg = self.bus.timed_pop_filtered(gst.CLOCK_TIME_NONE,
                                     gst.MESSAGE_ERROR | gst.MESSAGE_EOS)
        self.flag = True
        while(True):
            if(self.flag==False):
                break

    def quit(self):
        self.flag = False
        self.player.set_state(gst.STATE_NULL)

        #self.cap.release()