1010from jade .jade_tools import *
1111from queue import Queue
1212class MonitorLDKThread (Thread ):
13- def __init__ (self ,pyldk ,JadeLog ,ldkqueue ,time = 60 * 60 ,max_session_size = 1 ):
13+ def __init__ (self ,pyldk ,JadeLog ,ldkqueue ,time = 60 * 60 ,max_session_size = 1 , feature_id = None ):
1414 self .pyldk = pyldk
1515 self .JadeLog = JadeLog
1616 self .ldkqueue = ldkqueue
1717 self .time = time
1818 self .max_session_size = max_session_size
19+ self .feature_id = feature_id
1920 self .handlequeue = Queue (maxsize = max_session_size )
2021 super (MonitorLDKThread , self ).__init__ ()
2122 self .start ()
@@ -29,6 +30,8 @@ def run(self):
2930 self .handlequeue .put (haspStruct .handle )
3031 while haspStruct .status == 0 :
3132 haspStruct , feature_id = self .pyldk .login ()
33+ if self .feature_id is None :
34+ self .feature_id = feature_id
3235 if haspStruct .status == 0 :
3336 if self .handlequeue .qsize () == self .max_session_size :
3437 self .logout ()
@@ -38,7 +41,7 @@ def run(self):
3841 self .ldkqueue .put ((self .pyldk , haspStruct .handle ))
3942 else :
4043 break
41- if self .pyldk .get_ldk (feature_id ) is False :
44+ if self .pyldk .get_ldk (self . feature_id ) is False :
4245 break
4346 else :
4447 self .JadeLog .DEBUG ("加密狗监听正常" )
0 commit comments