# -*- coding: utf-8 -*-
#14-6-11
# create by: snower

import logging
import traceback
from tornado import tcpserver
from thrift.server import TServer
from tornado.ioloop import IOLoop

class TTornadoServer(tcpserver.TCPServer):
    def __init__(self,processor,input_transport_factory,input_protocol_factory,output_transport_factory=None,output_protocol_factory=None):
        tcpserver.TCPServer.__init__(self)
        self.processor = processor
        self.input_transport_factory = input_transport_factory
        self.output_transport_factory = output_transport_factory or input_transport_factory
        self.input_protocol_factory = input_protocol_factory
        self.output_protocol_factory = output_protocol_factory or input_protocol_factory

    def handle_stream(self, stream, address):
        itrans = self.input_transport_factory.getTransport(stream)
        otrans = self.output_transport_factory.getTransport(stream)
        iprot = self.input_protocol_factory.getProtocol(itrans)
        oprot = self.output_protocol_factory.getProtocol(otrans)

        def next():
            self.io_loop.add_callback(process)

        def process():
            if itrans.isOpen():
                try:
                    self.processor.process(iprot, oprot,callback=next)
                    return
                except Exception:
                    logging.error("processor error:%s",traceback.format_exc())
            itrans.close()
            otrans.close()
        next()
# -*- coding: utf-8 -*-
#14-6-11
# create by: snower

import logging
import traceback
from tornado import tcpserver
from thrift.server import TServer
from tornado.ioloop import IOLoop

class TTornadoServer(tcpserver.TCPServer):
    def __init__(self,processor,input_transport_factory,input_protocol_factory,output_transport_factory=None,output_protocol_factory=None):
        super(tcpserver.TCPServer,self).__init__()
        self.processor = processor
        self.input_transport_factory = input_transport_factory
        self.output_transport_factory = output_transport_factory or input_transport_factory
        self.input_protocol_factory = input_protocol_factory
        self.output_protocol_factory = output_protocol_factory or input_protocol_factory

    def handle_stream(self, stream, address):
        itrans = self.input_transport_factory.getTransport(stream)
        otrans = self.output_transport_factory.getTransport(stream)
        iprot = self.input_protocol_factory.getProtocol(itrans)
        oprot = self.output_protocol_factory.getProtocol(otrans)

        def next():
            self.io_loop.add_callback(process)

        def process():
            if itrans.isOpen():
                try:
                    self.processor.process(iprot, oprot,callback=next)
                    return
                except Exception:
                    logging.error("processor error:%s",traceback.format_exc())
            itrans.close()
            otrans.close()
        next()
fix server