|
@@ -56,15 +56,14 @@ def connect_success(sock): |
|
@@ -56,15 +56,14 @@ def connect_success(sock): |
|
56
|
monitor._socket.quit() # 旧的断开
|
56
|
monitor._socket.quit() # 旧的断开
|
|
57
|
monitor._temp_socket = None # 清除临时变量
|
57
|
monitor._temp_socket = None # 清除临时变量
|
|
58
|
|
58
|
|
|
59
|
- monitor.bind(sock)
|
|
|
|
60
|
- monitor._init_server_()
|
|
|
|
61
|
-
|
59
|
+ monitor.bind(sock) # 替换Sock
|
|
|
|
60
|
+ monitor.initialize() # 发送初始化消息
|
|
62
|
monitor._socket.new_server_func = functools.partial(
|
61
|
monitor._socket.new_server_func = functools.partial(
|
|
63
|
control_server.get_ws_address,
|
62
|
control_server.get_ws_address,
|
|
64
|
monitor._name,
|
63
|
monitor._name,
|
|
65
|
sock.ws_url
|
64
|
sock.ws_url
|
|
66
|
- )
|
|
|
|
67
|
- monitor._socket.server_replace = server_replace
|
65
|
+ ) # 设置获取新服务器的函数
|
|
|
|
66
|
+ monitor._socket.server_replace = server_replace # 设置开启新服务器的逻辑
|
|
68
|
|
67
|
|
|
69
|
|
68
|
|
|
70
|
def run():
|
69
|
def run():
|