From 552106db2b571ea0740dbfbcbf2d94853a2e3f6c Mon Sep 17 00:00:00 2001 From: Yuval Lifshitz Date: Tue, 20 Feb 2024 10:12:26 +0000 Subject: [PATCH] test/rgw/notifications: do not delay http responses to notifications we also increase the wating time after rerunning the http server to allow fo the persistent notifications retries to finish Fixes: https://tracker.ceph.com/issues/63909 Signed-off-by: Yuval Lifshitz (cherry picked from commit ca6688696b9ac9f838ffe21951331b6a1974dae8) --- src/test/rgw/bucket_notification/test_bn.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/test/rgw/bucket_notification/test_bn.py b/src/test/rgw/bucket_notification/test_bn.py index c10c413a2a7..b73da03cd6c 100644 --- a/src/test/rgw/bucket_notification/test_bn.py +++ b/src/test/rgw/bucket_notification/test_bn.py @@ -3152,7 +3152,7 @@ def test_ps_s3_persistent_topic_stats(): http_port = random.randint(10000, 20000) # start an http server in a separate thread - http_server = StreamingHTTPServer(host, http_port, num_workers=10, delay=0.5) + http_server = StreamingHTTPServer(host, http_port, num_workers=10) # create bucket bucket_name = gen_bucket_name() @@ -3227,10 +3227,10 @@ def test_ps_s3_persistent_topic_stats(): assert_equal(result[1], 0) # start an http server in a separate thread - http_server = StreamingHTTPServer(host, http_port, num_workers=10, delay=0.5) + http_server = StreamingHTTPServer(host, http_port, num_workers=10) - print('wait for '+str(delay)+'sec for the messages...') - time.sleep(delay) + print('wait for '+str(delay*2)+'sec for the messages...') + time.sleep(delay*2) # topic stats result = admin(['topic', 'stats', '--topic', topic_name], get_config_cluster()) @@ -3255,7 +3255,7 @@ def ps_s3_persistent_topic_configs(persistency_time, config_dict): http_port = random.randint(10000, 20000) # start an http server in a separate thread - http_server = StreamingHTTPServer(host, http_port, num_workers=10, delay=0.5) + http_server = StreamingHTTPServer(host, http_port, num_workers=10) # create bucket bucket_name = gen_bucket_name() -- 2.39.5