session_worker.py 文件源码

def _init_websock(self):
        #create the tornado websocket client
        params = self._param_bc.value
        param_server_host = params['param_server_host']
        param_server_port = params['param_server_port']
        self._websock = yield websocket.websocket_connect('ws://%s:%d' % (param_server_host, param_server_port), connect_timeout=3600)