diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-10-29 10:50:15 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-10-29 10:54:55 +0000 |
| commit | d82f002883fd9401f20a39cd3efaefd6e2587aa0 (patch) | |
| tree | b424aee5edbff75d893f277e5ee46cdcb65bc371 | |
| parent | 170e14f1343a234f33bf82adb28c58dc97db0f0a (diff) | |
| download | rabbitmq-server-git-d82f002883fd9401f20a39cd3efaefd6e2587aa0.tar.gz | |
rabbit_fifo: remove assertion
Removing assertion that the machine state contains no prefix messages
after recovery as this can happen when the WAL is running slowly on a
server and the leader commits entries by receining responses from
followers before it has a confirmation of it being locally written.
| -rw-r--r-- | src/rabbit_fifo.erl | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 12083b105c..ccacc136fb 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -567,10 +567,6 @@ state_enter(leader, #?MODULE{consumers = Cons, {Mod, Fun, Args} -> [{mod_call, Mod, Fun, Args ++ [Name]} | Effects] end; -state_enter(recovered, #?MODULE{prefix_msgs = PrefixMsgCounts}) - when PrefixMsgCounts =/= {[], []} -> - %% TODO: remove assertion? - exit({rabbit_fifo, unexpected_prefix_msgs, PrefixMsgCounts}); state_enter(eol, #?MODULE{enqueuers = Enqs, consumers = Custs0, waiting_consumers = WaitingConsumers0}) -> |