Lines Matching refs:dataq

14 def server(evt, serv, dataq=None):  argument
24         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()
150         self.dataq.put(want)
155         self.dataq.join()
162         self.dataq.put(want)
165         self.dataq.join()
175         self.dataq.put(want)
177         self.dataq.join()
182         self.dataq.put([self.block_long, EOF_sigil])
183         self.dataq.join()
192         self.dataq.put([EOF_sigil])
194         self.dataq.join()
205         self.dataq.put(want)
207         self.dataq.join()
213         self.dataq.put([EOF_sigil])
215         self.dataq.join()
229         self.dataq.put(want)
231         self.dataq.join()
244         self.dataq.put([EOF_sigil])
246         self.dataq.join()
265         self.dataq.put([EOF_sigil])
267         self.dataq.join()
274         self.dataq.put(want)
276         self.dataq.join()
296         self.dataq.put(want)
298         self.dataq.join()
340         self.dataq.put(data)
342         self.dataq.join()
356         self.dataq.put([EOF_sigil])
358         self.dataq.join()
378         self.dataq.put(send)
380         self.dataq.join()
394         self.dataq = Queue.Queue()
399                                                             self.dataq))
417         self.dataq.put(want)
419         self.dataq.join()
426         self.dataq.put(want)
428         self.dataq.join()
436         self.dataq.put(want)
441         self.dataq.join()
448         self.dataq.put(want)
451         self.dataq.join()