RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-19 08:57:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

rgw/test: allow for duplicate events in pubsub

Browse Source 
when tested via radosgw-admin.
also, add verification for the content of the events

Fixes: https://tracker.ceph.com/issues/49261

Signed-off-by: Yuval Lifshitz <ylifshit@redhat.com>
This commit is contained in:
Yuval Lifshitz 2021-02-14 17:19:17 +02:00
parent 6bcbd57c04
commit a695cf7e9d
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/test/rgw/rgw_multi/tests_ps.py
View File

@ -3053,17 +3053,19 @@ def test_ps_admin():
+ ps_zone.zone.zone_arg())
assert_equal(status, 0)
parsed_result = json.loads(result)
assert_equal(len(parsed_result['events']), 100)
marker = parsed_result['next_marker']
events1 = parsed_result['events']
result, status = ps_zone.zone.cluster.admin(['subscription', 'pull', '--uid', get_user(), '--subscription', bucket_name+SUB_SUFFIX, '--marker', marker]
+ ps_zone.zone.zone_arg())
assert_equal(status, 0)
parsed_result = json.loads(result)
assert_equal(len(parsed_result['events']), 10)
event_id = parsed_result['events'][0]['id']
events2 = parsed_result['events']
keys = list(bucket.list())
verify_events_by_elements({"events": events1+events2}, keys, exact_match=False)
# ack an event in the subscription
result, status = ps_zone.zone.cluster.admin(['subscription', 'ack', '--uid', get_user(), '--subscription', bucket_name+SUB_SUFFIX, '--event-id', event_id]
result, status = ps_zone.zone.cluster.admin(['subscription', 'ack', '--uid', get_user(), '--subscription', bucket_name+SUB_SUFFIX, '--event-id', events2[0]['id']]
+ ps_zone.zone.zone_arg())
assert_equal(status, 0)