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

[inner-1762] fix：no handler (cherry pick)

Browse Source
This commit is contained in:
wd2365151147
2022-07-01 15:55:17 +08:00
parent ea030e57f3
commit 0787195f7a
2 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnection.java
+6
View File
@@ -549,6 +549,12 @@ public class MySQLConnection extends AbstractConnection implements
this.recycler = recycler;
}
public void backendSpecialCleanUp() {
isExecuting = false;
isRowDataFlowing = false;
this.signal();
}
public void signal() {
if (recycler != null) {
recycler.signal();
src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnectionHandler.java
+4 -5
View File
@@ -227,12 +227,11 @@ public class MySQLConnectionHandler extends BackendAsyncHandler {
if (session != null && !source.isTesting() && this.source.getLogResponse().compareAndSet(false, true)) {
session.setBackendResponseEndTime(this.source);
}
this.source.setExecuting(false);
this.source.setRowDataFlowing(false);
this.source.getLogResponse().set(false);
this.source.signal();
if (responseHandler != null) {
responseHandler.rowEofResponse(data, false, source);
ResponseHandler respHand = responseHandler;
if (respHand != null) {
this.source.backendSpecialCleanUp();
respHand.rowEofResponse(data, false, source);
} else {
closeNoHandler();
}