From 68bfa944fe993b76f100f61959ede6f231ee91db Mon Sep 17 00:00:00 2001
From: Redkale <redkale@qq.com>
Date: Sat, 14 Jan 2023 13:17:37 +0800
Subject: [PATCH] =?UTF-8?q?ProtocolCodec=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/DispatcherServlet.java | 8 ++++----
 src/main/java/org/redkale/net/ProtocolCodec.java     | 6 +++---
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/java/org/redkale/net/DispatcherServlet.java b/src/main/java/org/redkale/net/DispatcherServlet.java
index 5a80aa7a2..25687e881 100644
--- a/src/main/java/org/redkale/net/DispatcherServlet.java
+++ b/src/main/java/org/redkale/net/DispatcherServlet.java
@@ -33,7 +33,7 @@ public abstract class DispatcherServlet<K extends Serializable, C extends Contex
 
     private final LongAdder executeCounter = new LongAdder(); //执行请求次数
 
-    private final LongAdder illRequestCounter = new LongAdder(); //错误请求次数
+    private final LongAdder illegalRequestCounter = new LongAdder(); //错误请求次数
 
     private final Object servletLock = new Object();
 
@@ -53,8 +53,8 @@ public abstract class DispatcherServlet<K extends Serializable, C extends Contex
         executeCounter.increment();
     }
 
-    protected void incrIllRequestCounter() {
-        illRequestCounter.increment();
+    protected void incrIllegalRequestCounter() {
+        illegalRequestCounter.increment();
     }
 
     protected void putServlet(S servlet) {
@@ -279,7 +279,7 @@ public abstract class DispatcherServlet<K extends Serializable, C extends Contex
     }
 
     public Long getIllRequestCounter() {
-        return illRequestCounter.longValue();
+        return illegalRequestCounter.longValue();
     }
 
 }
diff --git a/src/main/java/org/redkale/net/ProtocolCodec.java b/src/main/java/org/redkale/net/ProtocolCodec.java
index fecbee54a..b224b862d 100644
--- a/src/main/java/org/redkale/net/ProtocolCodec.java
+++ b/src/main/java/org/redkale/net/ProtocolCodec.java
@@ -12,7 +12,7 @@ import java.util.function.*;
 import java.util.logging.Level;
 
 /**
- * 一个AsyncConnection绑定一个ProtocolCodec实例
+ * 一个AsyncConnection绑定一个ProtocolCodec实例, 只会在读IOThread中运行
  *
  * @author zhangjx
  */
@@ -146,7 +146,7 @@ class ProtocolCodec implements CompletionHandler<Integer, ByteBuffer> {
             preparer.incrExecuteCounter();
             channel.offerReadBuffer(buffer);
             if (rs != Integer.MIN_VALUE) {
-                preparer.incrIllRequestCounter();
+                preparer.incrIllegalRequestCounter();
             }
             response.finish(true);
             if (context.logger.isLoggable(Level.FINEST)) {
@@ -197,7 +197,7 @@ class ProtocolCodec implements CompletionHandler<Integer, ByteBuffer> {
 
                 @Override
                 public void failed(Throwable exc, ByteBuffer attachment) {
-                    context.prepare.incrIllRequestCounter();
+                    context.prepare.incrIllegalRequestCounter();
                     channel.offerReadBuffer(attachment);
                     response.finish(true);
                     if (exc != null) {