equal
deleted
inserted
replaced
237 self.spinwakeuptimer = None |
237 self.spinwakeuptimer = None |
238 self.spinwakeupcond.notify() |
238 self.spinwakeupcond.notify() |
239 |
239 |
240 def spin(self): |
240 def spin(self): |
241 start = time.time() |
241 start = time.time() |
242 while not self.finishsem.acquire(0): |
242 if self.logger: |
243 with self.spinwakeuplock: |
243 while not self.finishsem.acquire(0): |
244 self.spinwakeuptimer = Timer(0.1, self.spinwakeup) |
244 with self.spinwakeuplock: |
245 self.spinwakeuptimer.start() |
245 self.spinwakeuptimer = Timer(0.1, self.spinwakeup) |
246 self.spinwakeupcond.wait() |
246 self.spinwakeuptimer.start() |
247 self.logger.progress("%.3fs"%(time.time() - start)) |
247 self.spinwakeupcond.wait() |
|
248 self.logger.progress("%.3fs"%(time.time() - start)) |
|
249 else: |
|
250 self.finishsem.acquire() |
248 |
251 |
249 return [self.exitcode, "".join(self.outdata), "".join(self.errdata)] |
252 return [self.exitcode, "".join(self.outdata), "".join(self.errdata)] |