Revert "[fix](SSL) Correctly close SSL connections (apache#38587)"

This reverts commit a03a1c2.
TangSiyang2001 · Aug 12, 2024 · 35f5e90 · 35f5e90
1 parent 9b9deb3
commit 35f5e90
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlChannel.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlChannel.java
@@ -314,7 +314,7 @@ public ByteBuffer fetchOnePacket() throws IOException {
             // before read, set limit to make read only one packet
             result.limit(result.position() + packetLen);
             readLen = readAll(result, false);
-            if (isSslMode && remainingBuffer.position() == 0 && result.hasRemaining()) {
+            if (isSslMode && remainingBuffer.position() == 0) {
                 byte[] header = result.array();
                 int packetId = header[3] & 0xFF;
                 if (packetId != sequenceId) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
@@ -344,11 +344,6 @@ public void processOnce() throws IOException {
                 LOG.warn("Null packet received from network. remote: {}", channel.getRemoteHostPortString());
                 throw new IOException("Error happened when receiving packet.");
             }
-            if (!packetBuf.hasRemaining()) {
-                LOG.info("No more data to be read. Close connection. remote={}", channel.getRemoteHostPortString());
-                ctx.setKilled();
-                return;
-            }
         } catch (AsynchronousCloseException e) {
             // when this happened, timeout checker close this channel
             // killed flag in ctx has been already set, just return