mirror of
https://github.com/fluencelabs/redis
synced 2025-04-02 15:51:05 +00:00
redis-trib: log event after we have reference to 'master'.
This commit is contained in:
parent
bf670e0745
commit
59e03a8f35
@ -116,6 +116,7 @@ class ClusterNode
|
|||||||
def load_info(o={})
|
def load_info(o={})
|
||||||
self.connect
|
self.connect
|
||||||
nodes = @r.cluster("nodes").split("\n")
|
nodes = @r.cluster("nodes").split("\n")
|
||||||
|
puts @r.cluster("nodes")
|
||||||
nodes.each{|n|
|
nodes.each{|n|
|
||||||
# name addr flags role ping_sent ping_recv link_status slots
|
# name addr flags role ping_sent ping_recv link_status slots
|
||||||
split = n.split
|
split = n.split
|
||||||
@ -900,8 +901,8 @@ class RedisTrib
|
|||||||
next if n == node
|
next if n == node
|
||||||
if n.info[:replicate] && n.info[:replicate].downcase == id
|
if n.info[:replicate] && n.info[:replicate].downcase == id
|
||||||
# Reconfigure the slave to replicate with some other node
|
# Reconfigure the slave to replicate with some other node
|
||||||
xputs ">>> #{n} as replica of #{master}"
|
|
||||||
master = get_master_with_least_replicas
|
master = get_master_with_least_replicas
|
||||||
|
xputs ">>> #{n} as replica of #{master}"
|
||||||
n.r.cluster("replicate",master.info[:name])
|
n.r.cluster("replicate",master.info[:name])
|
||||||
end
|
end
|
||||||
n.r.cluster("forget",argv[1])
|
n.r.cluster("forget",argv[1])
|
||||||
|
Loading…
x
Reference in New Issue
Block a user