(self, timeout_secs)
| 28 | class WatcherThread(threading.Thread): |
| 29 | |
| 30 | def __init__(self, timeout_secs): |
| 31 | threading.Thread.__init__(self) |
| 32 | self.timeout_secs = timeout_secs |
| 33 | self.completed = False |
| 34 | self.condition = threading.Condition() |
| 35 | self.daemon = True |
| 36 | self.caller_thread = threading.current_thread() |
| 37 | |
| 38 | def run(self): |
| 39 | started = time.time() |