|
|
|
@ -2324,12 +2324,15 @@ def client_post_auth(client):
|
|
|
|
|
|
|
|
|
|
class ClientSignal(QtCore.QThread):
|
|
|
|
|
sid_sig = QtCore.Signal(int, int)
|
|
|
|
|
connect_count = QtCore.Signal(str, int, int)
|
|
|
|
|
def __init__(self, ClientObj):
|
|
|
|
|
QtCore.QThread.__init__(self)
|
|
|
|
|
self.ClientObj = ClientObj
|
|
|
|
|
self.connect_count.connect(ClientObj._parent.connect_count_changed)
|
|
|
|
|
|
|
|
|
|
def run(self):
|
|
|
|
|
self.exit_flag = False
|
|
|
|
|
has_connect = None
|
|
|
|
|
try:
|
|
|
|
|
client_active = self.ClientObj.VarsApi.Get \
|
|
|
|
|
('cl_core_client_active_period')
|
|
|
|
@ -2346,6 +2349,16 @@ class ClientSignal(QtCore.QThread):
|
|
|
|
|
reply = 2
|
|
|
|
|
except Exception, e:
|
|
|
|
|
show_msg (e.message, 'no connection to server!')
|
|
|
|
|
if reply == 0:
|
|
|
|
|
if not has_connect:
|
|
|
|
|
self.connect_count.emit(self.ClientObj.host_name,
|
|
|
|
|
self.ClientObj.port, 1)
|
|
|
|
|
has_connect = True
|
|
|
|
|
else:
|
|
|
|
|
if has_connect:
|
|
|
|
|
self.connect_count.emit(self.ClientObj.host_name,
|
|
|
|
|
self.ClientObj.port, -1)
|
|
|
|
|
has_connect = False
|
|
|
|
|
self.sid_sig.emit(sid, reply)
|
|
|
|
|
for i in range (5):
|
|
|
|
|
time.sleep(float(client_active)/15.0)
|
|
|
|
|