Run tests sorted by expected runtime.

tools/testrunner/network/network_execution.py

 # Copyright 2012 the V8 project authors. All rights reserved.
 # Redistribution and use in source and binary forms, with or without
 # modification, are permitted provided that the following conditions are
 # met:
 #
 #     * Redistributions of source code must retain the above copyright
 #       notice, this list of conditions and the following disclaimer.
 #     * Redistributions in binary form must reproduce the above
 #       copyright notice, this list of conditions and the following
 #       disclaimer in the documentation and/or other materials provided
@@ skipping 15 matching lines @@
 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 
 
 import os
 import socket
 import subprocess
 import threading
 import time
 
 from . import distro
-from . import perfdata
 from ..local import execution
+from ..local import perfdata
 from ..objects import peer
 from ..objects import workpacket
 from ..server import compression
 from ..server import constants
 from ..server import local_handler
 from ..server import signatures
 
 
 def GetPeers():
   data = local_handler.LocalQuery([constants.REQUEST_PEERS])
   if not data: return []
   return [ peer.Peer.Unpack(p) for p in data ]
 
 
 class NetworkedRunner(execution.Runner):
   def __init__(self, suites, progress_indicator, context, peers, workspace):
     self.suites = suites
     num_tests = 0
     datapath = os.path.join("out", "testrunner_data")
+    # TODO(machenbach): These fields should exist now in the superclass.
+    # But there is no super constructor call. Check if this is a problem.
     self.perf_data_manager = perfdata.PerfDataManager(datapath)
     self.perfdata = self.perf_data_manager.GetStore(context.arch, context.mode)
     for s in suites:
       for t in s.tests:
         t.duration = self.perfdata.FetchPerfData(t) or 1.0
       num_tests += len(s.tests)
     self._CommonInit(num_tests, progress_indicator, context)
     self.tests = []  # Only used if we need to fall back to local execution.
     self.tests_lock = threading.Lock()
     self.peers = peers
@@ skipping 178 matching lines @@
       total_work += p.assigned_work
     for p in self.peers:
       p.assigned_work /= total_work
       p.runtime /= total_runtime
       perf_correction = p.assigned_work / p.runtime
       old_perf = p.relative_performance
       p.relative_performance = (old_perf + perf_correction) / 2.0
       compression.Send([constants.UPDATE_PERF, p.address,
                         p.relative_performance],
                        self.local_socket)