| 317 op=self.scheduled_operation |
317 op=self.scheduled_operation |
| 318 if not op: |
318 if not op: |
| 319 self.logger.debug("Queued operation aborted") |
319 self.logger.debug("Queued operation aborted") |
| 320 else: |
320 else: |
| 321 self.scheduled_operation=None |
321 self.scheduled_operation=None |
| |
322 |
| |
323 self.__launch(op) |
| |
324 |
| 322 self.current_operation=op |
325 self.current_operation=op |
| 323 self.current_operation['when_monotonic']=time.monotonic() |
326 self.current_operation['when_monotonic']=time.monotonic() |
| 324 |
|
| 325 self.__launch(op) |
|
| 326 |
|
| 327 self.state=ACTIVE |
327 self.state=ACTIVE |
| 328 self.__update_status() |
328 self.__update_status() |
| 329 |
329 |
| 330 |
330 |
| 331 def __main_thread(self): |
331 def __main_thread(self): |