Fixing SIGINT for MPI

cs01 · incardon · Aug 1, 2020 · Aug 3, 2020 · Aug 7, 2020 · Aug 13, 2020
commit 6af6f3f05fe1a7150deb3577994a3478544a486b
diff --git a/gdbgui/server/app.py b/gdbgui/server/app.py
@@ -334,6 +334,11 @@ def process_controllers_out():
                 """Attach processor information"""
                 for r in response:
                     r["proc"] = debug_session.mpi_rank
+                    if r["type"] == "notify":
+                        if r["message"] == "thread-group-started":
+                            debug_session.inferior_pid = int(r["payload"]["pid"])
+
+                # Here we parse for thread-group-started to get the inferior_pid
 
                 for client_id in client_ids:
                     logger.info("emiting message to websocket client id " + client_id)

diff --git a/gdbgui/server/sessionmanager.py b/gdbgui/server/sessionmanager.py
@@ -36,6 +36,7 @@ def __init__(
         self.start_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
         self.client_ids: Set[str] = set()
         self.mpi_rank = -1
+        self.inferior_pid = -1
 
     def terminate(self):
         if self.pid:
@@ -186,9 +187,9 @@ def debug_session_from_mpi_processor_id(
 
         return None
 
-    def send_signal_to_all_debug_sessions_processes(self):
-        for debug_session in self.to_dict().items():
-            print("PROCESS ID: " + debug_session["pid"])
+    def send_signal_to_all_debug_sessions_processes(self, signal_id: int):
+        for debug_session, _ in self.debug_session_to_client_ids.items():
+            os.kill(debug_session.inferior_pid, signal_id)
 
     def exit_all_gdb_processes_except_client_id(self, client_id: str):
         logger.info("exiting all subprocesses except client id")