mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2025-12-30 09:20:16 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner-2407-supplement ： upload metadata for switch

Browse Source
This commit is contained in:
dcy
2024-09-13 17:12:22 +08:00
committed by Rico
parent d6e46512b2
commit 61c7d47530
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -37,6 +37,7 @@ public final class DbGroupHaSwitch {
final ReentrantReadWriteLock lock = DbleServer.getInstance().getConfig().getLock();
lock.readLock().lock();
try {
ClusterHelper clusterHelper = ClusterHelper.getInstance(ClusterOperation.HA);
HaConfigManager.getInstance().info("added configLock");
PhysicalDbGroup dh = DbleServer.getInstance().getConfig().getDbGroups().get(dbGroupName);
if (dh == null) {
@@ -59,6 +60,11 @@ public final class DbGroupHaSwitch {
try {
//dble start in single mode
RawJson result = dh.switchMaster(masterName, true);
if (ClusterConfig.getInstance().isClusterEnable()) {
clusterHelper.setKV(ClusterMetaUtil.getHaStatusPath(dh.getGroupName()), result);
}
HaConfigManager.getInstance().haFinish(id, null, result);
} catch (Exception e) {
packetResult.setSuccess(false);