From 204101c452f2503b47bf79873807f7b620d3ba91 Mon Sep 17 00:00:00 2001 From: Shilpa Jagannath Date: Thu, 11 Jul 2024 16:46:29 -0400 Subject: [PATCH] qa/multisite: add copy_object tests Signed-off-by: Shilpa Jagannath --- src/test/rgw/rgw_multi/tests.py | 70 +++++++++++++++++++++++++++++++++ 1 file changed, 70 insertions(+) diff --git a/src/test/rgw/rgw_multi/tests.py b/src/test/rgw/rgw_multi/tests.py index dd16cb45f9f5b..2d49c7a0ce01c 100644 --- a/src/test/rgw/rgw_multi/tests.py +++ b/src/test/rgw/rgw_multi/tests.py @@ -3565,3 +3565,73 @@ def test_account_metadata_sync(): check_users_eq(source_conn, target_conn) check_groups_eq(source_conn, target_conn) check_oidc_providers_eq(source_conn, target_conn) + + +@attr('copy_object') +def test_copy_object_same_bucket(): + zonegroup = realm.master_zonegroup() + zonegroup_conns = ZonegroupConns(zonegroup) + primary = zonegroup_conns.rw_zones[0] + secondary = zonegroup_conns.rw_zones[1] + + bucket = primary.create_bucket(gen_bucket_name()) + log.debug('created bucket=%s', bucket.name) + + objname = 'dummy' + + # upload a dummy object and wait for sync. + k = new_key(primary, bucket, objname) + k.set_contents_from_string('foo') + zonegroup_meta_checkpoint(zonegroup) + + zonegroup_data_checkpoint(zonegroup_conns) + log.debug('created object=%s', objname) + + zonegroup_bucket_checkpoint(zonegroup_conns, bucket.name) + + # copy object on primary zone + primary.s3_client.copy_object(Bucket=bucket.name, + CopySource=bucket.name + '/'+ objname, + Key= objname + '-copy1') + + zonegroup_bucket_checkpoint(zonegroup_conns, bucket.name) + + # copy object on secondary zone + secondary.s3_client.copy_object(Bucket=bucket.name, + Key= objname + '-copy2', + CopySource=bucket.name + '/'+ objname) + + zonegroup_bucket_checkpoint(zonegroup_conns, bucket.name) + +@attr('copy_object') +def test_copy_object_different_bucket(): + zonegroup = realm.master_zonegroup() + zonegroup_conns = ZonegroupConns(zonegroup) + primary = zonegroup_conns.rw_zones[0] + secondary = zonegroup_conns.rw_zones[1] + + source_bucket = primary.create_bucket(gen_bucket_name()) + log.debug('created bucket=%s', source_bucket.name) + + objname = 'dummy' + + # upload a dummy object and wait for sync. + k = new_key(primary, source_bucket, objname) + k.set_contents_from_string('foo') + zonegroup_meta_checkpoint(zonegroup) + + zonegroup_bucket_checkpoint(zonegroup_conns, source_bucket.name) + + # create destination bucket + dest_bucket = primary.create_bucket(gen_bucket_name()) + log.debug('created bucket=%s', dest_bucket.name) + + zonegroup_meta_checkpoint(zonegroup) + + # copy object on primary zone + primary.s3_client.copy_object(Bucket = dest_bucket.name, + Key = objname + '-copy', + CopySource = source_bucket.name + '/' + objname) + + zonegroup_bucket_checkpoint(zonegroup_conns, dest_bucket.name) + -- 2.39.5