From e226690c555e87ac13f5d2543d197864e4d0270c Mon Sep 17 00:00:00 2001 From: Narayan Desai Date: Fri, 15 May 2009 03:57:33 +0000 Subject: Merge xmlrpc interfaces with Bcfg2.Server.Core git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@5238 ce84e21b-d406-0410-9b95-82705330c041 --- src/lib/Server/XMLRPC.py | 160 ----------------------------------------------- 1 file changed, 160 deletions(-) delete mode 100644 src/lib/Server/XMLRPC.py (limited to 'src/lib/Server/XMLRPC.py') diff --git a/src/lib/Server/XMLRPC.py b/src/lib/Server/XMLRPC.py deleted file mode 100644 index 36d7c3b79..000000000 --- a/src/lib/Server/XMLRPC.py +++ /dev/null @@ -1,160 +0,0 @@ - -import hashlib -import logging -import lxml.etree -import select -import socket -import threading -import time -import xmlrpclib - -from Bcfg2.Component import Component, automatic, exposed, locking -import Bcfg2.Server.Core - -logger = logging.getLogger('server') - -def critical_error(operation): - '''Log and err, traceback and return an xmlrpc fault to client''' - logger.error(operation, exc_info=1) - raise xmlrpclib.Fault(7, "Critical unexpected failure: %s" % (operation)) - -class SetupError(Exception): - '''Used when the server cant be setup''' - pass - -class bcfg2_server(Component, - Bcfg2.Server.Core.Core): - '''XML RPC interfaces for the server core''' - name = 'bcfg2-server' - implementation = 'bcfg2-server' - - def __init__(self, setup): - Component.__init__(self) - Bcfg2.Server.Core.Core.__init__(self, setup['repo'], setup['plugins'], - setup['password'], - setup['encoding'], setup['filemonitor']) - self.ca = setup['ca'] - self.fam_thread = threading.Thread(target=self._file_monitor_thread) - self.fam_thread.start() - - def _file_monitor_thread(self): - famfd = self.fam.fileno() - while True: - try: - if famfd: - rsockinfo = select.select([famfd], [], []) - else: - while not self.fam.pending(): - time.sleep(15) - self.fam.handle_event_set(self.lock) - except: - continue - - @exposed - def GetProbes(self, address): - '''Fetch probes for a particular client''' - resp = lxml.etree.Element('probes') - try: - name = self.metadata.resolve_client(address) - meta = self.build_metadata(name) - - for plugin in [p for p in list(self.plugins.values()) \ - if isinstance(p, Bcfg2.Server.Plugin.Probing)]: - for probe in plugin.GetProbes(meta): - resp.append(probe) - return lxml.etree.tostring(resp, encoding='UTF-8', - xml_declaration=True) - except Bcfg2.Server.Plugins.Metadata.MetadataConsistencyError: - warning = 'Client metadata resolution error for %s; check server log' % address[0] - self.logger.warning(warning) - raise xmlrpclib.Fault(6, warning) - except: - critical_error("error determining client probes") - - @exposed - def RecvProbeData(self, address, probedata): - '''Receive probe data from clients''' - try: - name = self.metadata.resolve_client(address) - meta = self.build_metadata(name) - except Bcfg2.Server.Plugins.Metadata.MetadataConsistencyError: - warning = 'metadata consistency error' - self.logger.warning(warning) - raise xmlrpclib.Fault(6, warning) - # clear dynamic groups - self.metadata.cgroups[meta.hostname] = [] - try: - xpdata = lxml.etree.XML(probedata) - except: - self.logger.error("Failed to parse probe data from client %s" % \ - (address[0])) - return False - - sources = [] - [sources.append(data.get('source')) for data in xpdata - if data.get('source') not in sources] - for source in sources: - if source not in self.plugins: - self.logger.warning("Failed to locate plugin %s" % (source)) - continue - dl = [data for data in xpdata if data.get('source') == source] - try: - self.plugins[source].ReceiveData(meta, dl) - except: - logger.error("Failed to process probe data from client %s" % \ - (address[0]), exc_info=1) - return True - - @exposed - def AssertProfile(self, address, profile): - '''Set profile for a client''' - try: - client = self.metadata.resolve_client(address) - self.metadata.set_profile(client, profile, address) - except (Bcfg2.Server.Plugins.Metadata.MetadataConsistencyError, - Bcfg2.Server.Plugins.Metadata.MetadataRuntimeError): - warning = 'metadata consistency error' - self.logger.warning(warning) - raise xmlrpclib.Fault(6, warning) - return True - - @exposed - def GetConfig(self, address, checksum=False): - '''Build config for a client''' - try: - client = self.metadata.resolve_client(address) - config = self.BuildConfiguration(client) - if checksum: - for cfile in config.findall('.//ConfigFile'): - if cfile.text != None: - csum = hashlib.md5() - csum.update(cfile.text) - cfile.set('checksum', csum.hexdigest()) - cfile.text = None - return lxml.etree.tostring(config, encoding='UTF-8', - xml_declaration=True) - except Bcfg2.Server.Plugins.Metadata.MetadataConsistencyError: - self.logger.warning("Metadata consistency failure for %s" % (address)) - raise xmlrpclib.Fault(6, "Metadata consistency failure") - - @exposed - def RecvStats(self, address, stats): - '''Act on statistics upload''' - sdata = lxml.etree.XML(stats) - client = self.metadata.resolve_client(address) - self.process_statistics(client, sdata) - return "" - - def authenticate(self, cert, user, password, address): - if self.ca: - acert = cert - else: - # no ca, so no cert validation can be done - acert = None - return self.metadata.AuthenticateConnection(acert, user, password, address) - - @exposed - def GetDecisionList(self, address, mode): - client = self.metadata.resolve_client(address) - meta = self.build_metadata(client) - return self.GetDecisions(meta, mode) -- cgit v1.2.3-1-g7c22