| 342 # TODO: Decide exact (manual) abort mechanism. Perhaps two stages |
342 # TODO: Decide exact (manual) abort mechanism. Perhaps two stages |
| 343 def abort(self): |
343 def abort(self): |
| 344 with self.lock: |
344 with self.lock: |
| 345 if self.borg_instance: |
345 if self.borg_instance: |
| 346 self.borg_instance.terminate() |
346 self.borg_instance.terminate() |
| 347 thread_log=self.thread_log |
347 #thread_log=self.thread_log |
| 348 thread_res=self.thread_res |
348 #thread_res=self.thread_res |
| 349 |
349 |
| 350 if thread_log: |
350 #if thread_log: |
| 351 thread_log.terminate() |
351 # thread_log.terminate() |
| 352 |
352 |
| 353 if thread_res: |
353 #if thread_res: |
| 354 thread_res.terminate() |
354 # thread_res.terminate() |
| 355 |
355 |
| 356 |
356 |
| 357 def join(self): |
357 def join(self): |
| 358 logger.debug('Waiting for borg listener threads to terminate') |
358 logger.debug('Waiting for borg listener threads to terminate') |
| 359 |
359 |