Add ability for cbuildbot master to synchronize with cbuildbot slaves.

bin/cbuildbot.py

 #!/usr/bin/python
 
 # 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.
 
 """CBuildbot is wrapper around the build process used by the pre-flight queue"""
 
 import errno
+import re
 import optparse
 import os
-import re
-import shutil
 import subprocess
 import sys
 
+import cbuildbot_comm
 from cbuildbot_config import config
 
 _DEFAULT_RETRIES = 3
 
 # ======================== Utility functions ================================
 
 def RunCommand(cmd, print_cmd=True, error_ok=False, error_message=None,
                exit_code=False, redirect_stdout=False, redirect_stderr=False,
                cwd=None, input=None, enter_chroot=False):
   """Runs a shell command.
@@ skipping 337 matching lines @@
     chroot_path = os.path.join(buildroot, 'chroot')
     if not os.path.isdir(chroot_path):
       _MakeChroot(buildroot)
     boardpath = os.path.join(chroot_path, 'build', buildconfig['board'])
     if not os.path.isdir(boardpath):
       _SetupBoard(buildroot, board=buildconfig['board'])
     if buildconfig['uprev']:
       _UprevPackages(buildroot, revisionfile, board=buildconfig['board'])
     _Build(buildroot)
     if buildconfig['uprev']:
-      _UprevPush(buildroot)
-      _UprevCleanup(buildroot)
+      if buildconfig['master']:
+        # Master bot needs to check if the other slaves completed.
+        if cbuildbot_comm.HaveSlavesCompleted(config):
+          _UprevPush(buildroot)
+          _UprevCleanup(buildroot)
+        else:
+          # At least one of the slaves failed or we timed out.
+          _UprevCleanup(buildroot)
+          sys.stderr('CBUILDBOT - One of the slaves has failed!!!')
+          sys.exit(1)
+      else:
+        # Publish my status to the master.
+        cbuildbot_comm.PublishStatus(cbuildbot_comm.STATUS_BUILD_COMPLETE)
+        _UprevCleanup(buildroot)
   except:
-    # something went wrong, cleanup (being paranoid) for next build
+    # Something went wrong, cleanup (being paranoid) for next build.
     if clobber:
       RunCommand(['sudo', 'rm', '-rf', buildroot], print_cmd=False)
+    # Send failure to master bot.
+    if not buildconfig['master']:
+      cbuildbot_comm.PublishStatus(cbuildbot_comm.STATUS_BUILD_FAILED)
     raise
 
 
 if __name__ == '__main__':
     main()