Add test for sync_object.
This commit is contained in:
parent
5fef6fc0b8
commit
14bdfd42f3
@ -93,6 +93,3 @@ def sync_object(orig_storage_url, orig_token, dest_storage_url,
|
|||||||
swiftclient.put_object(sync_to, name=object_name,
|
swiftclient.put_object(sync_to, name=object_name,
|
||||||
headers=post_headers,
|
headers=post_headers,
|
||||||
contents=_Iter2FileLikeObject(orig_body))
|
contents=_Iter2FileLikeObject(orig_body))
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
pass
|
|
||||||
|
@ -73,6 +73,24 @@ class TestObject(test_base.TestCase):
|
|||||||
swobjects.get_object,
|
swobjects.get_object,
|
||||||
self.orig_storage_url, "token", "cont1", "obj1")
|
self.orig_storage_url, "token", "cont1", "obj1")
|
||||||
|
|
||||||
|
def test_sync_object(self):
|
||||||
|
body = ("X" * 3) * 1024
|
||||||
|
new_connect = fake_http_connect(200, body)
|
||||||
|
self.stubs.Set(swobjects, 'http_connect_raw', new_connect)
|
||||||
|
|
||||||
|
def put_object(url, name=None, headers=None, contents=None):
|
||||||
|
self.assertEqual('obj1', name)
|
||||||
|
self.assertIn('x-auth-token', headers)
|
||||||
|
self.assertIsInstance(contents, swobjects._Iter2FileLikeObject)
|
||||||
|
contents_read = contents.read()
|
||||||
|
self.assertEqual(len(contents_read), len(body))
|
||||||
|
|
||||||
|
self.stubs.Set(swobjects.swiftclient, 'put_object', put_object)
|
||||||
|
|
||||||
|
swobjects.sync_object(self.orig_storage_url,
|
||||||
|
"token", self.dest_storage_url, "token",
|
||||||
|
"cont1", ("etag", "obj1"))
|
||||||
|
|
||||||
def test_get_object_chunked(self):
|
def test_get_object_chunked(self):
|
||||||
chunk_size = 32
|
chunk_size = 32
|
||||||
expected_chunk_time = 3
|
expected_chunk_time = 3
|
||||||
|
Loading…
Reference in New Issue
Block a user