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
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
|
# Copyright (C) 2008-2011 Dejan Muhamedagic <dmuhamedagic@suse.de>
# Copyright (C) 2013 Kristoffer Gronlund <kgronlund@suse.com>
# See COPYING for license information.
import os
import glob
from . import command
from . import xmlutil
from . import utils
from . import ui_cibstatus
from . import constants
from . import config
from . import options
from .cibstatus import cib_status
from .cibconfig import cib_factory
from .sh import ShellUtils
from . import tmpfiles
from . import completers as compl
from . import log
logger = log.setup_logger(__name__)
logger_utils = log.LoggerUtils(logger)
_NEWARGS = ('force', '--force', 'withstatus', 'empty')
class CibShadow(command.UI):
'''
CIB shadow management class
'''
name = "cib"
extcmd = ">/dev/null </dev/null crm_shadow -b"
extcmd_stdout = "</dev/null crm_shadow -b"
def requires(self):
if not utils.is_program('crm_shadow'):
logger_utils.no_prog_err('crm_shadow')
return False
return True
@command.level(ui_cibstatus.CibStatusUI)
def do_cibstatus(self):
pass
@command.skill_level('administrator')
@command.completers_repeating(compl.null, compl.choice(_NEWARGS))
def do_new(self, context, *args):
"usage: new [<shadow_cib>] [withstatus] [force] [empty]"
argl = list(args)
opt_l = utils.fetch_opts(argl, ["force", "--force", "withstatus", "empty"])
if len(argl) > 1:
context.fatal_error("Unexpected argument(s): " + ' '.join(argl))
name = None
if argl:
name = argl[0]
if not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
if name in (constants.tmp_cib_prompt, constants.live_cib_prompt):
context.fatal_error("Shadow name '%s' is not allowed" % (name))
del argl[0]
constants.tmp_cib = False
else:
fd, fname = tmpfiles.create(directory=xmlutil.cib_shadow_dir(), prefix="shadow.crmsh_")
name = os.path.basename(fname).replace("shadow.", "")
constants.tmp_cib = True
if "empty" in opt_l:
new_cmd = "%s -e '%s'" % (self.extcmd, name)
else:
new_cmd = "%s -c '%s'" % (self.extcmd, name)
if constants.tmp_cib or config.core.force or "force" in opt_l or "--force" in opt_l:
new_cmd = "%s --force" % new_cmd
if utils.ext_cmd(new_cmd) == 0:
context.info("%s shadow CIB created" % name)
self.do_use(context, name)
if "withstatus" in opt_l:
cib_status.load("shadow:%s" % name)
def _find_pe(self, context, infile):
'Find a pe input'
for p in ("%s/%s", "%s/%s.bz2", "%s/pe-*-%s.bz2"):
fl = glob.glob(p % (config.path.pe_state_dir, infile))
if fl:
break
if not fl:
context.fatal_error("no %s pe input file" % infile)
if len(fl) > 1:
context.fatal_error("more than one %s pe input file: %s" %
(infile, ' '.join(fl)))
if not fl[0]:
context.fatal_error("bad %s pe input file" % infile)
return fl[0]
@command.skill_level('administrator')
@command.completers(compl.null, compl.shadows)
def do_import(self, context, infile, name=None):
"usage: import {<file>|<number>} [<shadow>]"
if name and not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
# where's the input?
if not os.access(infile, os.F_OK):
if "/" in infile:
context.fatal_error(str(infile) + ": no such file")
infile = self._find_pe(context, infile)
if not name:
name = os.path.basename(infile).replace(".bz2", "")
if not xmlutil.pe2shadow(infile, name):
context.fatal_error("Error copying PE file to shadow: %s -> %s" % (infile, name))
# use the shadow and load the status from there
return self.do_use(context, name, "withstatus")
@command.skill_level('administrator')
@command.completers(compl.shadows)
def do_delete(self, context, name):
"usage: delete <shadow_cib>"
if not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
if utils.get_cib_in_use() == name:
context.fatal_error("%s shadow CIB is in use" % name)
if utils.ext_cmd("%s -D '%s' --force" % (self.extcmd, name)) == 0:
context.info("%s shadow CIB deleted" % name)
else:
context.fatal_error("failed to delete %s shadow CIB" % name)
@command.skill_level('administrator')
@command.completers(compl.shadows)
def do_reset(self, context, name):
"usage: reset <shadow_cib>"
if not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
if utils.ext_cmd("%s -r '%s'" % (self.extcmd, name)) == 0:
context.info("copied live CIB to %s" % name)
else:
context.fatal_error("failed to copy live CIB to %s" % name)
@command.skill_level('administrator')
@command.wait
@command.completers(compl.shadows)
def do_commit(self, context, name=None):
"usage: commit [<shadow_cib>]"
if name and not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
if not name:
name = utils.get_cib_in_use()
if not name:
context.fatal_error("There is nothing to commit")
if utils.ext_cmd("%s -C '%s' --force" % (self.extcmd, name)) == 0:
context.info("committed '%s' shadow CIB to the cluster" % name)
else:
context.fatal_error("failed to commit the %s shadow CIB" % name)
if constants.tmp_cib:
self._use('', '')
@command.skill_level('administrator')
def do_diff(self, context):
"usage: diff"
rc, s = ShellUtils().get_stdout(utils.add_sudo("%s -d" % self.extcmd_stdout))
utils.page_string(s)
@command.skill_level('administrator')
def do_list(self, context):
"usage: list"
if options.regression_tests:
for t in xmlutil.listshadows():
print(t)
else:
utils.multicolumn(xmlutil.listshadows())
def _use(self, name, withstatus):
# Choose a shadow cib for further changes. If the name
# provided is empty, then choose the live (cluster) cib.
# Don't allow ' in shadow names
if not name or name == "live":
if withstatus:
cib_status.load("live")
if constants.tmp_cib:
utils.ext_cmd("%s -D '%s' --force" % (self.extcmd, utils.get_cib_in_use()))
constants.tmp_cib = False
utils.clear_cib_in_use()
else:
utils.set_cib_in_use(name)
if withstatus:
cib_status.load("shadow:%s" % name)
return True
@command.skill_level('administrator')
@command.completers(compl.join(compl.shadows, compl.choice(['live'])),
compl.choice(['withstatus']))
def do_use(self, context, name='', withstatus=''):
"usage: use [<shadow_cib>] [withstatus]"
# check the name argument
if name and not utils.is_filename_sane(name):
context.fatal_error("Bad filename: " + name)
if name and name != "live":
if not os.access(xmlutil.shadowfile(name), os.F_OK):
context.fatal_error("%s: no such shadow CIB" % name)
if withstatus and withstatus != "withstatus":
context.fatal_error("Expected 'withstatus', got '%s'" % (withstatus))
# If invoked from configure
# take special precautions
if not context.previous_level_is("cibconfig"):
return self._use(name, withstatus)
if not cib_factory.has_cib_changed():
ret = self._use(name, withstatus)
# new CIB: refresh the CIB factory
cib_factory.refresh()
return ret
saved_cib = utils.get_cib_in_use()
self._use(name, '') # don't load the status yet
if not cib_factory.is_current_cib_equal(silent=True):
# user made changes and now wants to switch to a
# different and unequal CIB; we refuse to cooperate
context.error_message("the requested CIB is different from the current one")
if config.core.force:
context.info("CIB overwrite forced")
elif not utils.ask("All changes will be dropped. Do you want to proceed?"):
self._use(saved_cib, '') # revert to the previous CIB
return False
return self._use(name, withstatus) # now load the status too
# vim:ts=4:sw=4:et:
|
