]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/cephadm: avoid repeated calls to get_module_option 44134/head
authorSage Weil <sage@newdream.net>
Mon, 29 Nov 2021 20:51:26 +0000 (15:51 -0500)
committerSage Weil <sage@newdream.net>
Mon, 29 Nov 2021 21:34:48 +0000 (16:34 -0500)
We already stash these as MgrModule members.

Signed-off-by: Sage Weil <sage@newdream.net>
src/pybind/mgr/cephadm/module.py
src/pybind/mgr/cephadm/serve.py
src/pybind/mgr/cephadm/services/cephadmservice.py

index db7568a3e980fead33035601414d80c473cf773e..a618e9a616538c50be35d2364718faf39f24214b 100644 (file)
@@ -426,6 +426,7 @@ class CephadmOrchestrator(orchestrator.Orchestrator, MgrModule,
             self.agent_starting_port = 0
             self.apply_spec_fails: List[Tuple[str, str]] = []
             self.max_osd_draining_count = 10
+            self.device_enhanced_scan = False
 
         self.notify('mon_map', None)
         self.config_notify()
@@ -2216,7 +2217,7 @@ Then run the following:
             except Exception:
                 pass
             deps = sorted([self.get_mgr_ip(), server_port, root_cert,
-                           str(self.get_module_option('device_enhanced_scan'))])
+                           str(self.device_enhanced_scan)])
         elif daemon_type == 'iscsi':
             deps = [self.get_mgr_ip()]
         else:
index e4fd8f91d972ae4c2df686d844545b4ba87b85b9..5a93880138dd3ea67e32c9a47f48233d26e33af8 100644 (file)
@@ -400,7 +400,7 @@ class CephadmServe:
         return None
 
     def _refresh_host_devices(self, host: str) -> Optional[str]:
-        with_lsm = self.mgr.get_module_option('device_enhanced_scan')
+        with_lsm = self.mgr.device_enhanced_scan
         inventory_args = ['--', 'inventory',
                           '--format=json-pretty',
                           '--filter-for-batch']
index 42e7d55522a3265a5a0fda585bcc90e158ac2bb5..f44dc62b1349e8763d1912a8005d9dbba2f2e81b 100644 (file)
@@ -1035,7 +1035,7 @@ class CephadmAgent(CephService):
                'refresh_period': self.mgr.agent_refresh_rate,
                'listener_port': self.mgr.agent_starting_port,
                'host': daemon_spec.host,
-               'device_enhanced_scan': str(self.mgr.get_module_option('device_enhanced_scan'))}
+               'device_enhanced_scan': str(self.mgr.device_enhanced_scan)}
 
         listener_cert, listener_key = self.mgr.cherrypy_thread.ssl_certs.generate_cert(
             self.mgr.inventory.get_addr(daemon_spec.host))