1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
# 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 datetime import datetime, timedelta
from sos.report.plugins import (Plugin, RedHatPlugin, DebianPlugin,
UbuntuPlugin, PluginOpt)
from sos.utilities import sos_parse_version
class Pacemaker(Plugin):
short_desc = 'Pacemaker high-availability cluster resource manager'
plugin_name = "pacemaker"
profiles = ("cluster", )
packages = (
"pacemaker",
"pacemaker-remote",
)
option_list = [
PluginOpt('crm_from', default='', val_type=str,
desc='specfiy the start time for crm_report'),
PluginOpt('crm_scrub', default=True,
desc='enable crm_report password scrubbing')
]
envfile = ""
def setup_crm_mon(self):
""" Get cluster summary """
self.add_cmd_output("crm_mon -1 -A -n -r -t")
def setup_crm_shell(self):
""" Get cluster status and configuration """
self.add_cmd_output([
"crm status",
"crm configure show",
])
def setup_pcs(self):
""" Get pacemaker/corosync configuration """
pcs_pkg = self.policy.package_manager.pkg_by_name('pcs')
if pcs_pkg is None:
return
self.add_copy_spec("/var/log/pcsd/pcsd.log")
self.add_cmd_output([
"pcs stonith sbd status --full",
"pcs stonith sbd watchdog list",
"pcs stonith history show",
])
pcs_version = '.'.join(pcs_pkg['version'])
if sos_parse_version(pcs_version) > sos_parse_version('0.10.8'):
self.add_cmd_output("pcs property config --all")
else:
self.add_cmd_output("pcs property list --all")
self.add_cmd_output("pcs config", tags="pcs_config")
self.add_cmd_output("pcs quorum status", tags="pcs_quorum_status")
self.add_cmd_output("pcs status --full", tags="pcs_status")
def postproc_crm_shell(self):
""" Clear password """
self.do_cmd_output_sub(
"crm configure show",
r"passw([^\s=]*)=\S+",
r"passw\1=********"
)
def postproc_pcs(self):
""" Clear password """
self.do_cmd_output_sub(
"pcs config",
r"passw([^\s=]*)=\S+",
r"passw\1=********"
)
def setup(self):
self.add_copy_spec([
# Pacemaker 2.x default log locations
"/var/log/pacemaker/pacemaker.log*",
"/var/log/pacemaker/bundles/*/",
"/var/log/pacemaker/pengine*",
# Pacemaker 1.x default log locations
"/var/log/pacemaker.log",
"/var/log/pacemaker/bundles/*/",
# Common user-specified locations
"/var/log/cluster/pacemaker.log*",
"/var/log/cluster/bundles/*/",
])
self.setup_crm_mon()
# crm_report needs to be given a --from "YYYY-MM-DD HH:MM:SS" start
# time in order to collect data.
crm_from = (datetime.today() -
timedelta(hours=72)).strftime("%Y-%m-%d %H:%m:%S")
if self.get_option("crm_from"):
if re.match(r'\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}',
str(self.get_option("crm_from"))):
crm_from = self.get_option("crm_from")
else:
self._log_error(
f"crm_from parameter '{self.get_option('crm_from')}' is "
"not a valid date: using default")
crm_dest = self.get_cmd_output_path(name="crm_report", make=False)
if self.get_option("crm_scrub"):
crm_scrub = '-p "passw.*"'
else:
crm_scrub = ""
self._log_warn("scrubbing of crm passwords has been disabled:")
self._log_warn("data collected by crm_report may contain"
" sensitive values.")
self.add_cmd_output(f'crm_report --sos-mode {crm_scrub} -S -d '
f' --dest {crm_dest} --from "{crm_from}"',
chroot=self.tmp_in_sysroot())
# collect user-defined logfiles, matching a shell-style syntax:
# PCMK_logfile=filename
# specified in the pacemaker start-up environment file.
pattern = r'^\s*PCMK_logfile=[\'\"]?(\S+)[\'\"]?\s*(\s#.*)?$'
if self.path_isfile(self.envfile):
self.add_copy_spec(self.envfile)
with open(self.envfile, 'r', encoding='UTF-8') as file:
for line in file:
if re.match(pattern, line):
# remove trailing and leading quote marks, in case the
# line is e.g. PCMK_logfile="/var/log/pacemaker.log"
logfile = re.search(pattern, line).group(1)
for regexp in [r'^"', r'"$', r'^\'', r'\'$']:
logfile = re.sub(regexp, '', logfile)
self.add_copy_spec(logfile)
class DebianPacemaker(Pacemaker, DebianPlugin, UbuntuPlugin):
def setup(self):
self.envfile = self.path_join("/etc/default/pacemaker")
self.setup_crm_shell()
self.setup_pcs()
super().setup()
def postproc(self):
self.postproc_crm_shell()
self.postproc_pcs()
class RedHatPacemaker(Pacemaker, RedHatPlugin):
def setup(self):
self.envfile = self.path_join("/etc/sysconfig/pacemaker")
self.setup_pcs()
self.add_copy_spec("/etc/sysconfig/sbd")
super().setup()
def postproc(self):
self.postproc_pcs()
# vim: et ts=4 sw=4
|
