From dccc95abb8e33fa403e12102a340e3555c164a23 Mon Sep 17 00:00:00 2001
From: Siyang Tang <tangsiyang2001@foxmail.com>
Date: Wed, 14 Aug 2024 14:52:13 +0800
Subject: [PATCH] debug

---
 .../src/main/java/org/apache/doris/mysql/MysqlChannel.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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
index 392b0587585ed5..108d1df4f4e623 100644
--- 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
@@ -131,6 +131,7 @@ public void initSslBuffer() {
 
     public void setSequenceId(int sequenceId) {
         this.sequenceId = sequenceId;
+        LOG.info("set seq id to 0");
     }
 
     public String getRemoteIp() {
@@ -172,7 +173,9 @@ private int packetLen(boolean isSslHeader) {
 
     private void accSequenceId() {
         sequenceId++;
+        LOG.info("add seq id to {}", sequenceId);
         if (sequenceId > 255) {
+            LOG.info("reset sequence id");
             sequenceId = 0;
         }
     }
@@ -318,7 +321,7 @@ public ByteBuffer fetchOnePacket() throws IOException {
                 byte[] header = result.array();
                 int packetId = header[3] & 0xFF;
                 if (packetId != sequenceId) {
-                    LOG.warn("receive packet sequence id[" + packetId() + "] want to get[" + sequenceId + "]");
+                    LOG.warn("receive packet sequence id[" + packetId + "] want to get[" + sequenceId + "]");
                     throw new IOException("Bad packet sequence.");
                 }
                 int mysqlPacketLength = (header[0] & 0xFF) | ((header[1] & 0XFF) << 8) | ((header[2] & 0XFF) << 16);