diff options
| author | kjnilsson <knilsson@pivotal.io> | 2018-12-05 11:35:39 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2018-12-05 11:35:39 +0000 |
| commit | e0ad5b09f8aae9c84822018716d0ef32bd9cccce (patch) | |
| tree | 4b0da5154d0716cb59a3f686fe9877885d31be93 | |
| parent | 105204861abfd270b4ba8c1b6e5878e00c6049f5 (diff) | |
| download | rabbitmq-server-git-e0ad5b09f8aae9c84822018716d0ef32bd9cccce.tar.gz | |
Fix test to account for new event
| -rw-r--r-- | test/rabbit_fifo_SUITE.erl | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/test/rabbit_fifo_SUITE.erl b/test/rabbit_fifo_SUITE.erl index a2e22afc2e..56608e9af3 100644 --- a/test/rabbit_fifo_SUITE.erl +++ b/test/rabbit_fifo_SUITE.erl @@ -99,8 +99,13 @@ basics(Config) -> _ = ra:stop_server(ServerId), _ = ra:restart_server(ServerId), - % give time to become leader - timer:sleep(500), + %% wait for leader change to notice server is up again + receive + {ra_event, _, {machine, leader_change}} -> ok + after 5000 -> + exit(leader_change_timeout) + end, + {ok, FState6} = rabbit_fifo_client:enqueue(two, FState5b), % process applied event FState6b = process_ra_event(FState6, 250), @@ -523,8 +528,9 @@ conf(ClusterName, UId, ServerId, _, Peers) -> process_ra_event(State, Wait) -> receive {ra_event, From, Evt} -> - % ct:pal("processed ra event ~p~n", [Evt]), - {internal, _, _, S} = rabbit_fifo_client:handle_ra_event(From, Evt, State), + ct:pal("processed ra event ~p~n", [Evt]), + {internal, _, _, S} = + rabbit_fifo_client:handle_ra_event(From, Evt, State), S after Wait -> exit(ra_event_timeout) |