From 96683f7c9d3eb6c71fcd12f4847cacd2359024be Mon Sep 17 00:00:00 2001
From: Narayan Desai <desai@mcs.anl.gov>
Date: Mon, 11 Oct 2004 20:16:38 +0000
Subject: kill installation algorithm code

(Logical change 1.84)


git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@404 ce84e21b-d406-0410-9b95-82705330c041
---
 src/sbin/bcfg2 | 113 +--------------------------------------------------------
 1 file changed, 2 insertions(+), 111 deletions(-)

(limited to 'src')

diff --git a/src/sbin/bcfg2 b/src/sbin/bcfg2
index caa997b70..a790e94d7 100644
--- a/src/sbin/bcfg2
+++ b/src/sbin/bcfg2
@@ -1,11 +1,9 @@
 #!/usr/bin/env python
 from getopt import getopt, GetoptError
 from os import popen, chmod, unlink
-from sys import argv, exit, exc_info
+from sys import argv, exit
 from string import join
 from tempfile import mktemp
-from time import asctime, localtime
-from traceback import extract_tb
 
 from elementtree.ElementTree import Element, XML, tostring
 
@@ -13,14 +11,6 @@ from sss.ssslib import comm_lib
 
 from Bcfg2.Client.Debian import Debian
 
-def ElementMatch(master, sub):
-    if master.tag == sub.tag:
-        for k in sub.attrib.keys():
-            if master.attrib[k] != sub.attrib[k]:
-                return False
-        return True
-    return False
-
 def RunProbe(probe):
     ret = Element("probe-data", name=probe.attrib['name'], source=probe.attrib['source'])
     script = open(mktemp(), 'w+')
@@ -55,105 +45,6 @@ def dgetopt(arglist, opt, vopt):
             r[vopt[option]] = garg
     return r
 
-class ClientState(object):
-    def __init__(self, cfg, setup):
-        self.states = {}
-        self.structures = {}
-        self.cfg = cfg
-        self.setup = setup
-        self.modified = []
-        self.extra = []
-        self.toolset = Debian(cfg, setup)
-
-    def LogFailure(self, area, entry):
-        print "Failure in %s for entry: %s"%(area, tostring(entry))
-        (t,v,tb) = exc_info()
-        for line in extract_tb(tb):
-            print "File %s, line %i, in %s\n   %s\n"%(line)
-        print "%s: %s\n"%(t,v)
-        del t,v,tb
-
-    def VerifyEntry(self, entry, modlist = []):
-         try:
-            method = getattr(self.toolset, "Verify%s"%(entry.tag))
-            # verify state and stash value in state
-            if entry.tag == 'Package':
-                self.states[entry] = method(entry, modlist)
-            else:
-                self.states[entry] = method(entry)
-
-            if self.setup['debug']:
-                print entry.attrib['name'], self.states[entry]
-         except:
-            self.LogFailure("Verify", entry)
-
-    def InstallEntry(self, entry):
-        try:
-            method = getattr(self.toolset, "Install%s"%(entry.tag))
-            self.states[entry] = method(entry)
-        except:
-            self.LogFailure("Install", entry)
-
-    def Inventory(self):
-        # build initial set of states
-        unexamined = map(lambda x:(x,[]), self.cfg.getchildren())
-        while unexamined:
-            (r, modlist) = unexamined.pop()
-            if r.tag not in ['Bundle', 'Independant']:
-                self.VerifyEntry(r, modlist)
-            else:
-                modlist = [x.attrib['name'] for x in r.getchildren() if x.tag == 'ConfigFile']
-                unexamined += map(lambda x:(x,modlist), r.getchildren())
-                self.structures[r] = False
-
-        for structure in self.cfg.getchildren():
-            self.CheckStructure(structure)
-
-        # TwoWay: build list of "extra configs"
-        #e = self.toolset.FindElements()
-        #known = self.states.keys()
-        #for entry in e:
-        #    if not filter(lambda x:ElementMatch(x, entry), known):
-        #        self.extra.append(entry)
-        #print self.extra
-
-    def CheckStructure(self, structure):
-        if structure in self.modified:
-            self.modified.remove(structure)
-            if structure.tag == 'Bundle':
-                # check for clobbered data
-                modlist = [x.attrib['name'] for x in structure.getchildren() if x.tag == 'ConfigFile']
-                for entry in structure.getchildren():
-                    self.VerifyEntry(entry, modlist)
-        try:
-            state = map(lambda x:self.states[x], structure.getchildren())
-            if False not in state:
-                self.structures[structure] = True
-        except KeyError, k:
-            print "State verify evidently failed for %s"%(k)
-            self.structures[structure] = False
-
-    def Install(self):
-        self.modified  =  [k for (k,v) in self.structures.iteritems() if not v]
-        for entry in [k for (k,v) in self.states.iteritems() if not v]:
-            self.InstallEntry(entry)
-
-    def Commit(self):
-        self.toolset.Commit(self.states)
-
-    def GenerateStats(self):
-        stats = Element("Statistics")
-        SubElement(stats, "Structures", good=str(len([k for k,v in self.structures.iteritems() if v])), \
-                   bad=str(len([k for k,v in self.structures.iteritems() if not v])))
-        SubElement(stats, "Entries", good=str(len([k for k,v in self.states.iteritems() if v])), \
-                   bad=str(len([k for k,v in self.states.iteritems() if not v])))
-        if len([k for k,v in self.structures.iteritems() if not v]) == 0:
-            stats.attrib['state'] = 'clean'
-        else:
-            stats.attrib['state'] = 'dirty'
-        stats.attrib['time'] = asctime(localtime())
-        return stats
-
 if __name__ == '__main__':
     # parse command line options
     options =  {'v':'verbose','q':'quick', 'd':'debug', 'n':'dryrun', 'B':'build', 'p':'paranoid'}
@@ -197,7 +88,7 @@ if __name__ == '__main__':
         print "got error from server"
         exit(1)
 
-    client = ClientState(cfg, setup)
+    client = Debian(cfg, setup)
     # verify state
     client.Inventory()
 
-- 
cgit v1.2.3-1-g7c22