|
|
@ -269,13 +269,13 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
|
|
|
|
String masterHost = map.get("master-host");
|
|
|
|
String masterHost = map.get("master-host");
|
|
|
|
String masterPort = map.get("master-port");
|
|
|
|
String masterPort = map.get("master-port");
|
|
|
|
|
|
|
|
|
|
|
|
if (!isUseSameMaster(ip, port, masterHost, masterPort)) {
|
|
|
|
|
|
|
|
continue;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
if (flags.contains("s_down") || flags.contains("disconnected")) {
|
|
|
|
if (flags.contains("s_down") || flags.contains("disconnected")) {
|
|
|
|
slaveDown(ip, port);
|
|
|
|
slaveDown(ip, port);
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!isUseSameMaster(ip, port, masterHost, masterPort)) {
|
|
|
|
|
|
|
|
continue;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
String slaveAddr = createAddress(ip, port);
|
|
|
|
String slaveAddr = createAddress(ip, port);
|
|
|
|
currentSlaves.add(slaveAddr);
|
|
|
|
currentSlaves.add(slaveAddr);
|
|
|
|