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): |