1.1 --- a/gmyth-stream/server/0.3/plugins/transcoders/gmencoder.py Wed Aug 15 23:06:55 2007 +0100
1.2 +++ b/gmyth-stream/server/0.3/plugins/transcoders/gmencoder.py Thu Aug 16 14:45:22 2007 +0100
1.3 @@ -13,6 +13,7 @@
1.4 import time
1.5
1.6 import select
1.7 +import fcntl
1.8
1.9 import lib.utils as utils
1.10 import lib.server as server
1.11 @@ -76,12 +77,27 @@
1.12 return False
1.13
1.14 try:
1.15 + #p = select.poll()
1.16 + #print outfd.fileno()
1.17 + #p.register (connection, select.POLLNVAL | select.POLLERR | select.POLLHUP)
1.18 while (self.proc and self.proc.poll() == None):
1.19 - r, w, x = select.select([self.proc.stdout], [], [], 0)
1.20 + r, w, x = select.select([self.proc.stdout], [], [], 1)
1.21 if self.proc.stdout in r:
1.22 progress = self.proc.stdout.readline()
1.23 if (progress.find ("PROGRESS") >= 0):
1.24 self.status = progress.split (":")[1]
1.25 + elif (progress.find ("Erro") >= 0):
1.26 + return False
1.27 + """
1.28 + try:
1.29 + print connection.getpeername()
1.30 + print connection.getsockname()
1.31 + except Esception, e:
1.32 + print "Lost Connection"
1.33 + self.stop ()
1.34 + return False
1.35 + """
1.36 +
1.37 except Exception, e:
1.38 self.log.error(self.tid, "Problems handling data: %s" % e)
1.39 return False