mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-12 17:39:21 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix npe when innerRelease and close are concurrent inner 1883 (#3471)

Browse Source
This commit is contained in:
ylinzhu
2022-11-15 10:03:44 +08:00
committed by lin
parent 3e22f8bda4
commit efc6a660ec
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/net/service/AbstractService.java
+1 -1
View File
@@ -167,7 +167,7 @@ public abstract class AbstractService extends VariablesService implements Servic
connection.getSocketWR().disableReadForever();
}
if (closeTask.isFirst() && !connection.isOnlyFrontTcpConnected()) {
LOGGER.info("prepare close for conn.conn id {},reason [{}]", connection.getId(), closeTask.getReasonsStr());
LOGGER.info("prepare close for conn {},reason [{}]", connection, closeTask.getReasonsStr());
}
break;
src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java
+4
View File
@@ -18,6 +18,7 @@ import com.actiontech.dble.net.handler.BackEndRecycleRunnable;
import com.actiontech.dble.net.mysql.*;
import com.actiontech.dble.net.response.*;
import com.actiontech.dble.net.service.ServiceTask;
import com.actiontech.dble.net.service.ServiceTaskType;
import com.actiontech.dble.net.service.WriteFlags;
import com.actiontech.dble.route.RouteResultsetNode;
import com.actiontech.dble.rwsplit.RWSplitNonBlockingSession;
@@ -516,6 +517,9 @@ public class MySQLResponseService extends BackendService {
@Override
protected void beforeInsertServiceTask(@NotNull ServiceTask task) {
super.beforeInsertServiceTask(task);
if (task.getType() == ServiceTaskType.CLOSE) {
return;
}
if (session != null) {
session.setBackendResponseTime(this);
}