@@ -137,7 +137,7 @@ basics(Config) ->
137
137
{_ , _ } = rabbit_fifo_client :return (Ctag , [Mid ], FState7 ),
138
138
ok
139
139
end
140
- after 2000 ->
140
+ after 5000 ->
141
141
exit (await_msg_timeout )
142
142
end ,
143
143
rabbit_quorum_queue :stop_server (ServerId ),
@@ -172,7 +172,7 @@ rabbit_fifo_returns_correlation(Config) ->
172
172
Del ->
173
173
exit ({unexpected , Del })
174
174
end
175
- after 2000 ->
175
+ after 5000 ->
176
176
exit (await_msg_timeout )
177
177
end ,
178
178
rabbit_quorum_queue :stop_server (ServerId ),
@@ -205,7 +205,7 @@ duplicate_delivery(Config) ->
205
205
end
206
206
end
207
207
end
208
- after 2000 ->
208
+ after 5000 ->
209
209
exit (await_msg_timeout )
210
210
end
211
211
end ,
@@ -224,7 +224,7 @@ usage(Config) ->
224
224
{_ , _ , _ } = process_ra_events (receive_ra_events (2 , 2 ), F3 ),
225
225
% force tick and usage stats emission
226
226
ServerId ! tick_timeout ,
227
- timer :sleep (50 ),
227
+ timer :sleep (100 ),
228
228
Use = rabbit_fifo :usage (element (1 , ServerId )),
229
229
rabbit_quorum_queue :stop_server (ServerId ),
230
230
? assert (Use > 0.0 ),
@@ -306,7 +306,7 @@ returns_after_down(Config) ->
306
306
Self ! checkout_done
307
307
end ),
308
308
receive checkout_done -> ok after 1000 -> exit (checkout_done_timeout ) end ,
309
- timer :sleep (1000 ),
309
+ timer :sleep (2000 ),
310
310
% message should be available for dequeue
311
311
{ok , _ , {_ , _ , _ , _ , msg1 }, _ } = rabbit_fifo_client :dequeue (<<" tag" >>, settled , F2 ),
312
312
rabbit_quorum_queue :stop_server (ServerId ),
@@ -325,7 +325,7 @@ resends_after_lost_applied(Config) ->
325
325
receive
326
326
{ra_event , _ , {applied , _ }} ->
327
327
ok
328
- after 500 ->
328
+ after 2000 ->
329
329
exit (await_ra_event_timeout )
330
330
end ,
331
331
% send another message
@@ -354,7 +354,7 @@ handles_reject_notification(Config) ->
354
354
F0 = rabbit_fifo_client :init (ClusterName , [ServerId2 , ServerId1 ]),
355
355
{ok , F1 } = rabbit_fifo_client :enqueue (one , F0 ),
356
356
357
- timer :sleep (500 ),
357
+ timer :sleep (1000 ),
358
358
359
359
% the applied notification
360
360
_F2 = process_ra_events (receive_ra_events (1 , 0 ), F1 ),
@@ -391,7 +391,7 @@ discard(Config) ->
391
391
[msg1 ] = Letters ,
392
392
rejected = Reason ,
393
393
ok
394
- after 500 ->
394
+ after 1000 ->
395
395
flush (),
396
396
exit (dead_letter_timeout )
397
397
end ,
@@ -456,7 +456,7 @@ untracked_enqueue(Config) ->
456
456
ok = start_cluster (ClusterName , [ServerId ]),
457
457
458
458
ok = rabbit_fifo_client :untracked_enqueue ([ServerId ], msg1 ),
459
- timer :sleep (100 ),
459
+ timer :sleep (500 ),
460
460
F0 = rabbit_fifo_client :init (ClusterName , [ServerId ]),
461
461
{ok , _ , {_ , _ , _ , _ , msg1 }, _F5 } = rabbit_fifo_client :dequeue (<<" tag" >>, settled , F0 ),
462
462
rabbit_quorum_queue :stop_server (ServerId ),
@@ -578,7 +578,7 @@ receive_ra_events(Acc) ->
578
578
receive
579
579
{ra_event , _ , _ } = Evt ->
580
580
receive_ra_events ([Evt | Acc ])
581
- after 500 ->
581
+ after 1000 ->
582
582
Acc
583
583
end .
584
584
0 commit comments