TMP

Signed-off-by: Ciprian Hacman <[email protected]>

Author: hakman

upup/pkg/fi/nodeup/nodetasks/package.go

@@ -269,9 +269,13 @@ func (_ *Package) CheckChanges(a, e, changes *Package) error {
 // It just avoids unnecessary failures from running e.g. concurrent apt-get installs
 var packageManagerLock sync.Mutex
 
+// packageManagerLastUpdated is the last time the package manager update was done
+var packageManagerLastUpdated time.Time
+
 func (_ *Package) RenderLocal(t *local.LocalTarget, a, e, changes *Package) error {
 	packageManagerLock.Lock()
 	defer packageManagerLock.Unlock()
+	klog.V(2).Infof("Package Manager last updated: %s", packageManagerLastUpdated)
 
 	d, err := distributions.FindDistribution("/")
 	if err != nil {
@@ -332,10 +336,13 @@ func (_ *Package) RenderLocal(t *local.LocalTarget, a, e, changes *Package) erro
 			// If it is newer than 10 minutes, we skip apt-get update.
 			stat, err := os.Stat("/var/lib/dpkg/status")
 			if err == nil && stat.ModTime().After(time.Now().Add(-10*time.Minute)) {
+				klog.V(2).Infof("/var/lib/dpkg/status last updated: %s", stat.ModTime())
 				klog.V(2).Infof("Skipping fetching the list of available packages")
 			} else {
-				if err != nil && !os.IsNotExist(err) {
+				if err != nil {
 					klog.Warningf("Error getting dpkg status info: %v", err)
+				} else {
+					klog.V(2).Infof("/var/lib/dpkg/status last updated: %s", stat.ModTime())
 				}
 				args := []string{"apt-get", "update"}
 				klog.Infof("Running command %s", args)
@@ -345,6 +352,7 @@ func (_ *Package) RenderLocal(t *local.LocalTarget, a, e, changes *Package) erro
 				if err != nil {
 					return fmt.Errorf("error fetching the list of available packages: %v:\n%s", err, string(output))
 				}
+				packageManagerLastUpdated = time.Now()
 			}
 		}
 
@@ -386,6 +394,7 @@ func (_ *Package) RenderLocal(t *local.LocalTarget, a, e, changes *Package) erro
 			}
 			return fmt.Errorf("error installing package %q: %v: %s", e.Name, err, string(output))
 		}
+		packageManagerLastUpdated = time.Now()
 	} else {
 		if changes.Healthy != nil {
 			if d.IsDebianFamily() {