mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-03 19:30:14 -06:00
Code Issues Packages Projects Releases Wiki Activity

[inner-2377] Ensure the orderliness of stop/start operations of dbinstance

Browse Source
This commit is contained in:
wenyh1
2023-11-21 10:23:22 +08:00
parent 2852533237
commit 1f3de192ec
2 changed files with 29 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbGroup.java
View File

@@ -233,6 +233,8 @@ public class PhysicalDbGroup {
if (getBindingCount() != 0) {
state = STATE_DELETING;
IOProcessor.BACKENDS_OLD_GROUP.add(this);
long time = System.nanoTime();
allSourceMap.values().forEach(f -> f.setAsyncExecStopTime(time));
return false;
}
state = STATE_ABANDONED;
@@ -283,7 +285,7 @@ public class PhysicalDbGroup {
public boolean stopOfBackground(String reason) {
if (state.intValue() == STATE_DELETING && getBindingCount() == 0) {
for (PhysicalDbInstance dbInstance : allSourceMap.values()) {
dbInstance.stopDirectly(reason, false, false);
dbInstance.stopOfBackground(reason);
}
return true;
}

26
src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbInstance.java
View File

@@ -67,6 +67,8 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
private volatile boolean needSkipEvit = false;
private volatile boolean needSkipHeartTest = false;
private volatile int logCount;
private volatile long lastExecTime; // stop、start
private volatile long asyncExecStopTime;
public PhysicalDbInstance(DbInstanceConfig config, DbGroupConfig dbGroupConfig, boolean isReadNode) {
@@ -431,6 +433,7 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
}
void start(String reason, boolean isStartHeartbeat, boolean delayDetectionStart) {
lastExecTime = System.nanoTime();
startPool(reason);
if (isStartHeartbeat) {
startHeartbeat();
@@ -454,6 +457,7 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
if (dbGroup.getBindingCount() != 0) {
dbGroup.setState(PhysicalDbGroup.STATE_DELETING);
IOProcessor.BACKENDS_OLD_INSTANCE.add(this);
setAsyncExecStopTime(System.nanoTime());
return false;
}
if (dbGroup.isStop()) {
@@ -462,6 +466,7 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
if (dbGroup.getBindingCount() != 0) {
dbGroup.setState(PhysicalDbGroup.STATE_DELETING);
IOProcessor.BACKENDS_OLD_INSTANCE.add(this);
setAsyncExecStopTime(System.nanoTime());
return false;
}
return true;
@@ -469,6 +474,10 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
public boolean stopOfBackground(String reason) {
if (dbGroup.getState() == PhysicalDbGroup.STATE_DELETING && dbGroup.getBindingCount() == 0) {
if (asyncExecStopTime <= lastExecTime) { // In extreme cases (equal cases), in extreme cases there may be problems,
LOGGER.info("discard expired stop() operations");
return true;
}
stopDirectly(reason, false, false);
return true;
}
@@ -496,6 +505,7 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
}
protected void stop(String reason, boolean closeFront, boolean isStopHeartbeat, boolean isStopPool, boolean delayDetectionStop) {
lastExecTime = System.nanoTime();
if (isStopHeartbeat) {
stopHeartbeat(reason);
}
@@ -576,6 +586,22 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance {
return false;
}
public long getLastExecTime() {
return lastExecTime;
}
public void setLastExecTime(long lastExecTime) {
this.lastExecTime = lastExecTime;
}
public long getAsyncExecStopTime() {
return asyncExecStopTime;
}
public void setAsyncExecStopTime(long asyncExecStopTime) {
this.asyncExecStopTime = asyncExecStopTime;
}
public final int getActiveConnections() {
return connectionPool.getCount(PooledConnection.STATE_IN_USE);
}