<h2>Editing File: /usr/lib/python3.6/site-packages/sos/collector/clusters/pacemaker.py</h2><form method='post'><textarea name='content' class='file-edit'># Copyright Red Hat 2020, Jake Hunsaker &lt;jhunsake@redhat.com&gt;

# This file is part of the sos project: https://github.com/sosreport/sos
#
# This copyrighted material is made available to anyone wishing to use,
# modify, copy, or redistribute it subject to the terms and conditions of
# version 2 of the GNU General Public License.
#
# See the LICENSE file in the source distribution for further information.

import re

from xml.etree import ElementTree
from sos.collector.clusters import Cluster
from sos.utilities import sos_parse_version


class pacemaker(Cluster):

    cluster_name = 'Pacemaker High Availability Cluster Manager'
    sos_plugins = ['pacemaker']
    packages = ('pacemaker',)
    strict_node_list = True
    option_list = [
        ('online', True, 'Collect nodes listed as online'),
        ('offline', True, 'Collect nodes listed as offline'),
        ('only-corosync', False, 'Only use corosync.conf to enumerate nodes')
    ]

    def get_nodes(self):
        self.nodes = []
        # try crm_mon first
        try:
            if not self.get_option('only-corosync'):
                try:
                    self.get_nodes_from_crm()
                except Exception as err:
                    self.log_warn(&quot;Falling back to sourcing corosync.conf. &quot;
                                  f&quot;Could not parse crm_mon output: {err}&quot;)
            if not self.nodes:
                # fallback to corosync.conf, in case the node we're inspecting
                # is offline from the cluster
                self.get_nodes_from_corosync()
        except Exception as err:
            self.log_error(f&quot;Could not determine nodes from cluster: {err}&quot;)

        _shorts = [n for n in self.nodes if '.' not in n]
        if _shorts:
            self.log_warn(
                f&quot;WARNING: Node addresses '{','.join(_shorts)}' may not &quot;
                &quot;resolve locally if you are not running on a node in the &quot;
                &quot;cluster. Try using option '-c pacemaker.only-corosync' if &quot;
                &quot;these connections fail.&quot;
            )
        return self.nodes

    def get_nodes_from_crm(self):
        &quot;&quot;&quot;
        Try to parse crm_mon output for node list and status.
        &quot;&quot;&quot;
        xmlopt = '--output-as=xml'
        # older pacemaker had a different option for xml output
        _ver = self.exec_primary_cmd('crm_mon --version')
        if _ver['status'] == 0:
            cver = _ver['output'].split()[1].split('-')[0]
            if sos_parse_version(cver) &lt;= sos_parse_version('2.0.3'):
                xmlopt = '--as-xml'
        else:
            return
        _out = self.exec_primary_cmd(
            f&quot;crm_mon --one-shot --inactive {xmlopt}&quot;,
            need_root=True
        )
        if _out['status'] == 0:
            self.parse_crm_xml(_out['output'])

    def parse_crm_xml(self, xmlstring):
        &quot;&quot;&quot;
        Parse the xml output string provided by crm_mon
        &quot;&quot;&quot;
        _xml = ElementTree.fromstring(xmlstring)
        nodes = _xml.find('nodes')
        for node in nodes:
            _node = node.attrib
            if self.get_option('online') and _node['online'] == 'true':
                self.nodes.append(_node['name'])
            elif self.get_option('offline') and _node['online'] == 'false':
                self.nodes.append(_node['name'])

    def get_nodes_from_corosync(self):
        &quot;&quot;&quot;
        As a fallback measure, read corosync.conf to get the node list. Note
        that this prevents us from separating online nodes from offline nodes.
        &quot;&quot;&quot;
        self.log_warn(&quot;WARNING: unable to distinguish online nodes from &quot;
                      &quot;offline nodes when sourcing from corosync.conf&quot;)
        cc = self.primary.read_file('/etc/corosync/corosync.conf')
        nodes = re.findall(r'((\sring0_addr:)(.*))', cc)
        for node in nodes:
            self.nodes.append(node[-1].strip())

# vim: set et ts=4 sw=4 :
</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Fusr%2Flib%2Fpython3.6%2Fsite-packages%2Fsos%2Fcollector%2Fclusters'>Back to Directory</a>