mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-11 07:10:25 -06:00
Code Issues Packages Projects Releases Wiki Activity

avoid the case that the packet sequence is field,eof,err (#2318)

Browse Source
This commit is contained in:
Collapsar
2020-11-25 09:57:50 +08:00
committed by GitHub
parent 5e88859950
commit 8ff7e86072
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java
View File

@@ -69,7 +69,12 @@ public class RWSplitHandler implements ResponseHandler, LoadDataResponseHandler,
synchronized (this) {
if (!write2Client) {
data[3] = (byte) rwSplitService.nextPacketId();
frontedConnection.write(data);
if (buffer != null) {
buffer = rwSplitService.writeToBuffer(data, buffer);
frontedConnection.write(buffer);
} else {
frontedConnection.write(data);
}
write2Client = true;
}
}

1
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitService.java
View File

@@ -269,6 +269,7 @@ public class RWSplitService extends BusinessService {
super.cleanup();
if (session != null) {
TsQueriesCounter.getInstance().addToHistory(this);
session.close("clean up");
}
}
}