gmythstreamer.py 文件源码

def _register_io_handlers(self):
        def handler(source, cond):
            if cond & gobject.IO_IN:
                if not self.fifo:
                    self.fifo = open(self.fifo_name, "w")

                self.fifo.write(source.recv(1024))
                return True
            else:
                self.log.debug("Error communicating with MPlayer")
                return False

        flags = gobject.IO_IN | gobject.IO_ERR | gobject.IO_HUP
        self.io_watcher_id = gobject.io_add_watch(self.data,
                                                  flags,
                                                  handler)
    # _register_io_handlers()