Skip to content

Commit 61c7d47

Browse files
committed
inner-2407-supplement : upload metadata for switch
1 parent d6e4651 commit 61c7d47

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

src/main/java/com/actiontech/dble/services/manager/response/ha/DbGroupHaSwitch.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ public static void execute(Matcher switcher, PacketResult packetResult) {
3737
final ReentrantReadWriteLock lock = DbleServer.getInstance().getConfig().getLock();
3838
lock.readLock().lock();
3939
try {
40+
ClusterHelper clusterHelper = ClusterHelper.getInstance(ClusterOperation.HA);
4041
HaConfigManager.getInstance().info("added configLock");
4142
PhysicalDbGroup dh = DbleServer.getInstance().getConfig().getDbGroups().get(dbGroupName);
4243
if (dh == null) {
@@ -59,6 +60,11 @@ public static void execute(Matcher switcher, PacketResult packetResult) {
5960
try {
6061
//dble start in single mode
6162
RawJson result = dh.switchMaster(masterName, true);
63+
64+
if (ClusterConfig.getInstance().isClusterEnable()) {
65+
clusterHelper.setKV(ClusterMetaUtil.getHaStatusPath(dh.getGroupName()), result);
66+
}
67+
6268
HaConfigManager.getInstance().haFinish(id, null, result);
6369
} catch (Exception e) {
6470
packetResult.setSuccess(false);

0 commit comments

Comments
 (0)