diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-10-23 14:54:28 +0100 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2020-10-23 14:54:28 +0100 |
| commit | 27a16f3305d91c4e482ded963feecd35b64f6525 (patch) | |
| tree | 18f29d95d302291ebfd9dbc8c43244616efcd1a7 | |
| parent | 0d2556829e4d967846cd88f11822a7b8e4ecb22e (diff) | |
| download | rabbitmq-server-git-stream-parallel-tests.tar.gz | |
Use global locks to avoid parallel declares aborting the coordinator startupstream-parallel-tests
| -rw-r--r-- | src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_stream_coordinator.erl b/src/rabbit_stream_coordinator.erl index 8a1205b9af..9e4890c894 100644 --- a/src/rabbit_stream_coordinator.erl +++ b/src/rabbit_stream_coordinator.erl @@ -115,7 +115,9 @@ delete_replica(StreamId, Node) -> process_command({delete_replica, #{stream_id => StreamId, node => Node}}). process_command(Cmd) -> + global:set_lock(?STREAM_COORDINATOR_STARTUP), Servers = ensure_coordinator_started(), + global:del_lock(?STREAM_COORDINATOR_STARTUP), process_command(Servers, Cmd). process_command([], _Cmd) -> |