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

Generate an intermediate hash value for every non integer value to hash

This commit is contained in:
Diana Corbacho 2018-08-17 11:46:49 +01:00
parent cfb509ea8d
commit 59f5110e0d
1 changed files with 5 additions and 1 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

@ -249,8 +249,12 @@ jump_consistent_hash(KeyList, NumberOfBuckets) when is_list(KeyList) ->
jump_consistent_hash(hd(KeyList), NumberOfBuckets);
jump_consistent_hash(KeyBin, NumberOfBuckets) when is_binary(KeyBin) ->
Key = rabbit_data_coercion:to_integer(KeyBin),
jump_consistent_hash(Key, NumberOfBuckets);
jump_consistent_hash(Key, NumberOfBuckets) when is_integer(Key) ->
SeedState = rand:seed_s(exs1024s, {Key, Key, Key}),
jump_consistent_hash_value(-1, 0, NumberOfBuckets, SeedState).
jump_consistent_hash_value(-1, 0, NumberOfBuckets, SeedState);
jump_consistent_hash(Key, NumberOfBuckets) ->
jump_consistent_hash(erlang:phash2(Key), NumberOfBuckets).
jump_consistent_hash_value(B, J, NumberOfBuckets, _SeedState) when J >= NumberOfBuckets ->
B;