Lines Matching refs:target

484                 target = get_node_with_most_keys_in_slot(nodes,slot)
485                 xputs ">>> Covering slot #{slot} moving keys to #{target}"
487                 target.r.cluster('addslots',slot)
488                 target.r.cluster('setslot',slot,'stable')
490                     next if src == target
494                     src.r.cluster('setslot',slot,'importing',target.info[:name])
495                     move_slot(src,target,slot,:dots=>true,:fix=>true,:cold=>true)
917     def move_slot(source,target,slot,o={})  argument
925             print "Moving slot #{slot} from #{source} to #{target}: "
930             target.r.cluster("setslot",slot,"importing",source.info[:name])
931             source.r.cluster("setslot",slot,"migrating",target.info[:name])
938 …  source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:keys,*keys])
942 …source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:replace,:keys…
958                 n.r.cluster("setslot",slot,"node",target.info[:name])
965             target.info[:slots][slot] = true
1168             target = get_node_by_name(opt['to'])
1169             if !target || target.has_flag?("slave")
1174             target = nil
1175             while not target
1177                 target = get_node_by_name(STDIN.gets.chop)
1178                 if !target || target.has_flag?("slave")
1180                     target = nil
1215                 elsif src.info[:name] == target.info[:name]
1232                 next if n.info[:name] == target.info[:name]
1239         if sources.index(target)
1248         puts "    #{target.info_string}"
1258             move_slot(e[:source],target,e[:slot],
1474                 target = slots[slot]
1475                 print "Migrating #{k} to #{target}: "
1478                     cmd = ["migrate",target.info[:host],target.info[:port],k,0,@timeout]