Searched refs:dataq (Results 1 – 1 of 1) sorted by relevance
14 def server(evt, serv, dataq=None): argument24 if dataq:26 new_data = dataq.get(True, 0.5)27 dataq.task_done()105 self.dataq = Queue.Queue()109 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))131 self.dataq.put(want)133 self.dataq.join()140 self.dataq.put(want)142 self.dataq.join()[all …]