From be2e56f58969153f1f639d91b5bb6530160f4165 Mon Sep 17 00:00:00 2001
From: azw <vcl_delphi@126.com>
Date: Sat, 15 Apr 2023 08:50:40 +0000
Subject: [PATCH] 1

---
 server/wsproxy/GCListener.cc | 3 +++
 server/wsproxy/GCListener.h  | 1 +
 2 files changed, 4 insertions(+)

diff --git a/server/wsproxy/GCListener.cc b/server/wsproxy/GCListener.cc
index 70b9a21..5a7975b 100644
--- a/server/wsproxy/GCListener.cc
+++ b/server/wsproxy/GCListener.cc
@@ -1,5 +1,7 @@
 #include "precompile.h"
 
+#include <mutex>
+
 #include <google/protobuf/message.h>
 #include <a8/websocketsession.h>
 #include <a8/tcplistener.h>
@@ -148,6 +150,7 @@ void GCListener::Init()
     tcp_listener_->bind_port = JsonDataMgr::Instance()->GetConf()->At("listen_port")->AsXValue();
     tcp_listener_->Open();
 
+    kcp_session_mutex_ = std::make_shared<std::mutex>();
     udp_listener_ = std::make_shared<a8::UdpListener>();
     udp_listener_->on_error = GSUdpListeneron_error;
     udp_listener_->on_recv_packet = GSUdpListeneron_recv_packet;
diff --git a/server/wsproxy/GCListener.h b/server/wsproxy/GCListener.h
index f2aa64b..fdd4254 100644
--- a/server/wsproxy/GCListener.h
+++ b/server/wsproxy/GCListener.h
@@ -39,5 +39,6 @@ class GCListener : public a8::Singleton<GCListener>
  private:
     a8::TcpListener *tcp_listener_ = nullptr;
     std::shared_ptr<a8::UdpListener> udp_listener_;
+    std::shared_ptr<std::mutex> kcp_session_mutex_;
     std::map<long long, std::shared_ptr<KcpSession>> kcp_session_hash_;
 };