RGW/test_multi: add a helper function to get data sync oldest incremental change

Signed-off-by: Oguzhan Ozmen <oozmen@bloomberg.net>

diff --git a/src/test/rgw/rgw_multi/tests.py b/src/test/rgw/rgw_multi/tests.py
index e364b45f8f6a2281f524d20783126f7d63cd9e4c..d1ceddba4eab61287d9e830dc70c8ed4c44c8281 100644 (file)
--- a/src/test/rgw/rgw_multi/tests.py
+++ b/src/test/rgw/rgw_multi/tests.py
@@ -1,5 +1,6 @@
 import json
 import random
+import re
 import string
 import time
 import logging
@@ -425,6 +426,16 @@ def zonegroup_bucket_checkpoint(zonegroup_conns, bucket_name):
         if target_conn.zone.has_buckets():
             target_conn.check_bucket_eq(source_conn, bucket_name)
 
+def get_oldest_incremental_change_not_applied_epoch(zone):
+    cmd = ['sync', 'status']
+    sync_status_output, retcode = zone.cluster.admin(cmd, check_retcode=False, read_only=True)
+    assert(retcode == 0)
+    match = re.search(r"oldest incremental change not applied:\s*([0-9T:\.\+\-Z]+)", sync_status_output)
+    timestamp = match.group(1) if match else None
+    if timestamp is not None:
+        timestamp = datetime.strptime(timestamp, "%Y-%m-%dT%H:%M:%S.%f%z").timestamp()
+    return timestamp
+
 def set_master_zone(zone):
     zone.modify(zone.cluster, ['--master'])
     zonegroup = zone.zonegroup