borgend/backup.py

changeset 106
a7bdc239ef62
parent 104
d33e2d7dbeb1
child 107
f63835e9f29e
--- a/borgend/backup.py	Sun Feb 04 14:37:09 2018 +0000
+++ b/borgend/backup.py	Mon Feb 05 10:25:17 2018 +0000
@@ -17,6 +17,7 @@
 from .dreamtime import MonotonicTime, DreamTime, RealTime
 from .instance import BorgInstance
 from .scheduler import TerminableThread
+from .exprotect import protect_noreturn
 
 _logger=logging.getLogger(__name__)
 
@@ -294,6 +295,7 @@
         running=self.is_running()
         assert(not running)
 
+    @protect_noreturn
     def __log_listener(self):
         self.logger.debug('Log listener thread waiting for entries')
         success=True
@@ -385,6 +387,7 @@
 
         self.logger.debug('Borg subprocess terminated; terminating log listener thread')
 
+    @protect_noreturn
     def __result_listener(self):
         self.logger.debug('Result listener thread waiting for result')
 
@@ -545,6 +548,7 @@
         self.thread_log=None
         self.borg_instance=None
 
+    @protect_noreturn
     def __main_thread(self):
         with self._cond:
             while not self._terminate:

mercurial