mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-01 20:10:23 -05:00
Code Issues Packages Projects Releases Wiki Activity

zk show @@binlog.status

Browse Source
This commit is contained in:
yanhuqing666
2017-05-25 17:54:47 +08:00
parent b771f10f91
commit a06f34a14b
17 changed files with 315 additions and 167 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/io/mycat/MycatServer.java
+6 -6
View File
@@ -662,12 +662,12 @@ public class MycatServer {
}
private boolean isUseZkSwitch()
{
MycatConfig mycatConfig=config;
boolean isUseZkSwitch= mycatConfig.getSystem().isUseZKSwitch();
String loadZk=ZkConfig.getInstance().getValue(ZkParamCfg.ZK_CFG_FLAG);
return (isUseZkSwitch&&"true".equalsIgnoreCase(loadZk)) ;
private boolean isUseZkSwitch() {
return isUseZK() && config.getSystem().isUseZKSwitch();
}
public boolean isUseZK() {
return Boolean.parseBoolean(ZkConfig.getInstance().getValue(ZkParamCfg.ZK_CFG_FLAG));
}
public TxnLogProcessor getTxnLogProcessor() {