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
|
# -*- coding: UTF-8 -*-
# Copyright 2016 Red Hat, Inc.
# Part of clufter project
# Licensed under GPLv2+ (a copy included | http://gnu.org/licenses/gpl-2.0.txt)
"""ccs2pcs{,-flatiron,-needle} commands"""
__author__ = "Jan Pokorný <jpokorny @at@ Red Hat .dot. com>"
from ..command import Command, CommandAlias
from ..facts import cluster_pcs_1_2, cluster_pcs_flatiron
from ..filter import XMLFilter
from ..protocol import protocols
from ..utils_cman import PATH_CLUSTERCONF
from ._chains_pcs import ccsflat2cibfinal_chain, ccsflat2cibfinal_output
def _check_pacemaker_1_2(cmd_ctxt):
system = cmd_ctxt.get('system', 'UNKNOWN-SYSTEM')
system_extra = cmd_ctxt.get('system_extra', 'UNKNOWN-DISTRO')
if not cluster_pcs_1_2(system, system_extra):
from sys import stderr
svc_output = cmd_ctxt.get('svc_output',
lambda s, **kwargs: stderr.write(s + '\n'))
svc_output("Resulting configuration will likely not be applicable to"
" ``{0}'' system as it seems so outdated as far as Pacemaker"
" not supporting validation schema v1.2"
.format(': '.join((system, system_extra))),
base="error",
urgent=True,
)
@Command.deco(('ccs2ccsflat',
('ccs-disable-rg',
('ccs2ccs-pcmk',
('ccs-version-bump'))),
(ccsflat2cibfinal_chain)))
def ccs2pcs_flatiron(cmd_ctxt,
input=PATH_CLUSTERCONF,
ccs_pcmk="cluster-{ccs2ccsflat.in.hash}.conf",
cib="cib-{ccs2ccsflat.in.hash}.xml",
_common=XMLFilter.command_common):
"""(CMAN,rgmanager)->(Corosync/CMAN,Pacemaker) cluster cfg.
More specifically, the output is suitable for Pacemaker integrated
with Corosync ver. 1 (Flatiron) as present, e.g., in RHEL 6.{5, ..},
and consists of Corosync/CMAN configuration incl. fencing pass-through
(~cluster.conf) along with Pacemaker proper one (~cib.xml).
Options:
input input (CMAN,rgmanager) cluster configuration file
ccs_pcmk output Corosync/CMAN (+fencing pass-through) config. file
cib output proper Pacemaker cluster config. file (CIB)
"""
_check_pacemaker_1_2(cmd_ctxt)
file_proto = protocols.plugins['file'].ensure_proto
return (
file_proto(input),
(
(
(
file_proto(ccs_pcmk),
),
),
ccsflat2cibfinal_output(
file_proto(cib),
),
),
)
@Command.deco(('ccs2ccsflat',
('ccs-propagate-cman',
('ccs2needlexml',
('xml2simpleconfig'))),
(ccsflat2cibfinal_chain)))
def ccs2pcs_needle(cmd_ctxt,
input=PATH_CLUSTERCONF,
coro="corosync-{ccs2ccsflat.in.hash}.conf",
cib="cib-{ccs2ccsflat.in.hash}.xml",
_common=XMLFilter.command_common):
"""(CMAN,rgmanager)->(Corosync v2,Pacemaker) cluster cfg.
More specifically, the output is suitable for Pacemaker integrated
with Corosync ver. 2 (Needle) as present, e.g., in RHEL 7, and consists
of Pacemaker (~cib.xml) and Corosync (~corosync.conf) configurations.
Options:
input input (CMAN,rgmanager) cluster configuration file
coro output Corosync v2 config. file
cib output proper Pacemaker cluster config. file (CIB)
"""
_check_pacemaker_1_2(cmd_ctxt)
file_proto = protocols.plugins['file'].ensure_proto
return (
file_proto(input),
(
(
(
file_proto(coro),
),
),
ccsflat2cibfinal_output(
file_proto(cib),
),
),
)
@CommandAlias.deco
def ccs2pcs(cmds, *sys_id):
# cluster_pcs_needle assumed unless "cluster_pcs_flatiron"
return ccs2pcs_flatiron if cluster_pcs_flatiron(*sys_id) else ccs2pcs_needle
|
