Page MenuHomeClusterLabs Projects
Files F3686682

No OneTemporary
Actions

View Options

diff --git a/shell/modules/cibstatus.py b/shell/modules/cibstatus.py
index bc922839c2..d1fbc2982b 100644
--- a/shell/modules/cibstatus.py
+++ b/shell/modules/cibstatus.py
@@ -1,248 +1,249 @@
# Copyright (C) 2008 Dejan Muhamedagic <dmuhamedagic@suse.de>
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This software is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# General Public License for more details.
#
# You should have received a copy of the GNU General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
#
import sys
import re
+import time
from singletonmixin import Singleton
from xmlutil import *
from msg import *
def get_tag_by_id(node,tag,id):
"Find a doc node which matches tag and id."
for n in node.getElementsByTagName(tag):
if n.getAttribute("id") == id:
return n
return None
def get_status_node(n):
try: n = n.parentNode
except: return None
if n.tagName != "node_state":
return get_status_node(n)
return n.getAttribute("id")
def get_status_ops(status_node,rsc,op,interval,node = ''):
'''
Find a doc node which matches the operation. interval set to
"-1" means to lookup an operation with non-zero interval (for
monitors). Empty interval means any interval is fine.
'''
l = []
for n in status_node.childNodes:
if not is_element(n) or n.tagName != "node_state":
continue
if node and n.getAttribute("id") != node:
continue
for r in n.getElementsByTagName("lrm_resource"):
if r.getAttribute("id") != rsc:
continue
for o in r.getElementsByTagName("lrm_rsc_op"):
if o.getAttribute("operation") != op:
continue
if (interval == "") or \
(interval == "-1" and o.getAttribute("interval") != "0") or \
(interval != "" and o.getAttribute("interval") == interval):
l.append(o)
return l
class CibStatus(Singleton):
'''
CIB status management
'''
def __init__(self):
self.origin = "live"
self.status_node = None
self.doc = None
self.cib = None
self.modified = False
self.node_changes = {}
self.op_changes = {}
def _cib_path(self,source):
if source[0:7] == "shadow:":
return shadowfile(source[7:])
else:
return source
def _load_cib(self,source):
if source == "live":
doc,cib = read_cib(cibdump2doc)
else:
doc,cib = read_cib(file2doc,self._cib_path(source))
return doc,cib
def _load(self,source):
doc,cib = self._load_cib(source)
if not doc:
return False
status = get_conf_elem(doc, "status")
if not status:
return False
self.doc,self.cib = doc,cib
self.status_node = status
self.modified = False
self.node_changes = {}
self.op_changes = {}
return True
def status_node_list(self):
if not self.status_node and not self._load(self.origin):
return
return [x.getAttribute("id") for x in self.doc.getElementsByTagName("node_state")]
def status_rsc_list(self):
if not self.status_node and not self._load(self.origin):
return
rsc_list = [x.getAttribute("id") for x in self.doc.getElementsByTagName("lrm_resource")]
# how to uniq?
d = {}
for e in rsc_list:
d[e] = 0
return d.keys()
def load(self,source):
'''
Load the status section from the given source. The source
may be cluster ("live"), shadow CIB, or CIB in a file.
'''
if not self._load(source):
common_err("the cib contains no status")
return False
self.origin = source
return True
def save(self,dest = None):
'''
Save the modified status section to a file/shadow. If the
file exists, then it must be a cib file and the status
section is replaced with our status section. If the file
doesn't exist, then our section and some (?) configuration
is saved.
'''
if not self.modified:
common_info("apparently you didn't modify status")
return False
if (not dest and self.origin == "live") or dest == "live":
common_warn("cannot save status to the cluster")
return False
doc,cib = self.doc,self.cib
if dest:
dest_path = self._cib_path(dest)
if os.path.isfile(dest_path):
doc,cib = self._load_cib(dest)
if not doc or not cib:
common_err("%s exists, but no cib inside" % dest)
return False
else:
dest_path = self._cib_path(self.origin)
if doc != self.doc:
status = get_conf_elem(doc, "status")
rmnode(status)
cib.appendChild(doc.importNode(self.status_node,1))
xml = doc.toprettyxml(user_prefs.xmlindent)
try: f = open(dest_path,"w")
except IOError, msg:
common_err(msg)
return False
f.write(xml)
f.close()
return True
def get_status(self):
'''
Return the status section node.
'''
if not self.status_node and not self._load(self.origin):
return None
return self.status_node
def list_changes(self):
'''
Dump a set of changes done.
'''
if not self.modified:
return True
for node in self.node_changes:
print node,self.node_changes[node]
for op in self.op_changes:
print op,self.op_changes[op]
return True
def show(self):
'''
Page the "pretty" XML of the status section.
'''
if not self.status_node and not self._load(self.origin):
return
page_string(self.status_node.toprettyxml(user_prefs.xmlindent))
return True
def edit_node(self,node,state):
'''
Modify crmd, expected, and join attributes of node_state
to set the node's state to online, offline, or unclean.
'''
if not self.status_node and not self._load(self.origin):
return
node_node = get_tag_by_id(self.status_node,"node_state",node)
if not node_node:
common_err("node %s not found" % node)
return False
if state == "online":
node_node.setAttribute("crmd","online")
node_node.setAttribute("expected","member")
node_node.setAttribute("join","member")
elif state == "offline":
node_node.setAttribute("crmd","offline")
node_node.setAttribute("expected","")
elif state == "unclean":
node_node.setAttribute("crmd","offline")
node_node.setAttribute("expected","member")
else:
common_err("unknown state %s" % state)
return False
self.node_changes[node] = state
self.modified = True
return True
def edit_op(self,op,rsc,rc,op_status,node = ''):
'''
Set rc-code and op-status in the lrm_rsc_op status
section element.
'''
if not self.status_node and not self._load(self.origin):
return
l_op = op
l_int = ""
if op == "probe":
l_op = "monitor"
l_int = "0"
elif op == "monitor":
l_int = "-1"
elif op[0:8] == "monitor:":
l_op = "monitor"
l_int = op[8:]
op_nodes = get_status_ops(self.status_node,rsc,l_op,l_int,node)
if len(op_nodes) == 0:
common_err("operation %s not found" % op)
return False
elif len(op_nodes) > 1:
nodelist = [get_status_node(x) for x in op_nodes]
common_err("operation %s found at %s" % (op,' '.join(nodelist)))
return False
op_node = op_nodes[0]
if not node:
node = get_status_node(op_node)
prev_rc = op_node.getAttribute("rc-code")
op_node.setAttribute("rc-code",rc)
self.op_changes[node+":"+rsc+":"+op] = "rc="+rc
if op_status:
op_node.setAttribute("op-status",op_status)
self.op_changes[node+":"+rsc+":"+op] += "," "op-status="+op_status
op_node.setAttribute("last-run",str(int(time.time())))
if rc != prev_rc:
op_node.setAttribute("last-rc-change",str(int(time.time())))
self.modified = True
return True
# vim:ts=4:sw=4:et:

File Metadata

Mime Type
text/x-diff
Expires
Mon, Apr 21, 3:05 PM (1 d, 8 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1661770
Default Alt Text
(9 KB)

Event Timeline