diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2020-03-31 18:46:29 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-03-31 18:46:29 +0300 |
| commit | 1e9a5107579347549ef4e88a32826386869a3e65 (patch) | |
| tree | 7d91608df783058c89d2491ed0916107fe8a0e0b | |
| parent | 3da9ace1c8599d2bd4aacebcee757aa787ebf716 (diff) | |
| parent | 169fd53eac264c79913c08abfd7f9c08a9b9cb2f (diff) | |
| download | rabbitmq-server-git-1e9a5107579347549ef4e88a32826386869a3e65.tar.gz | |
Merge pull request #2292 from rabbitmq/rabbit_fifo_int_tweaks
Increase wait timeouts in rabbit_fifo_int
| -rw-r--r-- | test/rabbit_fifo_int_SUITE.erl | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/test/rabbit_fifo_int_SUITE.erl b/test/rabbit_fifo_int_SUITE.erl index e611b5e3a2..7d10ff9e8a 100644 --- a/test/rabbit_fifo_int_SUITE.erl +++ b/test/rabbit_fifo_int_SUITE.erl @@ -8,6 +8,8 @@ -include_lib("eunit/include/eunit.hrl"). -include_lib("rabbit_common/include/rabbit.hrl"). +-define(RA_EVENT_TIMEOUT, 1000). + all() -> [ {group, tests} @@ -92,7 +94,7 @@ basics(Config) -> {ok, FState2} = rabbit_fifo_client:enqueue(one, FState1), % process ra events - FState3 = process_ra_event(FState2, 250), + FState3 = process_ra_event(FState2, ?RA_EVENT_TIMEOUT), FState5 = receive {ra_event, From, Evt} -> @@ -109,7 +111,7 @@ basics(Config) -> end, % process settle applied notification - FState5b = process_ra_event(FState5, 250), + FState5b = process_ra_event(FState5, ?RA_EVENT_TIMEOUT), _ = ra:stop_server(ServerId), _ = ra:restart_server(ServerId), @@ -122,7 +124,7 @@ basics(Config) -> {ok, FState6} = rabbit_fifo_client:enqueue(two, FState5b), % process applied event - FState6b = process_ra_event(FState6, 250), + FState6b = process_ra_event(FState6, ?RA_EVENT_TIMEOUT), receive {ra_event, Frm, E} -> @@ -352,7 +354,7 @@ handles_reject_notification(Config) -> timer:sleep(500), % the applied notification - _F2 = process_ra_event(F1, 250), + _F2 = process_ra_event(F1, ?RA_EVENT_TIMEOUT), ra:stop_server(ServerId1), ra:stop_server(ServerId2), ok. |