Rollback trunk to bleeding_edge revision 12524

tools/testrunner/network/endpoint.py

Index: tools/testrunner/network/endpoint.py
diff --git a/tools/testrunner/network/endpoint.py b/tools/testrunner/network/endpoint.py
index 25547c2f15e7f0c87a719bf0a61c80d3347c838e..5dc2b9f902450aab5ae996093511ff97ba76694f 100644
--- a/tools/testrunner/network/endpoint.py
+++ b/tools/testrunner/network/endpoint.py
@@ -60,7 +60,6 @@ class EndpointProgress(progress.ProgressIndicator):
     self.sender_lock.acquire()
     while keep_running:
       time.sleep(0.1)
-      t1 = time.time()
       # This should be "atomic enough" without locking :-)
       # (We don't care which list any new elements get appended to, as long
       # as we don't lose any and the last one comes last.)
@@ -77,7 +76,10 @@ class EndpointProgress(progress.ProgressIndicator):
       result = []
       for t in tests:
         result.append(t.PackResult())
-      compression.Send(result, self.sock)
+      try:
+        compression.Send(result, self.sock)
+      except:
+        self.runner.terminate = True
       for t in tests:
         self.server.CompareOwnPerf(t, self.context.arch, self.context.mode)
       tests = []
@@ -108,7 +110,15 @@ def Execute(workspace, ctx, tests, sock, server):
 
   progress_indicator = EndpointProgress(sock, server, ctx)
   runner = execution.Runner(suites, progress_indicator, ctx)
-  runner.Run(server.jobs)
+  try:
+    runner.Run(server.jobs)
+  except IOError, e:
+    if e.errno == 2:
+      message = ("File not found: %s, maybe you forgot to 'git add' it?" %
+                 e.filename)
+    else:
+      message = "%s" % e
+    compression.Send([[-1, message]], sock)
   progress_indicator.HasRun(None)  # Sentinel to signal the end.
   progress_indicator.sender_lock.acquire()  # Released when sending is done.
   progress_indicator.sender_lock.release()