From 6b87597e97902a3f7a1a0f6eb1af02eb65c2af37 Mon Sep 17 00:00:00 2001
From: Narayan Desai <desai@mcs.anl.gov>
Date: Thu, 1 Sep 2005 19:54:40 +0000
Subject: fix version detection

2005/09/01 14:40:39-05:00 anl.gov!desai
simplify and optimize package performance

(Logical change 1.292)


git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@1163 ce84e21b-d406-0410-9b95-82705330c041
---
 src/lib/Client/Redhat.py | 57 ++++++++++++++++++++++++------------------------
 1 file changed, 29 insertions(+), 28 deletions(-)

(limited to 'src/lib/Client/Redhat.py')

diff --git a/src/lib/Client/Redhat.py b/src/lib/Client/Redhat.py
index ffcd2c003..d0bdbbfa2 100644
--- a/src/lib/Client/Redhat.py
+++ b/src/lib/Client/Redhat.py
@@ -23,10 +23,10 @@ class Redhat(Toolset):
         self.installed = {}
 
         # Build list of packages
-        instp = popen("rpm -qa --qf '%{NAME} %{VERSION}\n'")
+        instp = popen("rpm -qa --qf '%{NAME} %{VERSION}-%{RELEASE}\n'")
         for line in instp:
             [name, version] = line.split(' ')
-            self.installed[name] = version
+            self.installed[name] = version[:-1]
 
     def VerifyService(self, entry):
         '''Verify Service status for entry'''
@@ -71,31 +71,32 @@ class Redhat(Toolset):
         if not entry.get('version'):
             print "Can't install package %s, not enough data." % (entry.get('name'))
             return False
-        instp = Popen4("rpm -qi %s-%s" % (entry.get('name'), entry.get('version')))
-        istat = instp.poll()
-        while istat == -1:
-            instp.fromchild.read()
-            istat = instp.poll()
-        if istat != 0:
-            self.CondPrint('debug', "Package %s version incorrect" % entry.get('name'))
-        else:
-            if entry.attrib.get('verify', 'true') == 'true':
-                if self.setup['quick']:
-                    return True
-                verp = Popen4("rpm --verify -q %s-%s" %
-                              (entry.get('name'),entry.get('version')), bufsize=16384)
-                odata = verp.fromchild.read()
-                vstat = verp.poll()
-                while vstat == -1:
-                    odata += verp.fromchild.read()
-                    vstat = verp.poll()
-                output = [line for line in odata.split("\n") if line]
-                if vstat == 0:
+        if self.installed.has_key(entry.get('name')):
+            if entry.get('version') == self.installed[entry.get('name')]:
+                if (self.setup['quick'] or (entry.get('verify', 'true') == 'false')):
                     return True
-                else:
-                    if len([name for name in output if name.split()[-1] not in modlist]):
-                        return True
-                    else:
-                        self.CondPrint('debug',
-                                       "Package %s content verification failed" % entry.get('name'))
+            else:
+                self.CondPrint('debug', "Package %s: wrong version installed. want %s have %s" %
+                               (entry.get('name'), entry.get('version'), self.installed[entry.get('name')]))
+                return False
+        else:
+            self.CondPrint('debug', "Package %s: not installed" % (entry.get('name')))
+            return False
+
+        verp = Popen4("rpm --verify -q %s-%s" %
+                      (entry.get('name'),entry.get('version')), bufsize=16384)
+        odata = verp.fromchild.read()
+        vstat = verp.poll()
+        while vstat == -1:
+            odata += verp.fromchild.read()
+            vstat = verp.poll()
+            output = [line for line in odata.split("\n") if line]
+        if vstat == 0:
+            return True
+        else:
+            if len([name for name in output if name.split()[-1] not in modlist]):
+                return True
+            else:
+                self.CondPrint('debug',
+                               "Package %s content verification failed" % entry.get('name'))
         return False
-- 
cgit v1.2.3-1-g7c22