diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-10-19 23:03:47 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-10-19 23:03:47 +0300 |
| commit | 87325b09f7d066a5b7bde1682e3be877a604871e (patch) | |
| tree | 79eebeef8d66ad93f80b28963f84511431caa799 | |
| parent | 7e2a6ff328984bcb2515e73254942c86d00f0870 (diff) | |
| download | rabbitmq-server-git-87325b09f7d066a5b7bde1682e3be877a604871e.tar.gz | |
Improve a comment
| -rw-r--r-- | deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl b/deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl index 48df5162cc..44d7dca3b2 100644 --- a/deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl +++ b/deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl @@ -227,7 +227,6 @@ remove_bindings(none, X, Bindings) -> ok. remove_binding(#binding{source = S, destination = D, key = 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]), @@ -237,7 +236,7 @@ remove_binding(#binding{source = S, destination = D, key = RK}) -> next_bucket_number = NexN0}] -> %% Buckets with lower numbers stay as is; buckets that %% belong to this binding are removed; buckets with - %% greater numbers are updated (their numbers are adjusted downwards by weight) + %% greater numbers are updated (their numbers are adjusted downwards) BucketsOfThisBinding = maps:filter(fun (_K, V) -> V =:= D end, BM0), case maps:size(BucketsOfThisBinding) of 0 -> ok; |