Functionality to abandon multigrid controller (i.e. stop all threads)

Author: d-j-hatton

src/murfey/client/multigrid_control.py

@@ -122,6 +122,14 @@ async def dormancy_check(self):
                     log.warning(f"Could not delete database data for {self.session_id}")
                 self.dormant = True
 
+    def abandon(self):
+        for a in self.analysers.values():
+            a.request_stop()
+        for w in self._environment.watchers.values():
+            w.request_stop()
+        for p in self.rsync_processes.values():
+            p.request_stop()
+
     def finalise(self):
         for a in self.analysers.values():
             a.request_stop()

src/murfey/client/rsync.py

@@ -182,6 +182,10 @@ def stop(self):
             self.thread.join()
         logger.debug("RSync thread stop completed")
 
+    def request_stop(self):
+        self._stopping = True
+        self._halt_thread = True
+
     def finalise(
         self,
         thread: bool = True,