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
|
# 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.
from sos.report.plugins import Plugin, RedHatPlugin, DebianPlugin, UbuntuPlugin
from datetime import datetime, timedelta
import re
import os.path
class Pacemaker(Plugin):
short_desc = 'Pacemaker high-availability cluster resource manager'
plugin_name = "pacemaker"
version = "1.0"
profiles = ("cluster", )
packages = (
"pacemaker",
"pacemaker-remote",
)
option_list = [
("crm_from", "specify the start time for crm_report", "fast", ''),
("crm_scrub", "enable password scrubbing for crm_report", "", True),
]
envfile = ""
def setup_crm_mon(self):
self.add_cmd_output("crm_mon -1 -A -n -r -t")
def setup_crm_shell(self):
self.add_cmd_output([
"crm status",
"crm configure show",
])
def setup_pcs(self):
self.add_copy_spec("/var/log/pcsd/pcsd.log")
self.add_cmd_output([
"pcs config",
"pcs status --full",
"pcs stonith sbd status --full",
"pcs stonith sbd watchdog list",
"pcs stonith history show",
"pcs quorum status",
"pcs property list --all"
])
def postproc_crm_shell(self):
self.do_cmd_output_sub(
"crm configure show",
r"passw([^\s=]*)=\S+",
r"passw\1=********"
)
def postproc_pcs(self):
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/*/",
# 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(
"crm_from parameter '%s' is not a valid date: using "
"default" % self.get_option("crm_from"))
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('crm_report --sos-mode %s -S -d '
' --dest %s --from "%s"' %
(crm_scrub, crm_dest, 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 os.path.isfile(self.envfile):
self.add_copy_spec(self.envfile)
with open(self.envfile) as f:
for line in f:
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 = "/etc/default/pacemaker"
self.setup_crm_shell()
self.setup_pcs()
super(DebianPacemaker, self).setup()
def postproc(self):
self.postproc_crm_shell()
self.postproc_pcs()
class RedHatPacemaker(Pacemaker, RedHatPlugin):
def setup(self):
self.envfile = "/etc/sysconfig/pacemaker"
self.setup_pcs()
self.add_copy_spec("/etc/sysconfig/sbd")
super(RedHatPacemaker, self).setup()
def postproc(self):
self.postproc_pcs()
# vim: et ts=4 sw=4
|
