From 909d6fd9b25f4f9858510fc6d08ca1ab67cbff8e Mon Sep 17 00:00:00 2001 From: Shilpa Jagannath Date: Thu, 17 Jan 2019 13:49:53 +0530 Subject: [PATCH] single cluster fix firewalld workaround (cherry picked from commit 0372924807a5e5c880574c6cbf7f88733ac67d79) --- teuthology/task/ceph_ansible.py | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/teuthology/task/ceph_ansible.py b/teuthology/task/ceph_ansible.py index 43e940e247..fdda97c79d 100644 --- a/teuthology/task/ceph_ansible.py +++ b/teuthology/task/ceph_ansible.py @@ -130,8 +130,10 @@ class CephAnsible(Task): def remove_cluster_prefix(self): stripped_role = {} - self.each_cluster = self.ctx.cluster.only(lambda role: role.startswith(self.cluster_name))\ - if self.cluster_name else self.ctx.cluster + if self.cluster_name: + self.each_cluster = self.ctx.cluster.only(lambda role: role.startswith(self.cluster_name)) + else: + self.each_cluster = self.ctx.cluster log.info('current cluster {}'.format(self.each_cluster)) for remote, roles in self.each_cluster.remotes.iteritems(): stripped_role[remote] = [] @@ -140,6 +142,14 @@ class CephAnsible(Task): self.each_cluster.remotes = stripped_role log.info('updated cluster {}'.format(self.each_cluster)) + def start_firewalld(self): + + for remote, roles in self.each_cluster.remotes.iteritems(): + cmd = 'sudo service firewalld start' + remote.run( + args=cmd, stdout=StringIO(), + ) + def execute_playbook(self): """ Execute ansible-playbook @@ -514,6 +524,7 @@ class CephAnsible(Task): ]) self._copy_and_print_config() self._generate_client_config() + self.start_firewalld() str_args = ' '.join(args) ceph_installer.run( args=[ -- 2.39.5