From 62820aa7196faa3cad7e71310c14cfa49fc4ea5e Mon Sep 17 00:00:00 2001 From: Narayan Desai Date: Tue, 29 Nov 2005 20:00:54 +0000 Subject: Delete: src/lib/Client/XMLRPCComm.py }(Logical change 1.372) git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@1565 ce84e21b-d406-0410-9b95-82705330c041 --- src/lib/Client/XMLRPCComm.py | 70 -------------------------------------------- 1 file changed, 70 deletions(-) delete mode 100644 src/lib/Client/XMLRPCComm.py (limited to 'src') diff --git a/src/lib/Client/XMLRPCComm.py b/src/lib/Client/XMLRPCComm.py deleted file mode 100644 index 85af535da..000000000 --- a/src/lib/Client/XMLRPCComm.py +++ /dev/null @@ -1,70 +0,0 @@ -'''XMLRPC/SSL Communication Library (following the ssslib API)''' -__revision__ = '$Revision:$' - -from lxml.etree import XML -from ConfigParser import ConfigParser -from xmlrpclib import Fault, ServerProxy -from sys import exc_info -from traceback import extract_tb - -class CommunicationError(Exception): - '''Duplicate the sss.ssslib error API''' - pass - -class comm_lib(object): - '''This sets up the communication for XMLRPC Bcfg2''' - - def __init__(self): - self.cf = ConfigParser() - self.cf.read('/etc/bcfg2.conf') - location = self.cf.get("components", "bcfg2") - self.proxy = ServerProxy(location) - self.user = 'root' - self.password = self.cf.get("communication", "password") - - def ClientInit(self, component): - '''Return a single dummy handle''' - return "handle" - - def SendMessage(self, handle, msg): - '''Encode the XML msg as an XML-RPC request''' - data = XML(msg) - args = (self.user, self.password) - if data.tag == 'get-probes': - funcname = "GetProbes" - elif data.tag == 'probe-data': - funcname = "RecvProbeData" - args = (self.user, self.password, data.getchildren()) - elif data.tag == 'get-config': - funcname = 'GetConfig' - elif data.tag == 'upload-statistics': - funcname = "RecvStats" - args = (self.user, self.password, msg) - else: - print "unsupported function call" - raise CommunicationError, "foo" - func = getattr(self.proxy, funcname) - for i in range(5): - try: - self.response = apply(func, args) - return - except Fault, msg: - raise CommunicationError, msg - except: - print "Transient communication error; retrying" - continue - (trace, val, trb) = exc_info() - print "Unexpected communication error after retry" - for line in extract_tb(trb): - print ' File "%s", line %i, in %s\n %s\n' % line - print "%s: %s\n" % (trace, val) - del trace, val, trb - raise CommunicationError, "no connect" - - def RecvMessage(self, handle): - '''Return cached response''' - return self.response - - def ClientClose(self, handle): - '''This is a noop for xmlrpc''' - pass -- cgit v1.2.3-1-g7c22