gmyth: gmyth-stream/server/0.2/plugins/transcoders/mencoder

     1 import os

     2 import subprocess

     3 import fcntl

     5 import lib.utils as utils

     6 import lib.server as server

     8 from select import select

    10 def _setup_mythfilename(self):

    11     # mythtv:mythtv@192.168.3.110:6543/1002_20070426230000.nuv

    12     try:

    13         _mysql = self.args["input"].split("@")[0].split(":")

    14     except IndexError, e:

    15         _mysql = ["mythtv", "mythtv"]

    17     try:

    18         _args = self.args["input"].split("@")[1].split(":")

    19     except IndexError, e:

    20         _args = self.args["input"].split(":")

    22     gmyth_dict = {}

    23     gmyth_dict["mysql"] = _mysql

    24     gmyth_dict["backend"] = _args[0]

    25     gmyth_dict["port"] = _args[1].split("/", 1)[0]

    27     _tmp_file = _args[1].split("/", 1)[1]

    29     if _tmp_file.find("channel") >= 0:

    30         gmyth_dict["kind"] = "c"

    31         gmyth_dict["cfile"] = _tmp_file.split("=")[1]

    32     else:

    33         gmyth_dict["kind"] = "f"

    34         gmyth_dict["cfile"] = _tmp_file

    36     self.args["input"] = "-"

    37     return gmyth_dict

    38 # _setup_mythfilename

    40 def _setup_mythfile(err):

    41     size = err.readline().split("Size:")[1]

    42     flags = fcntl.fcntl (err, fcntl.F_GETFL, 0) | os.O_NONBLOCK

    43     fcntl.fcntl(err, fcntl.F_SETFL, flags)

    44     return size

    45 # _setup_mythfile

    47 def _setup_gmythcat(self):

    48     gmyth_cat = utils.which("gmyth-cat")

    49     return [ utils.which("gmyth-cat"),

    50             "-h", self.args["gmyth-cat"]["backend"],

    51             "-p", self.args["gmyth-cat"]["port"],

    52             "-" + self.args["gmyth-cat"]["kind"],

    53             self.args["gmyth-cat"]["cfile"]

    54            ]

    55 # _setup_gmythcat

    57 def start_myth(self, outfd):

    58     opts = _setup_gmythcat(self)

    59     try:

    60         self.gmyth = subprocess.Popen(opts, stdout=subprocess.PIPE,

    61                                       stderr=subprocess.PIPE,

    62                                       close_fds=True)

    63     except Exception, e:

    64         self.log.error("Error executing gmyth-cat: %s" % e)

    65         return False

    67     if not self._run_mencoder(input=self.gmyth.stdout,

    68                               output=subprocess.PIPE):

    69         return False

    71     if self.args["gmyth-cat"]["kind"] == "f":

    72         try:

    73             size = _setup_mythfile(self.gmyth.stderr)

    74             self.log.debug("Size of file: %s" % size)

    75         except Exception, e:

    76             self.log.error("Problems getting size of file: %s" % e)

    77             return False

    79     try:

    80         while self.proc and self.proc.poll() == None:

    81             r, w, x = select([self.gmyth.stderr, self.proc.stdout],

    82                              [], [], 0)

    83             if self.proc.stdout in r:

    84                 d = self.proc.stdout.read(4096)

    85                 outfd.write(d)

    87             if self.gmyth.stderr in r:

    88                 partial = self.gmyth.stderr.read(50).split("\n")[-2]

    89                 if partial != "":

    90                     self.status = utils.progress_bar(self.log,

    91                                                      int(partial),

    92                                                      int(size), 50)

    94     except IndexError, e:

    95         pass

    96     except Exception, e:

    97         self.log.error("Problems handling data: %s" % e)

    98         return False

   100     self.log.info("Finished sending data")

   101     return True

   102 # _start_myth()

author	melunko
	Thu May 24 21:14:40 2007 +0100 (2007-05-24)
branch	trunk
changeset 708	eaa6e1c5fab2
parent 682	367d791aeb57
child 717	24db16480456
permissions	-rw-r--r--