fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-03 00:01:04 +00:00
Code Issues Projects Releases Wiki Activity

redis-trib: fix for a slot allocation bug.

Browse Source
This commit is contained in:
antirez 2011-10-13 15:16:03 +02:00
parent 2b9ce0192e
commit dd9ad57062
1 changed files with 2 additions and 1 deletions

3
src/redis-trib.rb

@ -319,10 +319,11 @@ class RedisTrib
# divisibility. Like we have 3 nodes and need to get 10 slots, we take # divisibility. Like we have 3 nodes and need to get 10 slots, we take
# 4 from the first, and 3 from the rest. So the biggest is always the first. # 4 from the first, and 3 from the rest. So the biggest is always the first.
sources = sources.sort{|a,b| b.slots.length <=> a.slots.length} sources = sources.sort{|a,b| b.slots.length <=> a.slots.length}
source_tot_slots = sources.inject {|a,b| a.slots.length+b.slots.length}
sources.each_with_index{|s,i| sources.each_with_index{|s,i|
# Every node will provide a number of slots proportional to the # Every node will provide a number of slots proportional to the
# slots it has assigned. # slots it has assigned.
n = (numslots.to_f/4096*s.slots.length) n = (numslots.to_f/source_tot_slots*s.slots.length)
if i == 0 if i == 0
n = n.ceil n = n.ceil
else else