Improved code

szhnet · Sep 27, 2021 · ac250d8 · ac250d8
1 parent ed6addc
commit ac250d8
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -9,7 +9,7 @@ To add a dependency using Maven:
 <dependency>
     <groupId>io.jpower.kcp</groupId>
     <artifactId>kcp-netty</artifactId>
-    <version>1.4.11</version>
+    <version>1.4.12</version>
 </dependency>
 ```
 

diff --git a/kcp-example/pom.xml b/kcp-example/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <groupId>io.jpower.kcp</groupId>
         <artifactId>kcp-parent</artifactId>
-        <version>1.4.11</version>
+        <version>1.4.12</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

diff --git a/kcp-netty/pom.xml b/kcp-netty/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <groupId>io.jpower.kcp</groupId>
         <artifactId>kcp-parent</artifactId>
-        <version>1.4.11</version>
+        <version>1.4.12</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

diff --git a/kcp-netty/src/main/java/io/jpower/kcp/netty/Kcp.java b/kcp-netty/src/main/java/io/jpower/kcp/netty/Kcp.java
@@ -331,6 +331,7 @@ private void release(List<Segment> segQueue) {
         for (Segment seg : segQueue) {
             seg.recycle(true);
         }
+        segQueue.clear();
     }
 
     private ByteBuf tryCreateOrOutput(ByteBuf buffer, int need) {

diff --git a/kcp-netty/src/main/java/io/jpower/kcp/netty/UkcpClientChannel.java b/kcp-netty/src/main/java/io/jpower/kcp/netty/UkcpClientChannel.java
@@ -222,6 +222,10 @@ public UkcpClientChannel conv(int conv) {
         return this;
     }
 
+    public boolean kcpIsActive() {
+        return ukcp.isActive();
+    }
+
     void kcpReceive(ByteBuf buf) throws IOException {
         ukcp.receive(buf);
     }

diff --git a/kcp-netty/src/main/java/io/jpower/kcp/netty/UkcpClientUdpChannel.java b/kcp-netty/src/main/java/io/jpower/kcp/netty/UkcpClientUdpChannel.java
@@ -295,7 +295,7 @@ public void read() {
                     exception1 = t;
                 }
 
-                if (exception1 == null) {
+                if (exception1 == null && ukcpChannel.kcpIsActive()) {
                     boolean mergeSegmentBuf = ukcpChannel.config().isMergeSegmentBuf();
                     CodecOutputList<ByteBuf> recvBufList = null;
                     boolean recv = false;

diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>io.jpower.kcp</groupId>
     <artifactId>kcp-parent</artifactId>
-    <version>1.4.11</version>
+    <version>1.4.12</version>
     <packaging>pom</packaging>
 
     <name>kcp-netty [Parent]</name>