mtunnel.py 文件源码

def __init__(self, markov, sock):
            self.read_buffer = ''
            self.markov = markov
            #self.msock = MTunnelServer.ToRemoteServer(markov, self, msock)
            self.msock = None
            self.state = 0
            asyncore.dispatcher_with_send.__init__(self, sock)
            self.state_lock = threading.RLock()