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
|
# -*- coding: UTF-8 -*-
# Copyright 2015 Red Hat, Inc.
# Part of clufter project
# Licensed under GPLv2+ (a copy included | http://gnu.org/licenses/gpl-2.0.txt)
"""CIB helpers, mainly used in the filter definitions"""
__author__ = "Jan Pokorný <jpokorny @at@ Red Hat .dot. com>"
from .error import ClufterError
PATH_CIB = '/var/lib/pacemaker/cib/cib.xml'
class ResourceSpecError(ClufterError):
pass
class ResourceSpec(object):
"""Representation of simplified resource specification"""
# see also pcs/resource.py:resource_list_available
# get_full_ra_type
# note however that Pacemaker internally prefers this notation:
# class + class == "ocf"?("::" + provider):"" + ":" + type
# (i.e., double colon), as per
# pacemaker/lib/pengine/native.c:{native_print_xml,native_print,
# get_rscs_brief}
def __init__(self, spec):
split = spec.replace('::', ':', 1).split(':', 3)
try:
self._type = split.pop()
maybe_class = split.pop()
self._class = maybe_class if not(split) else split.pop()
self._provider = maybe_class if self._class == 'ocf' else None
except IndexError:
raise ResourceSpecError("Invalid spec: {0}".format(spec))
@property
def res_class(self):
return self._class
@property
def res_provider(self):
if self._class != 'ocf':
raise ResourceSpecError("No provider for class `ocf'")
return self._provider
@property
def res_type(self):
return self._type
@property
def xsl_attrs(self):
ret = ('<xsl:attribute name="class">{0}</xsl:attribute>'
.format(self._class))
if self._provider is not None:
ret += ('<xsl:attribute name="provider">{0}</xsl:attribute>'
.format(self._provider))
ret += ('<xsl:attribute name="type">{0}</xsl:attribute>'
.format(self._type))
return ret
@property
def xsl_attrs_select(self):
ret = "@class='{0}'".format(self._class)
if self._provider is not None:
ret += " and @provider='{0}'".format(self._provider)
ret += " and @type='{0}'".format(self._type)
return ret
def rg2hb_xsl(dst, src=None, req=False, op=False):
"""Emit XSL snippet yielding nvpair-encoded HB RA parameter from RG one
Parameters:
dst destination parameter (name in the nvpair)
src source parameter (if not provided, use dst ~ 1:1 match)
req valid values: False, True, abs (use raw `src` instead),
or None (propage parameter only if non-empty)
or Warning (deprecated paramater, implies False
and emitted warning [thus the literal object]),
op whether this is relevant for "operations" section
"""
assert req in (False, True, abs, None, Warning), "Invalid `req` param"
src = src or dst
deprecated, req = (True, False) if req is Warning else (False, req)
return (('''\
<xsl:if test="@{src}">
''' if req is False else '''\
<xsl:if test="@{src} != ''">
''' if req is None else '') + ('''\
<xsl:message
>WARNING: parameter/op {dst} (converted from {src}) is now deprecated</xsl:message>
''' if deprecated else '') + (('''\
<!-- {dst} ~ {src} -->
<nvpair id="{{concat($Prefix, '-ATTRS-{dst}')}}"
name="{dst}"
''' + ('''\
value="{{@{src}}}"/>
''' if req is not abs else '''\
value="{src}"/>
''')) if not op else ('''\
<!-- op:{dst} ~ {src} -->
<op id="{{concat($Prefix, '-OP-{dst}')}}"
name="{dst}"
interval="0"
''' + ('''\
timeout="{{concat(@{src}, 's')}}"/>
''' if req is not abs else '''\
timeout="{src}"/>
'''))) + ('''\
</xsl:if>
''' if not req else '')).format(dst=dst, src=src)
|
