root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fix binding deletion in duplicate-binding scenarios

This commit is contained in:
Falcon Taylor-Carter 2021-10-18 23:25:27 -04:00
parent 4dab02289d
commit 43b10615be
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl vendored
View File

@ -227,7 +227,7 @@ remove_bindings(none, X, Bindings) ->
ok.
remove_binding(#binding{source = S, destination = D, key = RK}) ->
Weight = rabbit_data_coercion:to_integer(RK),
_Weight = rabbit_data_coercion:to_integer(RK),
rabbit_log:debug("Consistent hashing exchange: removing binding "
"from exchange '~p' to destination '~p' with routing key '~s'",
[rabbit_misc:rs(S), rabbit_misc:rs(D), RK]),
@ -251,10 +251,10 @@ remove_binding(#binding{source = S, destination = D, key = RK}) ->
%% final state with "down the ring" buckets updated
NewBucketsDownTheRing = maps:fold(
fun(K0, V, Acc) ->
maps:put(K0 - Weight, V, Acc)
maps:put(K0 - N, V, Acc)
end, #{}, BucketsDownTheRing),
BM1 = maps:merge(UnchangedBuckets, NewBucketsDownTheRing),
NextN = NexN0 - Weight,
NextN = NexN0 - N,
State = State0#chx_hash_ring{bucket_map = BM1,
next_bucket_number = NextN},