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 # # 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: