##// END OF EJS Templates
little bug fixed in kernelmanager's queues
Omar Andres Zapata Mesa -
Show More
@@ -18,10 +18,10 b' class SubSocketChannel2p(SubSocketChannel):'
18 self.queue.put(Message(msg))
18 self.queue.put(Message(msg))
19
19
20 def get_msg(self):
20 def get_msg(self):
21 return self.queue.get(timeout=0.1)
21 return self.queue.get()
22
22
23 def was_called(self):
23 def was_called(self):
24 return self.queue.not_empty()
24 return not self.queue.empty()
25
25
26 class XReqSocketChannel2p(XReqSocketChannel):
26 class XReqSocketChannel2p(XReqSocketChannel):
27 #---------------------------------------------------------------------------
27 #---------------------------------------------------------------------------
@@ -34,10 +34,10 b' class XReqSocketChannel2p(XReqSocketChannel):'
34 self.queue.put(Message(msg))
34 self.queue.put(Message(msg))
35
35
36 def get_msg(self):
36 def get_msg(self):
37 return self.queue.get(timeout=0.1)
37 return self.queue.get()
38
38
39 def was_called(self):
39 def was_called(self):
40 return self.queue.not_empty()
40 return not self.queue.empty()
41
41
42 class RepSocketChannel2p(RepSocketChannel):
42 class RepSocketChannel2p(RepSocketChannel):
43 #---------------------------------------------------------------------------
43 #---------------------------------------------------------------------------
General Comments 0
You need to be logged in to leave comments. Login now