rec10/branches/0.4/src/rec10gridserver.py

   1 #!/usr/bin/python
   2 # coding: UTF-8
   3 # Rec10 TS Recording Tools
   4 # Copyright (C) 2009 Yukikaze
   5 from SocketServer import *
   6 import recdb
   7 import configreader
   8 RECV_BUF = 8192
   9
  10 class Handler(BaseRequestHandler):
  11     """
  12     This is a server to encode ts files in another pc.
  13
  14     """
  15     def handle(self):
  16         print "connect from:", self.client_address
  17         cons=getTask()
  18         print cons+" is sent"
  19         self.request.send(cons)
  20         """while True:
  21             #ret = self.request.recv(RECV_BUF)
  22             #if len(ret) == 0:
  23             #    break
  24             self.request.send()
  25
  26             """
  27         self.request.close()
  28
  29 def getTask():
  30     tasks=recdb.getnow("1")
  31     rett=""
  32     for task in tasks:
  33         if task["type"]=="ts2avi":
  34             title=task['title']
  35             opt=task['opt']
  36             btime=task['btime']
  37             etime=task['etime']
  38             chtxt=task['chtxt']
  39             recdb.del_reckey("ts2avi", title, chtxt, btime)
  40             recdb.rec_reckey("grid", title, chtxt, btime, etime, opt)
  41             rett="title="+title+","+"opt="+opt+";"
  42             break
  43     return rett
  44 def main():
  45     port=int(configreader.getpath("gridserver_port"))
  46     sv = ThreadingTCPServer(('', port), Handler)
  47     print "This is a Rec10 GridServer."
  48     print "Waiting for connections at port"+str(port)
  49     print 'listen to:', sv.socket.getsockname()
  50     sv.serve_forever()
  51
  52 if __name__ == '__main__': main()