We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e20285b commit 225234aCopy full SHA for 225234a
1 file changed
jade/jade_threading.py
@@ -29,12 +29,15 @@ def run(self):
29
self.handlequeue.put(haspStruct.handle)
30
while haspStruct.status == 0:
31
haspStruct, feature_id = self.pyldk.login()
32
- if self.handlequeue.qsize() == self.max_session_size:
33
- self.logout()
34
- self.handlequeue.put(haspStruct.handle)
35
- if self.ldkqueue.qsize() > 0:
36
- self.ldkqueue.get()
37
- self.ldkqueue.put((self.pyldk,haspStruct.handle))
+ if haspStruct.status == 0:
+ if self.handlequeue.qsize() == self.max_session_size:
+ self.logout()
+ self.handlequeue.put(haspStruct.handle)
+ if self.ldkqueue.qsize() > 0:
+ self.ldkqueue.get()
38
+ self.ldkqueue.put((self.pyldk, haspStruct.handle))
39
+ else:
40
+ break
41
if self.pyldk.get_ldk(feature_id) is False:
42
break
43
else:
0 commit comments