From 2ccd8ebc73039985ccd0e6673d9291f7607530a8 Mon Sep 17 00:00:00 2001
From: yanghao <yanghao@webull.com>
Date: Thu, 8 Aug 2024 20:09:00 +0800
Subject: [PATCH] adding session in the session list of acceptor when created

---
 acceptor.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/acceptor.go b/acceptor.go
index a5c86ee0d..047b3c72e 100644
--- a/acceptor.go
+++ b/acceptor.go
@@ -335,13 +335,13 @@ func (a *Acceptor) handleConnection(netConn net.Conn) {
 			a.globalLog.OnEventf("Session %v not found for incoming message: %s", sessID, msgBytes)
 			return
 		}
-		dynamicSession, err := a.sessionFactory.createSession(sessID, a.storeFactory, a.settings.globalSettings.clone(), a.logFactory, a.app)
+		a.sessions[sessID], err = a.sessionFactory.createSession(sessID, a.storeFactory, a.settings.globalSettings.clone(), a.logFactory, a.app)
 		if err != nil {
 			a.globalLog.OnEventf("Dynamic session %v failed to create: %v", sessID, err)
 			return
 		}
-		a.dynamicSessionChan <- dynamicSession
-		session = dynamicSession
+		a.dynamicSessionChan <- a.sessions[sessID]
+		session = a.sessions[sessID]
 	}
 
 	a.sessionAddr.Store(sessID, netConn.RemoteAddr())