diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-03-20 15:50:48 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-03-21 16:03:16 +0000 |
| commit | b1f2b34cc6e3bbab08b0055f7213a5cd662e470f (patch) | |
| tree | 05a2778880176828def3cc03f75037320c43e2b5 /src | |
| parent | 1ff2630eef3e7ddbc3841a888a05b24cd3c2aff9 (diff) | |
| download | rabbitmq-server-git-b1f2b34cc6e3bbab08b0055f7213a5cd662e470f.tar.gz | |
Disable test that cannot currently pass
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 9da3a6913c..450fd4679d 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -366,22 +366,22 @@ apply(Meta, {down, Pid, noconnection}, %% all pids for the disconnected node will be marked as suspected not just %% the one we got the `down' command for Node = node(Pid), - ConsumerUpdateActiveFun = consumer_active_flag_update_function(State0), {State, Effects1} = - maps:fold(fun({_, P} = Cid, #consumer{checked_out = Checked0, - status = up} = C0, - {St0, Eff}) when node(P) =:= Node -> - Credit = increase_credit(C0, map_size(Checked0)), - C = C0#consumer{status = suspected_down, - credit = Credit}, - {St, Eff0} = return_all(St0, Eff, Cid, C), - Eff1 = ConsumerUpdateActiveFun(St, Cid, C, false, - suspected_down, Eff0), - {St, Eff1}; - (_, _, {St, Eff}) -> - {St, Eff} - end, {State0, []}, Cons0), + maps:fold( + fun({_, P} = Cid, #consumer{checked_out = Checked0, + status = up} = C0, + {St0, Eff}) when node(P) =:= Node -> + Credit = increase_credit(C0, map_size(Checked0)), + C = C0#consumer{status = suspected_down, + credit = Credit}, + {St, Eff0} = return_all(St0, Eff, Cid, C), + Eff1 = consumer_update_active_effects(St, Cid, C, false, + suspected_down, Eff0), + {St, Eff1}; + (_, _, {St, Eff}) -> + {St, Eff} + end, {State0, []}, Cons0), Enqs = maps:map(fun(P, E) when node(P) =:= Node -> E#enqueuer{status = suspected_down}; (_, E) -> E |