From a162cc99864635ab6a5ec34fae13b4b735210239 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=8F=B6=E8=90=BD=E5=AF=92=E5=A1=98?=
 <22316734+ylht@users.noreply.github.com>
Date: Sun, 21 Apr 2024 21:18:11 +0800
Subject: [PATCH] [fix] a peer may disconnect and then connect with a new
 session, then we should put the new session in the session table

---
 .../communication/client/netty/NettyTOMMessageDecoder.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/main/java/bftsmart/communication/client/netty/NettyTOMMessageDecoder.java b/src/main/java/bftsmart/communication/client/netty/NettyTOMMessageDecoder.java
index d60454dd6..9269474f7 100644
--- a/src/main/java/bftsmart/communication/client/netty/NettyTOMMessageDecoder.java
+++ b/src/main/java/bftsmart/communication/client/netty/NettyTOMMessageDecoder.java
@@ -154,9 +154,10 @@ protected void decode(ChannelHandlerContext context, ByteBuf buffer, List<Object
                 sm.signed = true;
             }
 
-            if (!isClient) {                
-                rl.readLock().lock();                
-                if (!sessionTable.containsKey(sm.getSender())) {
+            if (!isClient) {
+                rl.readLock().lock();
+                if (!sessionTable.containsKey(sm.getSender()) ||
+                        !sessionTable.get(sm.getSender()).getChannel().equals(context.channel())) {
                     rl.readLock().unlock();
               
                     NettyClientServerSession cs = new NettyClientServerSession(