From: jparsons@sourceware.org <jparsons@sourceware.org>
To: cluster-devel.redhat.com
Subject: [Cluster-devel] conga/luci/site/luci/Extensions cluster_adapte ...
Date: 28 Jul 2006 11:46:35 -0000 [thread overview]
Message-ID: <20060728114635.21869.qmail@sourceware.org> (raw)
CVSROOT: /cvs/cluster
Module name: conga
Changes by: jparsons at sourceware.org 2006-07-28 11:46:35
Modified files:
luci/site/luci/Extensions: cluster_adapters.py ricci_bridge.py
Log message:
Big fixes for resource support
Patches:
http://sourceware.org/cgi-bin/cvsweb.cgi/conga/luci/site/luci/Extensions/cluster_adapters.py.diff?cvsroot=cluster&r1=1.17&r2=1.18
http://sourceware.org/cgi-bin/cvsweb.cgi/conga/luci/site/luci/Extensions/ricci_bridge.py.diff?cvsroot=cluster&r1=1.9&r2=1.10
--- conga/luci/site/luci/Extensions/cluster_adapters.py 2006/07/27 16:34:11 1.17
+++ conga/luci/site/luci/Extensions/cluster_adapters.py 2006/07/28 11:46:35 1.18
@@ -5,6 +5,13 @@
from ricci_bridge import *
import time
import Products.ManagedSystem
+from Ip import Ip
+from Clusterfs import Clusterfs
+from Fs import Fs
+from NFSClient import NFSClient
+from Netfs import Netfs
+from Script import Script
+from Samba import Samba
#Policy for showing the cluster chooser menu:
#1) If there are no clusters in the ManagedClusterSystems
@@ -1320,7 +1327,7 @@
return {}
-def addResource(self, request):
+def addResource(self, request, ragent):
if not request.form:
return "Nothing submitted, no changes made."
@@ -1336,20 +1343,32 @@
'smb': addSmb}
type = request.form["type"]
- return types[type](request)
+ res = types[type](request)
+ modelb = request.SESSION.get('model')
+ modelstr = ""
+ conf = modelb.exportModelAsString()
+ rb = ricci_bridge(ragent)
+ #try:
+ if True:
+ batch_id, result = rb.setClusterConf(str(conf))
+ #except:
+ else:
+ return "Some error occured in setClusterConf\n"
+
+ return "Resource Added"
def getResourceForEdit(modelb, name):
- resPtr = modelb.getResourcesPtr()
- resources = resPrt.getChildren()
-
+ resources = modelb.getResourcesPtr().getChildren()
+
for res in resources:
if res.getName() == name:
resources.removeChild(res)
break
-
+
return res
+
def addIp(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1365,7 +1384,7 @@
return res
def addFs(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1396,7 +1415,7 @@
return res
def addGfs(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1417,7 +1436,7 @@
return res
def addNfsm(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1439,7 +1458,7 @@
return res
def addNfsc(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1453,7 +1472,7 @@
return res
def addNfsx(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1465,7 +1484,7 @@
return res
def addScr(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1478,7 +1497,7 @@
return res
def addSmb(request):
- modelb = request.SESSION["model"]
+ modelb = request.SESSION.get('model')
if request.form.has_key('edit'):
res = getResourceForEdit(modelb, request.form['oldname'])
else:
@@ -1493,5 +1512,8 @@
def appendModel(request, model):
try:
request.SESSION.set('model', model)
- except: pass
+ except:
+ pass
+ return
+
--- conga/luci/site/luci/Extensions/ricci_bridge.py 2006/07/27 14:23:59 1.9
+++ conga/luci/site/luci/Extensions/ricci_bridge.py 2006/07/28 11:46:35 1.10
@@ -1,4 +1,3 @@
-
from time import *
import os
from socket import *
@@ -10,526 +9,516 @@
class ricci_bridge:
- def __init__(self, hostname, port=11111):
- self.__hostname = hostname
- self.__port = port
- return
+ def __init__(self, hostname, port=11111):
+ self.__hostname = hostname
+ self.__port = port
+ return
- def process(self, xml_out):
- #if os.path.exists("/opt/zopetooey/Extensions/certs/privkey.pem"):
- # return "<h1>Path Exists</h1>"
- #else:
- # return "<h1>Path Does Not Exist</h1>"
- CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="get_cluster.conf"/></request></module></batch></ricci>'
+ def process(self, xml_out):
+ CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="get_cluster.conf"/></request></module></batch></ricci>'
- doc = self.makeConnection(CLUSTER_STR)
+ doc = self.makeConnection(CLUSTER_STR)
- if doc == None:
- print "Sorry, doc is None"
- if doc != None:
- bt_node = None
- for node in doc.firstChild.childNodes:
+ if doc == None:
+ print "Sorry, doc is None"
+ if doc != None:
+ bt_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ bt_node = node
+ if bt_node == None:
+ print "bt_node == None"
+ doc = None
+ else:
+ #print doc.toxml()
+ mod_node = None
+ for node in bt_node.childNodes:
if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- bt_node = node
- if bt_node == None:
- print "bt_node == None"
+ if node.nodeName == 'module':
+ mod_node = node
+ if mod_node == None:
+ print "mod_node == None"
doc = None
- else:
- #print doc.toxml()
- mod_node = None
- for node in bt_node.childNodes:
+ else:
+ resp_node = None
+ for node in mod_node.childNodes:
if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'module':
- mod_node = node
- if mod_node == None:
- print "mod_node == None"
+ resp_node = node
+ if resp_node == None:
+ print "resp_node == None"
doc = None
else:
- resp_node = None
- for node in mod_node.childNodes:
+ fr_node = None
+ for node in resp_node.childNodes:
if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- resp_node = node
- if resp_node == None:
- print "resp_node == None"
+ fr_node = node
+ if fr_node == None:
+ print "fr_node == None"
doc = None
else:
- fr_node = None
- for node in resp_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- fr_node = node
- if fr_node == None:
- print "fr_node == None"
- doc = None
+ varnode = None
+ for node in fr_node.childNodes:
+ if node.nodeName == 'var':
+ varnode = node
+ break
+ if varnode == None:
+ print "varnode == None"
+ doc = None
else:
- varnode = None
- for node in fr_node.childNodes:
- if node.nodeName == 'var':
- varnode = node
+ cl_node = None
+ for node in varnode.childNodes:
+ if node.nodeName == 'cluster':
+ cl_node = node
break
- if varnode == None:
- print "varnode == None"
- doc = None
- else:
- cl_node = None
- for node in varnode.childNodes:
- if node.nodeName == 'cluster':
- cl_node = node
- break
- if cl_node == None:
- print "cl_node == None"
- doc = None
- else:
- docc = minidom.Document()
- docc.appendChild(cl_node)
-
- return docc
-
- def __sendall(self, str, ssl_sock):
- print str
- s = str
- while len(s) != 0:
- pos = ssl_sock.write(s)
- s = s[pos:]
- return
-
+ if cl_node == None:
+ print "cl_node == None"
+ doc = None
+ else:
+ docc = minidom.Document()
+ docc.appendChild(cl_node)
+
+ return docc
- def __receive(self, ssl_sock):
- doc = None
- xml_in = ''
- try:
- while True:
- buff = ssl_sock.read(1024)
- if buff == '':
- break
- xml_in += buff
- try:
- doc = minidom.parseString(xml_in)
- break
- except:
- pass
- except:
- pass
- try:
- #print 'try parse xml'
- doc = minidom.parseString(xml_in)
- #print 'xml is good'
- except:
- pass
- #print "response--------------------------------"
- #print doc.toxml()
- #print "response--------------------------------"
- return doc
+ def __sendall(self, str, ssl_sock):
+ print str
+ s = str
+ while len(s) != 0:
+ pos = ssl_sock.write(s)
+ s = s[pos:]
+ return
- def getClusterStatus(self):
- CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="status"/></request></module></batch></ricci>'
- # socket
- sock = socket(AF_INET, SOCK_STREAM)
- sock.connect((self.__hostname, self.__port))
- ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
-
- # receive ricci header
- hello = self.__receive(ss)
- if hello != None:
- pass
- #print hello.toxml()
- self.__sendall(CLUSTER_STR, ss)
-
-
- # receive response
- doc = self.__receive(ss)
- if doc == None:
- print "Sorry, doc is None"
- else:
- payload = self.extractPayload(doc)
- sock.shutdown(2)
- sock.close()
-
- return payload
-
- def startService(self,servicename, preferrednode = None):
- if preferrednode != None:
- QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="start_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/><var mutable="false" name="nodename" type="string" value=\"' + preferrednode + '\" /></function_call></request></module></batch></ricci>'
- else:
- QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="start_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
+
+ def __receive(self, ssl_sock):
+ doc = None
+ xml_in = ''
+ try:
+ while True:
+ buff = ssl_sock.read(1024)
+ if buff == '':
+ break
+ xml_in += buff
+ try:
+ doc = minidom.parseString(xml_in)
+ break
+ except:
+ pass
+ except:
+ pass
+ try:
+ #print 'try parse xml'
+ doc = minidom.parseString(xml_in)
+ #print 'xml is good'
+ except:
+ pass
+ return doc
+
+ def getClusterStatus(self):
+ CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="status"/></request></module></batch></ricci>'
+ # socket
+ sock = socket(AF_INET, SOCK_STREAM)
+ sock.connect((self.__hostname, self.__port))
+ ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
+
+ # receive ricci header
+ hello = self.__receive(ss)
+ if hello != None:
+ pass
+ #print hello.toxml()
+ self.__sendall(CLUSTER_STR, ss)
+
+
+ # receive response
+ doc = self.__receive(ss)
+ if doc == None:
+ print "Sorry, doc is None"
+ else:
+ payload = self.extractPayload(doc)
+ sock.shutdown(2)
+ sock.close()
+
+ return payload
+
+ def startService(self,servicename, preferrednode = None):
+ if preferrednode != None:
+ QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="start_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/><var mutable="false" name="nodename" type="string" value=\"' + preferrednode + '\" /></function_call></request></module></batch></ricci>'
+ else:
+ QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="start_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
- try:
- payload = self.makeConnection(QUERY_STR)
- except RicciReceiveError, r:
- return None
-
+ try:
+ payload = self.makeConnection(QUERY_STR)
+ except RicciReceiveError, r:
+ return None
+
- batch_number, result = self.batchAttemptResult(payload)
- return (batch_number, result)
+ batch_number, result = self.batchAttemptResult(payload)
+ return (batch_number, result)
- def restartService(self,servicename):
- QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="restart_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
+ def restartService(self,servicename):
+ QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="restart_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
- try:
- payload = self.makeConnection(QUERY_STR)
- except RicciReceiveError, r:
- return None
-
+ try:
+ payload = self.makeConnection(QUERY_STR)
+ except RicciReceiveError, r:
+ return None
+
- batch_number, result = self.batchAttemptResult(payload)
- return (batch_number, result)
+ batch_number, result = self.batchAttemptResult(payload)
+ return (batch_number, result)
- def stopService(self,servicename):
- QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="stop_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
+ def stopService(self,servicename):
+ QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request sequence="1254" API_version="1.0"><function_call name="stop_service"><var mutable="false" name="servicename" type="string" value=\"' + servicename + '\"/></function_call></request></module></batch></ricci>'
- try:
- payload = self.makeConnection(QUERY_STR)
- except RicciReceiveError, r:
- return None
-
+ try:
+ payload = self.makeConnection(QUERY_STR)
+ except RicciReceiveError, r:
+ return None
+
- batch_number, result = self.batchAttemptResult(payload)
- return (batch_number, result)
+ batch_number, result = self.batchAttemptResult(payload)
+ return (batch_number, result)
- def getDaemonStates(self, dlist):
- CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="service"><request API_version="1.0"><function_call name="query"><var mutable="false" name="search" type="list_xml">'
-
- for item in dlist:
- CLUSTER_STR = CLUSTER_STR + '<service name=\"' + item + '\"/>'
+ def getDaemonStates(self, dlist):
+ CLUSTER_STR='<?xml version="1.0" ?><ricci async="false" function="process_batch" version="1.0"><batch><module name="service"><request API_version="1.0"><function_call name="query"><var mutable="false" name="search" type="list_xml">'
- CLUSTER_STR = CLUSTER_STR + '</var></function_call></request></module></batch></ricci>'
+ for item in dlist:
+ CLUSTER_STR = CLUSTER_STR + '<service name=\"' + item + '\"/>'
- try:
- payload = self.makeConnection(CLUSTER_STR)
- except RicciReceiveError, r:
- return None
+ CLUSTER_STR = CLUSTER_STR + '</var></function_call></request></module></batch></ricci>'
- result = self.extractDaemonInfo(payload)
+ try:
+ payload = self.makeConnection(CLUSTER_STR)
+ except RicciReceiveError, r:
+ return None
- return result
-
- def makeConnection(self,query_str):
- # socket
- sock = socket(AF_INET, SOCK_STREAM)
- sock.connect((self.__hostname, self.__port))
- ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
-
- # receive ricci header
- hello = self.__receive(ss)
- if hello != None:
- pass
- #print hello.toxml()
- self.__sendall(query_str, ss)
-
-
- # receive response
- payload = self.__receive(ss)
- if payload == None:
- raise RicciReceiveError('FATAL',"Unable to receive ricci data for %s" % self.__hostname)
- sock.shutdown(2)
- sock.close()
-
- return payload
-
-
- def extractPayload(self, doc):
- docc = None
- bt_node = None
- for node in doc.firstChild.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- bt_node = node
- if bt_node == None:
- doc = None
- else:
- #print doc.toxml()
- mod_node = None
- for node in bt_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'module':
- mod_node = node
- if mod_node == None:
- doc = None
- else:
- resp_node = None
- for node in mod_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- resp_node = node
- if resp_node == None:
- doc = None
- else:
- fr_node = None
- for node in resp_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- fr_node = node
- if fr_node == None:
- doc = None
- else:
- varnode = None
- for node in fr_node.childNodes:
- if node.nodeName == 'var':
- varnode = node
- break
- if varnode == None:
- doc = None
- else:
- cl_node = None
- for node in varnode.childNodes:
- if node.nodeName == 'cluster':
- cl_node = node
- break
- if cl_node == None:
- doc = None
- else:
- docc = minidom.Document()
- docc.appendChild(cl_node)
- return docc
-
-
- def getBatchResult(self, doc):
- docc = None
- bt_node = None
- for node in doc.firstChild.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- bt_node = node
- if bt_node == None:
- doc = None
+ result = self.extractDaemonInfo(payload)
+
+ return result
+
+ def makeConnection(self,query_str):
+ # socket
+ sock = socket(AF_INET, SOCK_STREAM)
+ sock.connect((self.__hostname, self.__port))
+ ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
+
+ # receive ricci header
+ hello = self.__receive(ss)
+ if hello != None:
+ pass
+ #print hello.toxml()
+ self.__sendall(query_str, ss)
+
+
+ # receive response
+ payload = self.__receive(ss)
+ if payload == None:
+ raise RicciReceiveError('FATAL',"Unable to receive ricci data for %s" % self.__hostname)
+ sock.shutdown(2)
+ sock.close()
+
+ return payload
+
+
+ def extractPayload(self, doc):
+ docc = None
+ bt_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ bt_node = node
+ if bt_node == None:
+ doc = None
+ else:
+ #print doc.toxml()
+ mod_node = None
+ for node in bt_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'module':
+ mod_node = node
+ if mod_node == None:
+ doc = None
+ else:
+ resp_node = None
+ for node in mod_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ resp_node = node
+ if resp_node == None:
+ doc = None
else:
- #print doc.toxml()
- mod_node = None
- for node in bt_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'module':
- mod_node = node
- if mod_node == None:
- doc = None
- else:
- resp_node = None
- for node in mod_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- resp_node = node
- if resp_node == None:
- doc = None
- else:
- fr_node = None
- for node in resp_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- fr_node = node
- if fr_node == None:
- doc = None
+ fr_node = None
+ for node in resp_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ fr_node = node
+ if fr_node == None:
+ doc = None
+ else:
+ varnode = None
+ for node in fr_node.childNodes:
+ if node.nodeName == 'var':
+ varnode = node
+ break
+ if varnode == None:
+ doc = None
+ else:
+ cl_node = None
+ for node in varnode.childNodes:
+ if node.nodeName == 'cluster':
+ cl_node = node
+ break
+ if cl_node == None:
+ doc = None
else:
- varnode = None
- for node in fr_node.childNodes:
- if node.nodeName == 'var':
- varnode = node
- break
- if varnode == None:
- doc = None
- else:
- cl_node = None
- for node in varnode.childNodes:
- if node.nodeName == 'cluster':
- cl_node = node
- break
- if cl_node == None:
- doc = None
- else:
- docc = minidom.Document()
- docc.appendChild(cl_node)
- return docc
-
- def extractClusterConf(self, doc):
- docc = None
- bt_node = None
- for node in doc.firstChild.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- bt_node = node
- if bt_node == None:
- print "bt_node == None"
- doc = None
+ docc = minidom.Document()
+ docc.appendChild(cl_node)
+ return docc
+
+
+ def getBatchResult(self, doc):
+ docc = None
+ bt_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ bt_node = node
+ if bt_node == None:
+ doc = None
+ else:
+ #print doc.toxml()
+ mod_node = None
+ for node in bt_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'module':
+ mod_node = node
+ if mod_node == None:
+ doc = None
+ else:
+ resp_node = None
+ for node in mod_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ resp_node = node
+ if resp_node == None:
+ doc = None
else:
- #print doc.toxml()
- mod_node = None
- for node in bt_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'module':
- mod_node = node
- if mod_node == None:
- print "mod_node == None"
- doc = None
- else:
- resp_node = None
- for node in mod_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- resp_node = node
- if resp_node == None:
- print "resp_node == None"
- doc = None
- else:
- fr_node = None
- for node in resp_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- fr_node = node
- if fr_node == None:
- print "fr_node == None"
- doc = None
+ fr_node = None
+ for node in resp_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ fr_node = node
+ if fr_node == None:
+ doc = None
+ else:
+ varnode = None
+ for node in fr_node.childNodes:
+ if node.nodeName == 'var':
+ varnode = node
+ break
+ if varnode == None:
+ doc = None
+ else:
+ cl_node = None
+ for node in varnode.childNodes:
+ if node.nodeName == 'cluster':
+ cl_node = node
+ break
+ if cl_node == None:
+ doc = None
else:
- varnode = None
- for node in fr_node.childNodes:
- if node.nodeName == 'var':
- varnode = node
- break
- if varnode == None:
- print "varnode == None"
- doc = None
- else:
- cl_node = None
- for node in varnode.childNodes:
- if node.nodeName == 'cluster':
- cl_node = node
- break
- if cl_node == None:
- print "cl_node == None"
- doc = None
- else:
- docc = minidom.Document()
- docc.appendChild(cl_node)
-
- return docc
-
- def extractDaemonInfo(self, doc):
- print "VVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVVV"
- print doc.toxml()
- print "^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^"
- resultlist = list()
- docc = None
- bt_node = None
- for node in doc.firstChild.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- bt_node = node
- if bt_node == None:
- print "bt_node == None"
- doc = None
+ docc = minidom.Document()
+ docc.appendChild(cl_node)
+ return docc
+
+ def extractClusterConf(self, doc):
+ docc = None
+ bt_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ bt_node = node
+ if bt_node == None:
+ print "bt_node == None"
+ doc = None
+ else:
+ #print doc.toxml()
+ mod_node = None
+ for node in bt_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'module':
+ mod_node = node
+ if mod_node == None:
+ print "mod_node == None"
+ doc = None
+ else:
+ resp_node = None
+ for node in mod_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ resp_node = node
+ if resp_node == None:
+ print "resp_node == None"
+ doc = None
else:
- #print doc.toxml()
- mod_node = None
- for node in bt_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'module':
- mod_node = node
- if mod_node == None:
- print "mod_node == None"
- doc = None
- else:
- resp_node = None
- for node in mod_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- resp_node = node
- if resp_node == None:
- print "resp_node == None"
- doc = None
- else:
- fr_node = None
- for node in resp_node.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- fr_node = node
- if fr_node == None:
- print "fr_node == None"
- doc = None
+ fr_node = None
+ for node in resp_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ fr_node = node
+ if fr_node == None:
+ print "fr_node == None"
+ doc = None
+ else:
+ varnode = None
+ for node in fr_node.childNodes:
+ if node.nodeName == 'var':
+ varnode = node
+ break
+ if varnode == None:
+ print "varnode == None"
+ doc = None
+ else:
+ cl_node = None
+ for node in varnode.childNodes:
+ if node.nodeName == 'cluster':
+ cl_node = node
+ break
+ if cl_node == None:
+ print "cl_node == None"
+ doc = None
else:
- varnode = None
- for node in fr_node.childNodes:
- if node.nodeName == 'var':
- varnode = node
- break
- if varnode == None:
- print "varnode == None"
- doc = None
- else:
- svc_node = None
- for node in varnode.childNodes:
- if node.nodeName == 'service':
- svchash = {}
- svchash['name'] = node.getAttribute('name')
- svchash['enabled'] = node.getAttribute('enabled')
- svchash['running'] = node.getAttribute('running')
- resultlist.append(svchash)
-
- return resultlist
+ docc = minidom.Document()
+ docc.appendChild(cl_node)
+
+ return docc
- def batchAttemptResult(self, doc):
- docc = None
- rc_node = None
- for node in doc.firstChild.childNodes:
+ def extractDaemonInfo(self, doc):
+ resultlist = list()
+ docc = None
+ bt_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ bt_node = node
+ if bt_node == None:
+ print "bt_node == None"
+ doc = None
+ else:
+ #print doc.toxml()
+ mod_node = None
+ for node in bt_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'module':
+ mod_node = node
+ if mod_node == None:
+ print "mod_node == None"
+ doc = None
+ else:
+ resp_node = None
+ for node in mod_node.childNodes:
if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- #get batch number and status code
- batch_number = node.getAttribute('batch_id')
- result = node.getAttribute('status')
- return (batch_number, result)
+ resp_node = node
+ if resp_node == None:
+ print "resp_node == None"
+ doc = None
+ else:
+ fr_node = None
+ for node in resp_node.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ fr_node = node
+ if fr_node == None:
+ print "fr_node == None"
+ doc = None
+ else:
+ varnode = None
+ for node in fr_node.childNodes:
+ if node.nodeName == 'var':
+ varnode = node
+ break
+ if varnode == None:
+ print "varnode == None"
+ doc = None
else:
- print "RETURNING NONE!!!"
- return (None, None )
-
+ svc_node = None
+ for node in varnode.childNodes:
+ if node.nodeName == 'service':
+ svchash = {}
+ svchash['name'] = node.getAttribute('name')
+ svchash['enabled'] = node.getAttribute('enabled')
+ svchash['running'] = node.getAttribute('running')
+ resultlist.append(svchash)
+
+ return resultlist
+
+ def batchAttemptResult(self, doc):
+ docc = None
+ rc_node = None
+ for node in doc.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ #get batch number and status code
+ batch_number = node.getAttribute('batch_id')
+ result = node.getAttribute('status')
+ return (batch_number, result)
+ else:
+ print "RETURNING NONE!!!"
+ return (None, None )
+
- def getRicciResponse(self):
- sock = socket(AF_INET, SOCK_STREAM)
- try:
- sock.connect((self.__hostname, self.__port))
- except:
- return False
- ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
- # receive ricci header
- hello = self.__receive(ss)
- if hello != None:
- return True
- else:
- return False
+ def getRicciResponse(self):
+ sock = socket(AF_INET, SOCK_STREAM)
+ try:
+ sock.connect((self.__hostname, self.__port))
+ except:
+ return False
+ ss = ssl(sock, PATH_TO_PRIVKEY, PATH_TO_CACERT)
+ # receive ricci header
+ hello = self.__receive(ss)
+ if hello != None:
+ return True
+ else:
+ return False
- def checkBatch(self, batch_id):
- QUERY_STR = '<?xml version="1.0" ?><ricci version="1.0" function="batch_report" batch_id="' + batch_id + '"/>'
+ def checkBatch(self, batch_id):
+ QUERY_STR = '<?xml version="1.0" ?><ricci version="1.0" function="batch_report" batch_id="' + batch_id + '"/>'
- try:
- payload = self.makeConnection(QUERY_STR)
- except RicciReceiveError, r:
- return None
-
- #return true if finished or not present
- success = payload.firstChild.getAttribute('success')
- if success != "0":
- return True #I think this is ok...if id cannot be found
- for node in payload.firstChild.childNodes:
- if node.nodeType == xml.dom.Node.ELEMENT_NODE:
- if node.nodeName == 'batch':
- #get batch number and status code
- batch_number = node.getAttribute('batch_id')
- result = node.getAttribute('status')
- if result == "0":
- return True
- else:
- return False
- else:
- return False
+ try:
+ payload = self.makeConnection(QUERY_STR)
+ except RicciReceiveError, r:
+ return None
+
+ #return true if finished or not present
+ success = payload.firstChild.getAttribute('success')
+ if success != "0":
+ return True #I think this is ok...if id cannot be found
+ for node in payload.firstChild.childNodes:
+ if node.nodeType == xml.dom.Node.ELEMENT_NODE:
+ if node.nodeName == 'batch':
+ #get batch number and status code
+ batch_number = node.getAttribute('batch_id')
+ result = node.getAttribute('status')
+ if result == "0":
+ return True
+ else:
+ return False
+ else:
+ return False
- return False
+ return False
-def setClusterConf(clusterconf, propagate=True):
- if propagate == True:
- propg = "True"
- else:
- propg = "False"
-
- QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="set_cluster.conf"/><var propagate="' + propg + '" cluster.conf="' + clusterconf + '"/></request></module></batch></ricci>'
-
- try:
- payload = self.makeConnection(QUERY_STR)
- except RicciReceiveError, r:
- return None
-
-
- batch_number, result = self.batchAttemptResult(payload)
- return (batch_number, result)
+ def setClusterConf(self, clusterconf, propagate=True):
+ if propagate == True:
+ propg = "True"
+ else:
+ propg = "False"
+
+ QUERY_STR='<?xml version="1.0" ?><ricci async="true" function="process_batch" version="1.0"><batch><module name="cluster"><request API_version="1.0"><function_call name="set_cluster.conf"/><var propagate="' + propg + '" cluster.conf="' + str(clusterconf) + '"/></request></module></batch></ricci>'
+
+ try:
+ payload = self.makeConnection(QUERY_STR)
+ except RicciReceiveError, r:
+ return None
+
+
+ batch_number, result = self.batchAttemptResult(payload)
+ return (batch_number, result)
def createClusterBatch(cluster_name, cluster_alias, nodeList, services, shared_storage, LVS):
next reply other threads:[~2006-07-28 11:46 UTC|newest]
Thread overview: 185+ messages / expand[flat|nested] mbox.gz Atom feed top
2006-07-28 11:46 jparsons [this message]
-- strict thread matches above, loose matches on Subject: below --
2008-07-17 16:36 [Cluster-devel] conga/luci/site/luci/Extensions cluster_adapte rmccabe
2008-04-18 20:37 rmccabe
2007-12-12 15:45 rmccabe
2007-08-23 19:00 rmccabe
2007-08-22 20:57 rmccabe
2007-05-03 19:51 rmccabe
2007-04-02 16:35 rmccabe
2007-04-02 15:56 rmccabe
2007-03-27 2:03 rmccabe
2007-03-16 3:19 rmccabe
2007-03-16 3:19 rmccabe
2007-03-16 3:19 rmccabe
2007-03-13 3:07 rmccabe
2007-03-13 3:06 rmccabe
2007-03-12 5:47 rmccabe
2007-03-12 5:46 rmccabe
2007-03-12 5:46 rmccabe
2007-03-06 22:48 rmccabe
2007-03-01 20:22 rmccabe
2007-03-01 20:22 rmccabe
2007-03-01 20:22 rmccabe
2007-02-13 19:50 rmccabe
2007-02-13 19:50 rmccabe
2007-02-12 20:25 rmccabe
2007-02-12 20:24 rmccabe
2007-02-07 22:00 rmccabe
2007-02-07 21:30 rmccabe
2007-02-05 19:56 rmccabe
2007-01-31 23:45 rmccabe
2007-01-31 19:28 rmccabe
2007-01-31 18:50 rmccabe
2007-01-30 21:41 jparsons
2007-01-30 21:21 jparsons
2007-01-30 21:05 jparsons
2007-01-29 23:30 rmccabe
2007-01-26 19:35 rmccabe
2007-01-18 2:48 rmccabe
2007-01-17 22:26 rmccabe
2007-01-17 22:14 rmccabe
2007-01-10 23:33 jparsons
2007-01-10 22:45 rmccabe
2007-01-10 20:06 rmccabe
2006-12-20 20:40 jparsons
2006-12-14 21:37 rmccabe
2006-12-14 17:03 rmccabe
2006-12-08 23:02 rmccabe
2006-11-30 20:12 jparsons
2006-11-27 21:06 rmccabe
2006-11-27 21:05 rmccabe
2006-11-27 18:15 rmccabe
2006-11-20 23:32 rmccabe
2006-11-20 15:05 jparsons
2006-11-17 5:50 rmccabe
2006-11-17 5:48 rmccabe
2006-11-10 18:18 rmccabe
2006-11-10 17:59 rmccabe
2006-11-09 22:30 rmccabe
2006-11-09 14:17 rmccabe
2006-11-08 21:42 rmccabe
2006-11-08 15:52 jparsons
2006-11-07 20:14 jparsons
2006-11-07 20:13 jparsons
2006-11-07 2:36 jparsons
2006-11-07 1:32 jparsons
2006-11-06 23:55 rmccabe
2006-11-05 0:59 rmccabe
2006-11-03 21:13 jparsons
2006-11-03 1:24 rmccabe
2006-11-03 1:08 rmccabe
2006-11-02 20:58 rmccabe
2006-11-02 20:45 rmccabe
2006-11-02 20:41 rmccabe
2006-11-02 3:17 rmccabe
2006-10-31 17:18 rmccabe
2006-10-31 0:16 rmccabe
2006-10-30 22:52 rmccabe
2006-10-30 20:43 jparsons
2006-10-27 1:11 rmccabe
2006-10-25 0:43 rmccabe
2006-10-24 14:08 rmccabe
2006-10-23 20:47 jparsons
2006-10-20 22:09 rmccabe
2006-10-20 21:59 rmccabe
2006-10-19 14:57 rmccabe
2006-10-18 23:12 rmccabe
2006-10-18 19:16 rmccabe
2006-10-16 21:01 rmccabe
2006-10-16 20:51 jparsons
2006-10-16 19:17 jparsons
2006-10-16 5:28 rmccabe
2006-10-16 4:54 rmccabe
2006-10-16 4:51 rmccabe
2006-10-13 22:56 rmccabe
2006-10-12 22:11 jparsons
2006-10-12 21:00 kupcevic
2006-10-12 20:54 jparsons
2006-10-12 20:48 jparsons
2006-10-12 19:40 rmccabe
2006-10-12 17:27 jparsons
2006-10-12 17:08 jparsons
2006-10-12 15:50 jparsons
2006-10-12 15:45 jparsons
2006-10-12 0:04 jparsons
2006-10-11 23:56 jparsons
2006-10-11 23:11 jparsons
2006-10-11 23:08 rmccabe
2006-10-11 22:37 jparsons
2006-10-11 20:58 jparsons
2006-10-11 17:43 jparsons
2006-10-11 17:29 rmccabe
2006-10-11 16:35 jparsons
2006-10-11 16:25 jparsons
2006-10-11 16:18 rmccabe
2006-10-10 21:33 kupcevic
2006-10-09 20:21 rmccabe
2006-10-04 16:20 rmccabe
2006-10-04 16:05 jparsons
2006-10-04 15:11 jparsons
2006-10-02 22:30 rmccabe
2006-10-02 21:42 rmccabe
2006-10-02 21:09 rmccabe
2006-10-02 20:53 rmccabe
2006-09-28 22:04 rmccabe
2006-09-28 20:10 rmccabe
2006-09-27 18:46 rmccabe
2006-09-27 16:18 jparsons
2006-09-27 15:51 jparsons
2006-09-27 15:35 jparsons
2006-09-25 22:59 rmccabe
2006-09-22 18:24 rmccabe
2006-08-30 22:59 rmccabe
2006-08-22 17:46 jparsons
2006-08-22 17:41 jparsons
2006-08-16 23:40 jparsons
2006-08-16 21:56 jparsons
2006-08-16 21:54 jparsons
2006-08-16 21:51 jparsons
2006-08-16 19:14 rmccabe
2006-08-16 16:10 jparsons
2006-08-14 15:12 jparsons
2006-08-13 19:38 jparsons
2006-08-13 19:37 jparsons
2006-08-13 18:36 jparsons
2006-08-13 16:32 jparsons
2006-08-13 16:15 jparsons
2006-08-13 15:02 jparsons
2006-08-13 14:57 jparsons
2006-08-13 13:48 jparsons
2006-08-12 21:13 jparsons
2006-08-12 20:31 jparsons
2006-08-12 18:22 jparsons
2006-08-12 17:53 jparsons
2006-08-11 0:29 jparsons
2006-08-10 23:06 shuennek
2006-08-10 16:50 jparsons
2006-08-10 14:16 jparsons
2006-08-09 22:05 jparsons
2006-08-09 21:48 jparsons
2006-08-03 13:37 jparsons
2006-08-02 18:59 rmccabe
2006-08-02 17:25 rmccabe
2006-08-01 15:29 jparsons
2006-08-01 15:25 jparsons
2006-08-01 15:20 jparsons
2006-08-01 15:13 jparsons
2006-08-01 15:04 jparsons
2006-07-31 18:21 rmccabe
2006-07-28 19:03 jparsons
2006-07-28 18:57 jparsons
2006-07-28 18:40 jparsons
2006-07-28 14:16 jparsons
2006-07-28 14:02 jparsons
2006-07-27 16:34 jparsons
2006-07-27 15:53 rmccabe
2006-07-25 20:16 jparsons
2006-07-25 20:01 jparsons
2006-07-25 0:56 jparsons
2006-07-24 21:51 jparsons
2006-07-24 21:13 jparsons
2006-07-24 19:50 jparsons
2006-07-19 22:28 rmccabe
2006-07-19 21:38 rmccabe
2006-07-19 20:57 rmccabe
2006-07-19 20:19 rmccabe
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20060728114635.21869.qmail@sourceware.org \
--to=jparsons@sourceware.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.