From 2d3eb3aaf6645900a36c8bf35aab479379bd71af Mon Sep 17 00:00:00 2001
From: ylinzhu <46126022+ylinzhu@users.noreply.github.com>
Date: Mon, 21 Nov 2022 17:38:07 +0800
Subject: [PATCH] optimize channel log inner 1895 (#3485)

fix

fix level

fix level
---
 .../com/actiontech/dble/net/impl/nio/NIOSocketWR.java  | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/net/impl/nio/NIOSocketWR.java b/src/main/java/com/actiontech/dble/net/impl/nio/NIOSocketWR.java
index 19795d6f2..35ed1adab 100644
--- a/src/main/java/com/actiontech/dble/net/impl/nio/NIOSocketWR.java
+++ b/src/main/java/com/actiontech/dble/net/impl/nio/NIOSocketWR.java
@@ -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));