Test runner: More fixes.

tools/testrunner/network/endpoint.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 42 matching lines @@
   def HasRun(self, test):
     # The runners that call this have a lock anyway, so this is safe.
     self.results_queue.append(test)
 
   def _SenderThread(self):
     keep_running = True
     tests = []
     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.)
       current = self.results_queue
       self.results_queue = []
       for c in current:
         if c is None:
           keep_running = False
         else:
           tests.append(c)
       if keep_running and len(tests) < 1:
         continue  # Wait for more results.
       if len(tests) < 1: break  # We're done here.
       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 = []
     self.sender_lock.release()
 
 
 def Execute(workspace, ctx, tests, sock, server):
   suite_paths = utils.GetSuitePaths(os.path.join(workspace, "test"))
   suites = []
   for root in suite_paths:
@@ skipping 18 matching lines @@
   progress_indicator = EndpointProgress(sock, server, ctx)
   runner = execution.Runner(suites, progress_indicator, ctx)
   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)
+    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()