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 <ylifshit@redhat.com>
(cherry picked from commit ca6688696b9ac9f838ffe21951331b6a1974dae8)

diff --git a/src/test/rgw/bucket_notification/test_bn.py b/src/test/rgw/bucket_notification/test_bn.py
index c10c413a2a7db5cf68b31c406d5c1f196e81da73..b73da03cd6cce39263da85a694f8e450e4ae0e7a 100644 (file)
--- 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()