diff options
| author | Michal Kuratczyk <mkuratczyk@vmware.com> | 2022-01-04 09:17:50 +0100 |
|---|---|---|
| committer | Michal Kuratczyk <mkuratczyk@vmware.com> | 2022-01-04 09:17:50 +0100 |
| commit | f88548fcc3a06f7a23abf1e5d35712b71521487f (patch) | |
| tree | 392fa8c389d495359d8bbf0d48af2afed66ae67a | |
| parent | 194032321a15e82b1b22317fb4ccb019f8aff765 (diff) | |
| download | rabbitmq-server-git-quorum-queues-v2-no-flow.tar.gz | |
Experiment: do not block/unblockquorum-queues-v2-no-flow
| -rw-r--r-- | deps/rabbit/src/rabbit_fifo_client.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_fifo_client.erl b/deps/rabbit/src/rabbit_fifo_client.erl index 3b084acbc5..e3fdb25948 100644 --- a/deps/rabbit/src/rabbit_fifo_client.erl +++ b/deps/rabbit/src/rabbit_fifo_client.erl @@ -186,7 +186,7 @@ enqueue(Correlation, Msg, Cmd = rabbit_fifo:make_enqueue(self(), Next, Msg), case send_command(Node, Correlation, Cmd, low, State1) of {slow, State} when not Slow -> - BlockFun(), + % BlockFun(), {slow, set_timer(State)}; Any -> Any @@ -585,7 +585,7 @@ handle_ra_event(From, {applied, Seqs}, S end end, State2, Commands), - UnblockFun(), + % UnblockFun(), {ok, State, Actions}; _ -> {ok, State1, Actions} |