rec10/trunk/src/gridserver.py

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