From 33a351a6fad6c0beb8e29e14c031367d4ed29e34 Mon Sep 17 00:00:00 2001
From: Narayan Desai <desai@mcs.anl.gov>
Date: Mon, 12 Sep 2005 20:33:27 +0000
Subject: new pkgtool API to allow for multiple package types on a single arch

(Logical change 1.304)


git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@1246 ce84e21b-d406-0410-9b95-82705330c041
---
 src/lib/Client/Toolset.py | 73 ++++++++++++++++++++++++++---------------------
 1 file changed, 40 insertions(+), 33 deletions(-)

(limited to 'src/lib/Client')

diff --git a/src/lib/Client/Toolset.py b/src/lib/Client/Toolset.py
index 7b7296da0..7d7715eda 100644
--- a/src/lib/Client/Toolset.py
+++ b/src/lib/Client/Toolset.py
@@ -495,42 +495,49 @@ class Toolset(object):
             [self.InstallEntry(ent) for ent in work if ent.tag != 'Package']
 
             packages = [pkg for pkg in work if pkg.tag == 'Package']
+            ptypes = []
+            [ptypes.append(ptype) for ptype in [pkg.get('type') for pkg in packages]
+             if pkg.get('type') not in ptypes]
             if packages:
-                # try single large install
-                self.CondPrint("verbose", "Trying single pass package install")
-                pkglist = " ".join([self.pkgtool[1][0] % tuple([pkg.get(field, '') for field in self.pkgtool[1][1]])
-                                    for pkg in packages])
-                self.CondPrint("debug", "Installing packages: %s" % pkglist)
-                cmdrc = system(self.pkgtool[0] % pkglist)
-
-                if cmdrc == 0:
-                    self.CondPrint('verbose', "Single Pass Succeded")
-                    # set all package states to true and flush workqueues
-                    badpkgs = [entry for entry in self.states.keys() if entry.tag == 'Package'
-                               and not self.states[entry]]
-                    for entry in badpkgs:
-                        self.CondPrint('debug', 'Setting state to true for pkg %s' % (entry.get('name')))
-                        self.states[entry] = True
-                    self.Refresh()
-                else:
-                    self.CondPrint("verbose", "Single Pass Failed")
-                    # do single pass installs
-                    #system("dpkg --configure --pending")
-                    self.Refresh()
-                    for pkg in packages:
-                        # handle state tracking updates
-                        if self.VerifyPackage(pkg, []):
-                            self.CondPrint("verbose", "Forcing state to true for pkg %s" % (pkg.get('name')))
-                            self.states[pkg] = True
-                        else:
-                            self.CondPrint("verbose", "Installing pkg %s version %s" %
-                                           (pkg.get('name'), pkg.get('version')))
-                            cmdrc = system(self.pkgtool[0] %
-                                           (self.pkgtool[1][0]%tuple([pkg.get(field) for field in self.pkgtool[1][1]])))
-                            if cmdrc == 0:
+                for pkgtype in ptypes:
+                    # try single large install
+                    self.CondPrint("verbose", "Trying single pass package install for pkgtype %s" % pkgtype)
+                    if not self.pkgtool.has_key(pkgtype):
+                        self.CondPrint("verbose", "No support for pkgtype %s" % (pkgtype))
+                        continue
+                    pkgtool = self.pkgtool[pkgtype]
+                    pkglist = " ".join([pkgtool[1][0] % tuple([pkg.get(field, '') for field in pkgtool[1][1]])
+                                        for pkg in packages if pkg.get('type') == pkgtype])
+                    self.CondPrint("debug", "Installing packages: %s" % pkglist)
+                    cmdrc = system(pkgtool[0] % pkglist)
+
+                    if cmdrc == 0:
+                        self.CondPrint('verbose', "Single Pass Succeded")
+                        # set all package states to true and flush workqueues
+                        badpkgs = [entry for entry in self.states.keys() if entry in pkglist
+                                   and not self.states[entry]]
+                        for entry in badpkgs:
+                            self.CondPrint('debug', 'Setting state to true for pkg %s' % (entry.get('name')))
+                            self.states[entry] = True
+                        self.Refresh()
+                    else:
+                        self.CondPrint("verbose", "Single Pass Failed")
+                        # do single pass installs
+                        self.Refresh()
+                        for pkg in pkglist:
+                            # handle state tracking updates
+                            if self.VerifyPackage(pkg, []):
+                                self.CondPrint("verbose", "Forcing state to true for pkg %s" % (pkg.get('name')))
                                 self.states[pkg] = True
                             else:
-                                self.CondPrint('verbose', "Failed to install package %s" % (pkg.get('name')))
+                                self.CondPrint("verbose", "Installing pkg %s version %s" %
+                                               (pkg.get('name'), pkg.get('version')))
+                                cmdrc = system(pkgtool[0] %
+                                               (pkgtool[1][0]%tuple([pkg.get(field) for field in pkgtool[1][1]])))
+                                if cmdrc == 0:
+                                    self.states[pkg] = True
+                                else:
+                                    self.CondPrint('verbose', "Failed to install package %s" % (pkg.get('name')))
             for entry in [ent for ent in work if self.states[ent]]:
                 work.remove(entry)
                 self.modified.append(entry)
-- 
cgit v1.2.3-1-g7c22