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

Merge branch 'master' into fix/1997&1995

Browse Source
This commit is contained in:
LUA
2022-11-22 10:34:37 +08:00
committed by GitHub
parent 8a0cf8837a 2d3eb3aaf6
commit b079d9005e
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/actiontech/dble/net/impl/nio/NIOSocketWR.java
View File

@@ -81,7 +81,8 @@ public class NIOSocketWR extends SocketWR {
//when write errored,the flow control doesn't work
clearWriteQueue();
con.getWritingSize().set(0);
if (Objects.equals(e.getMessage(), "Broken pipe") || Objects.equals(e.getMessage(), "Connection reset by peer") || e instanceof ClosedChannelException) {
if (Objects.equals(e.getMessage(), "Broken pipe") || Objects.equals(e.getMessage(), "Connection reset by peer") ||
e instanceof ClosedChannelException) {
// target problem,
//ignore this exception,will close by read side.
LOGGER.warn("Connection was closed while write. Detail reason:{}. {}.", e.toString(), con.getService());
@@ -93,7 +94,12 @@ public class NIOSocketWR extends SocketWR {
} catch (Exception e) {
writeDataErr = true;
LOGGER.info("con {} write err:", con.getService(), e);
//connection was closed,nio channel may be closed
if (con.isClosed()) {
LOGGER.info("connection was closed while write, con is {}, reason is {}", con.getService(), e);
} else {
LOGGER.warn("con {} write err:", con.getService(), e);
}
clearWriteQueue();
con.getWritingSize().set(0);
con.pushServiceTask(ServiceTaskFactory.getInstance(con.getService()).createForForceClose(e.getMessage(), CloseType.WRITE));