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

Merge pull request #3839 from actiontech/inner-2371

Browse Source 
[inner-2371] fix: sql execution hang problem caused by the inability to respond to the front side due to unprocessed packets.
This commit is contained in:
wenyh
2023-11-13 13:48:24 +08:00
committed by GitHub
parent c0dd7dae9e e4675a8ea0
commit 1bc1d5d9ed
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/actiontech/dble/services/BackendService.java
View File

@@ -131,7 +131,7 @@ public abstract class BackendService extends AbstractService {
handleDataError(e);
} finally {
isHandling.set(false);
if (taskQueue.size() > 0) {
if (!taskQueue.isEmpty()) {
doHandle(task);
}
}
@@ -232,7 +232,7 @@ public abstract class BackendService extends AbstractService {
protected void handleDataError(Exception e) {
LOGGER.warn(this.toString() + " handle data error:", e);
connection.close("handle data error:" + e.getMessage());
while (taskQueue.size() > 0) {
while (!taskQueue.isEmpty()) {
clearTaskQueue();
readSize.set(0);
// clear all data from the client
@@ -697,8 +697,8 @@ public abstract class BackendService extends AbstractService {
handleDataError(e);
} finally {
isHandling.set(false);
if (taskQueue.size() > 0) {
doHandle(null);
if (!taskQueue.isEmpty()) {
doHandle(taskQueue.peek());
}
}
}