Lines Matching refs:nodes
127 nodes = @r.cluster("nodes").split("\n")
128 nodes.each{|n|
427 nodes = []
430 nodes << n if n.r.cluster("getkeysinslot",slot,1).length > 0
432 nodes
446 nodes = nodes_with_keys_in_slot(slot)
447 slots[slot] = nodes
448 xputs "Slot #{slot} has keys in #{nodes.length} nodes: #{nodes.join(", ")}"
460 none.each{|slot,nodes|
472 single.each{|slot,nodes|
473 xputs ">>> Covering slot #{slot} with #{nodes[0]}"
474 nodes[0].r.cluster("addslots",slot)
483 multi.each{|slot,nodes|
484 target = get_node_with_most_keys_in_slot(nodes,slot)
489 nodes.each{|src|
516 def get_node_with_most_keys_in_slot(nodes,slot) argument
684 ips.each do |ip,nodes|
685 if nodes.empty?
694 interleaved.push nodes.shift