diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-10-17 00:08:53 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-10-17 00:08:53 +0300 |
| commit | a8f96b41721189cb7e17aa75d9a448ca28574219 (patch) | |
| tree | 4acb910d6328992ffdcb3a7303abb0333fa0e352 /src | |
| parent | 1a83adbd230f2a4f00cf1c6e8e3d73cdb4470e07 (diff) | |
| download | rabbitmq-server-git-a8f96b41721189cb7e17aa75d9a448ca28574219.tar.gz | |
Update tests for rabbit_fifo:state_enter/2
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 5e3de3ba96..536d544e87 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -574,8 +574,9 @@ state_enter(eol, #?MODULE{enqueuers = Enqs, [{send_msg, P, eol, ra_event} || P <- maps:keys(maps:merge(Enqs, AllConsumers))] ++ [{mod_call, rabbit_quorum_queue, file_handle_release_reservation, []}]; -state_enter(_, #?MODULE{cfg = #cfg{resource = _Resource} }) -> - [{mod_call, rabbit_quorum_queue, file_handle_other_reservation, []}]; +state_enter(State, #?MODULE{cfg = #cfg{resource = _Resource}}) when State =/= leader -> + FHReservation = {mod_call, rabbit_quorum_queue, file_handle_other_reservation, []}, + [FHReservation]; state_enter(_, _) -> %% catch all as not handling all states []. |