test-rgw-call.sh: add missing file

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>

diff --git a/src/test/rgw/test-rgw-call.sh b/src/test/rgw/test-rgw-call.sh
new file mode 100755 (executable)
index 0000000..72ce106
--- /dev/null
+++ b/src/test/rgw/test-rgw-call.sh
@@ -0,0 +1,6 @@
+#!/bin/bash
+
+. "`dirname $0`/test-rgw-common.sh"
+. "`dirname $0`/test-rgw-meta-sync.sh"
+
+eval "$@"

diff --git a/src/test/rgw/test_multi.py b/src/test/rgw/test_multi.py
index d8edcfb2f1dd70ba96e09b470d474be95d287b22..e127fcf0071b6cafe24b6734e73713deab53e854 100644 (file)
--- a/src/test/rgw/test_multi.py
+++ b/src/test/rgw/test_multi.py
@@ -603,8 +603,46 @@ def test_object_sync():
             realm.zone_data_checkpoint(target_zone, source_zone)
 
             check_bucket_eq(source_zone, target_zone, bucket_name)
-            
 
+def test_object_delete():
+    buckets, zone_bucket = create_bucket_per_zone()
+
+    all_zones = []
+    for z in zone_bucket:
+        all_zones.append(z)
+
+    objname = 'myobj'
+    content = 'asdasd'
+
+    # don't wait for meta sync just yet
+    for zone, bucket_name in zone_bucket.iteritems():
+        k = new_key(zone, bucket_name, objname)
+        k.set_contents_from_string(content)
+
+    realm.meta_checkpoint()
+
+    # check object exists
+    for source_zone, bucket_name in zone_bucket.iteritems():
+        for target_zone in all_zones:
+            if source_zone.zone_name == target_zone.zone_name:
+                continue
+
+            realm.zone_data_checkpoint(target_zone, source_zone)
+
+            check_bucket_eq(source_zone, target_zone, bucket_name)
+
+    # check object removal
+    for source_zone, bucket_name in zone_bucket.iteritems():
+        k = get_key(source_zone, bucket_name, objname)
+        k.delete()
+        for target_zone in all_zones:
+            if source_zone.zone_name == target_zone.zone_name:
+                continue
+
+            realm.zone_data_checkpoint(target_zone, source_zone)
+
+            check_bucket_eq(source_zone, target_zone, bucket_name)
+        
 def init(parse_args):
     cfg = ConfigParser.RawConfigParser({
                                          'num_zones': 2,