1
This commit is contained in:
parent
7250700376
commit
dfc57226ea
@ -39,6 +39,7 @@ class ClientSide:
|
|||||||
'remoteConnIdx' : idx,
|
'remoteConnIdx' : idx,
|
||||||
'data' : str(base64.b64encode(data))
|
'data' : str(base64.b64encode(data))
|
||||||
})
|
})
|
||||||
|
break
|
||||||
except:
|
except:
|
||||||
print('qqqqq', flush=True)
|
print('qqqqq', flush=True)
|
||||||
break
|
break
|
||||||
@ -52,10 +53,8 @@ class ClientSide:
|
|||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
data += yield self.remote_conn.read_message()
|
data += yield self.remote_conn.read_message()
|
||||||
print(data, flush=True)
|
|
||||||
if not data:
|
if not data:
|
||||||
continue
|
continue
|
||||||
print(data, flush=True)
|
|
||||||
lines = data.split('\n')
|
lines = data.split('\n')
|
||||||
if data[-1] == '\n':
|
if data[-1] == '\n':
|
||||||
data = lines[-1]
|
data = lines[-1]
|
||||||
|
@ -165,7 +165,7 @@ class RemoteServer(tornado.tcpserver.TCPServer):
|
|||||||
if not app.addRemoteConn(conn):
|
if not app.addRemoteConn(conn):
|
||||||
stream.close()
|
stream.close()
|
||||||
return
|
return
|
||||||
await tornado.gen.sleep(2)
|
await tornado.gen.sleep(0.3)
|
||||||
if not app.isConnectOk(conn.idx):
|
if not app.isConnectOk(conn.idx):
|
||||||
stream.close()
|
stream.close()
|
||||||
return
|
return
|
||||||
|
Loading…
x
Reference in New Issue
Block a user