Update checked in version of gsutil to version 4.6

third_party/boto/tests/integration/s3/test_connection.py

 # -*- coding: utf-8 -*-
 # Copyright (c) 2006-2011 Mitch Garnaat http://garnaat.org/
 #
 # Permission is hereby granted, free of charge, to any person obtaining a
 # copy of this software and associated documentation files (the
 # "Software"), to deal in the Software without restriction, including
 # without limitation the rights to use, copy, modify, merge, publish, dis-
 # tribute, sublicense, and/or sell copies of the Software, and to permit
 # persons to whom the Software is furnished to do so, subject to the fol-
 # lowing conditions:
 #
 # The above copyright notice and this permission notice shall be included
 # in all copies or substantial portions of the Software.
 #
 # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 # OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL-
 # ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT
-# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, 
+# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
 # WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
 # IN THE SOFTWARE.
 
 """
 Some unit tests for the S3Connection
 """
 
 import unittest
 import time
@@ skipping 160 matching lines @@
         except S3PermissionsError:
             pass
         # now try to create an RRS key
         k = bucket.new_key('reduced_redundancy')
         k.set_contents_from_string('This key has reduced redundancy',
                                    reduced_redundancy=True)
 
         # now try to inject a response header
         data = k.get_contents_as_string(response_headers={'response-content-type' : 'foo/bar'})
         assert k.content_type == 'foo/bar'
-        
+
         # now delete all keys in bucket
         for k in bucket:
             if k.name == 'reduced_redundancy':
                 assert k.storage_class == 'REDUCED_REDUNDANCY'
             bucket.delete_key(k)
         # now delete bucket
         time.sleep(5)
         c.delete_bucket(bucket)
         print '--- tests completed ---'
 
     def test_basic_anon(self):
         auth_con = S3Connection()
         # create a new, empty bucket
         bucket_name = 'test-%d' % int(time.time())
         auth_bucket = auth_con.create_bucket(bucket_name)
 
         # try read the bucket anonymously
         anon_con = S3Connection(anon=True)
         anon_bucket = Bucket(anon_con, bucket_name)
         try:
             iter(anon_bucket.list()).next()
             self.fail("anon bucket list should fail")
         except S3ResponseError:
             pass
 
         # give bucket anon user access and anon read again
         auth_bucket.set_acl('public-read')
+        time.sleep(5)
         try:
             iter(anon_bucket.list()).next()
             self.fail("not expecting contents")
         except S3ResponseError, e:
             self.fail("We should have public-read access, but received "
                       "an error: %s" % e)
         except StopIteration:
             pass
 
         # cleanup
         auth_con.delete_bucket(auth_bucket)
 
     def test_error_code_populated(self):
         c = S3Connection()
         try:
             c.create_bucket('bad$bucket$name')
         except S3ResponseError, e:
             self.assertEqual(e.error_code, 'InvalidBucketName')
         else:
             self.fail("S3ResponseError not raised.")