Add support for prebuilt uploading using rsync.

prebuilt_unittest.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.
 
 import mox
 import os
 import prebuilt
 import shutil
 import tempfile
@@ skipping 91 matching lines @@
       tmp = open(full_path, 'w')
       tmp.close()
 
   def _LoadPrivateMockFilters(self):
     """Load mock filters as defined in the setUp function."""
     dir_structure = [os.path.join(self.private_structure_base, entry)
                      for entry in self.private_pkgs]
 
     self._CreateNestedDir(self.private_dir, dir_structure)
     prebuilt.LoadPrivateFilters(self.tmp_dir)
- 
+
   def testFilterPattern(self):
     """Check that particular packages are filtered properly."""
     self._LoadPrivateMockFilters()
     packages = ['/some/dir/area/j-t-r-0.1.r3.tbz',
                 '/var/pkgs/new/alpha_beta-0.2.3.4.tbz',
                 '/usr/local/cache/good-0.1.3.tbz',
                 '/usr-blah/b_d/salt-flavor-0.0.3.tbz']
     expected_list = ['/usr/local/cache/good-0.1.3.tbz']
     filtered_list = [file for file in packages if not
                      prebuilt.ShouldFilterPackage(file)]
@@ skipping 34 matching lines @@
     """
     results = {}
     for entry in self.files_to_sync:
       results[entry] = os.path.join(
         gs_bucket_path, entry.replace(self.fake_path, '').lstrip('/'))
     return results
 
   def testGenerateUploadDict(self):
     gs_bucket_path = 'gs://chromeos-prebuilt/host/version'
     self.mox.StubOutWithMock(cros_build_lib, 'ListFiles')
-    cros_build_lib.ListFiles(' ').AndReturn(self.files_to_sync)
+    cros_build_lib.ListFiles(self.fake_path).AndReturn(self.files_to_sync)
     self.mox.ReplayAll()
-    result = prebuilt.GenerateUploadDict(' ', gs_bucket_path, self.fake_path)
+    result = prebuilt.GenerateUploadDict(self.fake_path, gs_bucket_path)
     self.assertEqual(result, self._generate_dict_results(gs_bucket_path))
 
   def testFailonUploadFail(self):
     """Make sure we fail if one of the upload processes fail."""
     files = {'test': '/uasd'}
     self.assertEqual(prebuilt.RemoteUpload(files), set([('test', '/uasd')]))
 
   def testDetermineMakeConf(self):
     """Test the different known variants of boards for proper path discovery."""
     targets = {'amd64': os.path.join(prebuilt._PREBUILT_MAKE_CONF['amd64']),
@@ skipping 42 matching lines @@
     temp_packages_file.flush()
     new_packages_file = prebuilt.FilterPackagesFile(temp_packages_file.name)
     new_contents = open(new_packages_file.name).read()
     self.assertEqual("".join(private_packages_file), new_contents)
     self.assertEqual("".join(private_packages_file), new_packages_file.read())
     new_packages_file.close()
 
 
 if __name__ == '__main__':
   unittest.main()