def init_handler():
""" sub-process init handler """
signal.signal(signal.SIGINT, signal.SIG_DFL)
signal.signal(signal.SIGTERM, signal.SIG_DFL)
signal.signal(signal.SIGHUP, signal.SIG_DFL)
signal.signal(signal.SIGUSR1, debug)
def main():
""" The main entrance """
port = sys.argv[1]
signal.signal(signal.SIGINT, exit_signal_handler)
signal.signal(signal.SIGTERM, exit_signal_handler)
signal.signal(signal.SIGHUP, exit_signal_handler)
signal.signal(signal.SIGUSR1, debug)
gc.set_threshold(20000, 10, 10)
handler = MaitreyaHandler()
processor = Maitreya.Processor(handler)
transport = TSocket.TServerSocket(port=port)
tfactory = TTransport.TBufferedTransportFactory()
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
# server = TProcessPoolServer(processor, transport, tfactory, pfactory)
server = TGeventServer.TGeventProcessPoolServer(processor, transport, tfactory, pfactory)
server.setNumWorkers(WORKER_NUM)
server.setPostForkCallback(init_handler)
print "server started..."
server.serve()