parallel_emerge: print total time and load in status output

parallel_emerge

 #!/usr/bin/python2.6
 # Copyright (c) 2010 The Chromium OS Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Program to run emerge in parallel, for significant speedup.
 
 Usage:
  ./parallel_emerge --board=BOARD [emerge args] package
 
@@ skipping 49 matching lines @@
 # emerge args we are passing through.
 PACKAGE = None
 EMERGE_ARGS = ""
 BOARD = None
 
 # Runtime flags. TODO(): Maybe make these command-line options or
 # environment variables.
 VERBOSE = False
 AUTOCLEAN = False
 
+# Global start time
+GLOBAL_START = time.time()
+
 
 def ParseArgs(argv):
   """Set global vars based on command line.
 
   We need to be compatible with emerge arg format.
   We scrape --board=XXX and --jobs=XXX, and distinguish between args
   and package names.
   TODO(): Robustify argument processing, as it's possible to
   pass in many two argument parameters that are difficult
   to programmatically identify, although we don't currently
@@ skipping 386 matching lines @@
     # List of total package installs represented in deps_map.
     install_jobs = [x for x in deps_map if deps_map[x]["action"] == "merge"]
     self._total_jobs = len(install_jobs)
 
     # Initialize the ready queue, these are jobs with no unmet dependencies.
     self._emerge_queue = [x for x in deps_map if not deps_map[x]["needs"]]
     # Initialize the failed queue to empty.
     self._retry_queue = []
     self._failed = {}
 
+  def _LoadAvg(self):
+    loads = open('/proc/loadavg', 'r').readline().split()[:3]
+    return ' '.join(loads)
+
   def _Status(self):
     """Print status."""
-    print "Pending %s, Ready %s, Running %s, Retrying %s, Total %s" % (
+    seconds = time.time() - GLOBAL_START
+    print "Pending %s, Ready %s, Running %s, Retrying %s, Total %s " \
+        "[Time %dm%ds Load %s]" % (
         len(self._deps_map), len(self._emerge_queue),
-        len(self._jobs), len(self._retry_queue), self._total_jobs)
+        len(self._jobs), len(self._retry_queue), self._total_jobs,
+        seconds / 60, seconds % 60, self._LoadAvg())
 
   def _LaunchOneEmerge(self, target):
     """Run emerge --nodeps to do a single package install.
 
     If this is a pseudopackage, that means we're done, and can select in in the
     world file.
     Args:
       target: The full package name of the package to install.
               eg. "sys-apps/portage-2.17"
     Returns:
@@ skipping 169 matching lines @@
 
 if VERBOSE:
   PrintDepsMap(dependency_graph)
 
 # Run the queued emerges.
 scheduler = EmergeQueue(dependency_graph)
 scheduler.Run()
 
 print "Done"