gmyth: gmyth-stream/server/0.2/plugins/transcoders/gmencoder.py@0469baf4217c

     1 import os

     2 import shlex

     3 import signal

     4 import subprocess

     6 import lib.utils as utils

     7 import lib.server as server

     9 __all__ = ("TranscoderGMencoder",)

    11 class TranscoderGMencoder(server.Transcoder):

    12     gmencoder_path = utils.which("gmencoder")

    13     name = "gmencoder"

    14     priority = -1

    15     proc = None

    17     def __init__(self, params):

    18         server.Transcoder.__init__(self, params)

    19         self.opts = []

    20     # __init__()

    22     def _insert_param (self, name, value):

    23         if (value != ""):

    24             self.opts.append(name)

    25             self.opts.append(value)

    27     def _parser_params (self):

    28         self._insert_param("-i", \

    29             "%s://%s" % (self.params_first("uri_prefix", "file"), self.params_first("uri_path", "")))

    30         self._insert_param("--video-encode", self.params_first("ve", ""))

    31         self._insert_param("--video-opts", "bitrate=200,pass=2,quantizer=5")

    32         self._insert_param("--video-fps", self.params_first("fps", ""))

    33         self._insert_param("--video-width", self.params_first("width", ""))

    34         self._insert_param("--video-height", self.params_first("height", ""))

    35         self._insert_param("--audio-rate", "32000")

    36         self._insert_param("--audio-encode", self.params_first("ae", ""))

    37     # _parse_params

    39     def start(self, outfd):

    40         self.opts.append (self.gmencoder_path)

    41         self._parser_params ()

    42         self._insert_param ("-o", "fd://%d" % outfd.fileno())

    44         cmd = " ".join(self.opts)

    45         self.log.info ("GMencoder: %s", cmd)

    47         try:

    48             self.proc = subprocess.Popen(self.opts, stdin=subprocess.PIPE)

    49         except Exception, e:

    50             self.log.error("Error executing GMencoder: %s" % e)

    51             return False

    53         try:

    54              self.proc.wait()

    55         except Exception, e:

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

    57             return False

    59         return True

    60     # start()

    63     def stop(self):

    64         if self.proc:

    65             self.log.info ("STOPed GMencoder plugin")

    66             try:

    67                 self.proc.stdin.write ("QUIT\n")

    68             except Exception, e:

    69                 pass

    71             try:

    72                 self.proc.wait()

    73             except Exception, e:

    74                 pass

    76             self.proc = None

    77     # stop()

    79 # TranscoderGMencoder

author	rosfran
	Tue May 15 22:14:04 2007 +0100 (2007-05-15)
branch	trunk
changeset 657	0469baf4217c
parent 595	5c5cff842d57
child 672	4e623a4274a1
permissions	-rw-r--r--