make sure MonitorGroup gRPC server stops gracefully

Signed-off-by: Alexander Indenbaum <[email protected]>
ceph · Dec 18, 2023 · 49c840e · 49c840e
1 parent 919847a
commit 49c840e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/control/server.py b/control/server.py
@@ -120,8 +120,10 @@ def _wait_for_group_id(self):
         self.logger.info(f"MonitorGroup server is listening on {self._monitor_address()} for group id")
         self.monitor_event.wait()
         self.monitor_event = None
-        self.logger.info("Stopping the monitor server...")
-        self.monitor_server.stop(None)
+        self.logger.info("Stopping the MonitorGroup server...")
+        grace = self.config.getfloat_with_default("gateway", "monitor_stop_grace", 1/1000)
+        self.monitor_server.stop(grace).wait()
+        self.logger.info("The MonitorGroup gRPC server stopped...")
         self.monitor_server = None
 
     def serve(self):