From ff82fd65320df6b85da122d7fb28455d8cd3e990 Mon Sep 17 00:00:00 2001 From: hbzheng8 <95574906+hbzheng8@users.noreply.github.com> Date: Thu, 29 Aug 2024 12:47:50 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9B=B4=E6=8E=A5close=20socket=EF=BC=8C?= =?UTF-8?q?=E8=A7=A3=E5=86=B3TLS=20half-close=20policy=E6=8A=A5=E9=94=99?= =?UTF-8?q?=E9=97=AE=E9=A2=98=20(#5240)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../parse/driver/mysql/socket/BioSocketChannel.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java index a36e7f3c..1bdb876f 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java +++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java @@ -167,16 +167,6 @@ public class BioSocketChannel implements SocketChannel { public void close() { Socket socket = this.socket; if (socket != null) { - try { - socket.shutdownInput(); - } catch (IOException e) { - // Ignore, could not do anymore - } - try { - socket.shutdownOutput(); - } catch (IOException e) { - // Ignore, could not do anymore - } try { socket.close(); } catch (IOException e) {