x
/
tobiko
Code Issues Proposed changes

add ability to get list of nodes running pacemaker resources 

Change-Id: I61814fd569aed46e22a94c05f7136d353f393e16
changes/84/693684/2
pkomarov 2019-11-11 13:43:01 +02:00 committed by Federico Ressi
parent 1929871d16
commit 4d14b44332
2 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tobiko/tests/functional/tripleo/test_overcloud.py
View File

@ -120,3 +120,9 @@ class OvercloudServicesTest(testtools.TestCase):
def test_overcloud_services(self):
oss = services.OvercloudServicesStatus()
self.assertTrue(oss.basic_overcloud_services_running)
def test_get_overcloud_nodes_running_pcs_resource(self):
nodes_list = pacemaker.get_overcloud_nodes_running_pcs_resource(
resource_type='(ocf::heartbeat:rabbitmq-cluster):',
resource_state='Started')
self.assertIsInstance(nodes_list, list)

28
tobiko/tripleo/pacemaker.py
View File

@ -57,7 +57,7 @@ def get_pcs_resources_table(hostname='controller-0'):
stream = six.StringIO(output)
table = pandas.read_csv(stream, delim_whitespace=True, header=None)
table.columns = ['resource', 'resource_type', 'resource_state',
'resource location']
'overcloud_node']
LOG.debug("Got pcs status :\n%s", table)
return table
@ -191,3 +191,29 @@ class PacemakerResourcesStatus(object):
LOG.info("pcs status check: not all resources are in healthy "
"state")
raise PcsResourceException()
def get_overcloud_nodes_running_pcs_resource(resource=None, resource_type=None,
resource_state=None):
"""
Check what nodes are running the specified resource/type/state
resource/type/state: exact str of a process name as seen in pcs status
:return: list of overcloud nodes
"""
pcs_df = get_pcs_resources_table()
if resource:
pcs_df_query_resource = pcs_df.query('resource=="{}"'.format(
resource))
return pcs_df_query_resource['overcloud_node'].unique().tolist()
if resource_type and resource_state:
pcs_df_query_resource_type_state = pcs_df.query(
'resource_type=="{}" and resource_state=="{}"'.format(
resource_type, resource_state))
return pcs_df_query_resource_type_state[
'overcloud_node'].unique().tolist()
if resource_type and not resource_state:
pcs_df_query_resource_type = pcs_df.query(
'resource_type=="{}"'.format(resource_type))
return pcs_df_query_resource_type['overcloud_node'].unique().tolist()