From e2210f07ba102dfbe16944be9c3b506dc310925c Mon Sep 17 00:00:00 2001 From: Narayan Desai Date: Mon, 28 Nov 2005 21:44:30 +0000 Subject: Rename: src/sbin/Bcfg2ServerX -> src/sbin/Bcfg2Server }(Logical change 1.369) git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@1554 ce84e21b-d406-0410-9b95-82705330c041 --- src/sbin/Bcfg2ServerX | 187 -------------------------------------------------- 1 file changed, 187 deletions(-) delete mode 100644 src/sbin/Bcfg2ServerX (limited to 'src') diff --git a/src/sbin/Bcfg2ServerX b/src/sbin/Bcfg2ServerX deleted file mode 100644 index 76e4e7dac..000000000 --- a/src/sbin/Bcfg2ServerX +++ /dev/null @@ -1,187 +0,0 @@ -#!/usr/bin/env python - -'''The XML-RPC Bcfg2 Server''' -__revision__ = '$Revision:$' - -from getopt import getopt, GetoptError -from sys import argv, exc_info -from syslog import openlog, LOG_LOCAL0, syslog, LOG_INFO, LOG_ERR -from Bcfg2.Server.Core import Core, CoreInitError -from Bcfg2.Server.Metadata import MetadataConsistencyError -from Bcfg2.Server.Component import Component -from threading import Lock -from select import select, error as selecterror -from signal import signal, SIGINT, SIGTERM -from xmlrpclib import Fault -from socket import gethostbyaddr, herror -from lxml.etree import XML, Element, tostring -from M2Crypto.SSL import SSLError - -def dgetopt(arglist, opt, vopt): - '''parse options into a dictionary''' - ret = {} - for optname in opt.values() + vopt.values(): - ret[optname] = False - gstr = "".join(opt.keys()) + "".join([field+':' for field in vopt.keys()]) - try: - opts = getopt(arglist, gstr)[0] - except GetoptError, gerr: - print gerr - print "bcfg2 Usage:" - for arg in opt.iteritems(): - print " -%s %s" % arg - for arg in vopt.iteritems(): - print " -%s <%s>" % arg - raise SystemExit, 1 - for (gopt, garg) in opts: - option = gopt[1:] - if opt.has_key(option): - ret[opt[option]] = True - else: - ret[vopt[option]] = garg - return ret - -class Bcfg2(Component): - """The Bcfg2 Server component providing XML-RPC access to Bcfg methods""" - __name__ = 'bcfg2' - __implementation__ = 'bcfg2' - - request_queue_size = 15 - - def __init__(self, setup): - Component.__init__(self, setup) - self.shut = False - # set shutdown handlers for sigint and sigterm - signal(SIGINT, self.start_shutdown) - signal(SIGTERM, self.start_shutdown) - try: - self.Core = Core(setup, setup['configfile']) - self.CoreLock = Lock() - except CoreInitError, msg: - print msg - raise SystemExit, 1 - self.funcs.update({"GetConfig":self.Bcfg2GetConfig, "GetProbes":self.Bcfg2GetProbes, - "RecvProbeData":self.Bcfg2RecvProbeData, "RecvStats":self.Bcfg2RecvStats}) - for plugin in self.Core.plugins.values(): - for method in plugin.__rmi__: - self.register_function(getattr(self.Core.plugins[plugin.__name__], method), - "%s.%s" % (plugin.__name__, method)) - - def get_request(self): - '''We need to do work between requests, so select with timeout instead of blocking in accept''' - rsockinfo = [] - famfd = self.Core.fam.fileno() - while self.socket not in rsockinfo: - if self.shut: - raise SSLError - try: - rsockinfo = select([self.socket, famfd], [], [], 15)[0] - except selecterror: - raise SSLError - if famfd in rsockinfo: - self.Core.fam.Service() - if self.socket in rsockinfo: - # workaround for m2crypto 0.15 bug - self.socket.postConnectionCheck = None - return self.socket.accept() - - def serve_forever(self): - """Handle one request at a time until doomsday.""" - while not self.shut: - self.handle_request() - - def start_shutdown(self, signum, frame): - '''Shutdown on unexpected signals''' - self.shut = True - - def handle_error(self): - '''Catch error path for clean exit''' - return False - - def Bcfg2GetProbes(self, address): - '''Fetch probes for a particular client''' - peer = address[0] - resp = Element('probes') - try: - client = gethostbyaddr(peer)[0] - except herror: - raise Fault, "host resolution error" - try: - meta = self.Core.metadata.FetchMetadata(client) - except MetadataConsistencyError: - raise Fault, 'metadata resolution error' - for generator in self.Core.generators: - for probe in generator.GetProbes(meta): - resp.append(probe) - return tostring(resp) - - def Bcfg2RecvProbeData(self, address, probedata): - '''Receive probe data from clients''' - peer = address[0] - try: - client = gethostbyaddr(peer)[0] - except herror: - raise Fault, "host resolution error" - for data in probedata: - try: - [generator] = [gen for gen in self.Core.generators if gen.__name__ == data.get('source')] - generator.ReceiveData(client, data) - except IndexError: - syslog(LOG_ERR, "Failed to locate plugin %s" % (data.get('source'))) - except: - syslog(LOG_ERR, "Unexpected failure in probe data receipt") - return True - - def Bcfg2GetConfig(self, address, image=False, profile=False): - '''Build config for a client''' - peer = address[0] - try: - client = gethostbyaddr(peer)[0] - except herror: - raise Fault, "host resolution error" - if image and profile: - try: - # if metadata is provided, call FetchMetadata with settings - # it is screwey. i know. - self.Core.metadata.FetchMetadata(client, image=image, profile=profile) - except MetadataConsistencyError: - syslog(LOG_ERR, "Metadata consistency error for client %s" % client) - return Fault, 'metadata error' - return tostring(self.Core.BuildConfiguration(client)) - - def Bcfg2RecvStats(self, address, stats): - '''Act on statistics upload''' - sdata = XML(stats) - state = sdata.find(".//Statistics") - # Versioned stats to prevent tied client/server upgrade - if state.get('version') >= '2.0': - try: - client = gethostbyaddr(address[0])[0] - except herror: - return Fault, 'host resolution error' - - # Update statistics - self.Core.stats.updateStats(sdata, client) - - syslog(LOG_INFO, "Client %s reported state %s"%(client, state.attrib['state'])) - return "" - -if __name__ == '__main__': - openlog("Bcfg2", 0, LOG_LOCAL0) - options = {'v':'verbose', 'd':'debug'} - doptions = {'D':'daemon', 'c':'configfile', 'C':'client'} - ssetup = dgetopt(argv[1:], options, doptions) - if not ssetup['configfile']: - ssetup['configfile'] = '/etc/bcfg2.conf' - s = Bcfg2(ssetup) - while not s.shut: - try: - s.serve_forever() - except: - syslog(LOG_ERR, "Unexpected serve loop failure") - (trace, val, trb)=exc_info() - for line in extract_tb(trb): - syslog(LOG_ERR, ' File "%s", line %i, in %s\n %s\n'%line) - syslog(LOG_ERR, "%s: %s\n"%(trace, val)) - del trace, val, trb - syslog(LOG_INFO, "Shutting down") -- cgit v1.2.3-1-g7c22