]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/cephadm: do not remove daemons from remove_service
authorSage Weil <sage@redhat.com>
Mon, 9 Mar 2020 18:15:49 +0000 (13:15 -0500)
committerSage Weil <sage@redhat.com>
Tue, 10 Mar 2020 13:43:05 +0000 (08:43 -0500)
Signed-off-by: Sage Weil <sage@redhat.com>
src/pybind/mgr/cephadm/module.py
src/pybind/mgr/cephadm/tests/test_cephadm.py

index 8272bee58c317702411187ab1a41cf090a40a995..bd805bc0203de0149b94d72c4900891c7c46613b 100644 (file)
@@ -1823,18 +1823,9 @@ class CephadmOrchestrator(orchestrator.Orchestrator, MgrModule):
         return self._remove_daemons(args)
 
     def remove_service(self, service_name):
-        args = []
-        for host, dm in self.cache.daemons.items():
-            for name, d in dm.items():
-                if d.matches_service(service_name):
-                    args.append(
-                        (d.name(), d.hostname, True)
-                    )
-        self.log.info('Remove service %s (daemons %s)' % (
-            service_name, [a[0] for a in args]))
+        self.log.info('Remove service %s' % service_name)
         self.spec_store.rm(service_name)
-        if args:
-            return self._remove_daemons(args)
+        self._kick_serve_loop()
         return trivial_result(['Removed service %s' % service_name])
 
     def get_inventory(self, host_filter=None, refresh=False):
index 6080ee5503b314908a624ad0dbc20858f0d0feeb..17300ce70a7c3ca8bffdbd43e6cc698458c3e140 100644 (file)
@@ -226,7 +226,7 @@ class TestCephadm(object):
             wait(cephadm_module, c)
             c = cephadm_module.remove_service('rgw.myrgw')
             out = wait(cephadm_module, c)
-            assert out == ["Removed rgw.myrgw.foobar from host 'test'"]
+            assert out == ["Removed service rgw.myrgw"]
 
     @mock.patch("cephadm.module.CephadmOrchestrator._run_cephadm", _run_cephadm('{}'))
     def test_rbd_mirror(self, cephadm_module):