server_common/wsproxy
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-04-15 08:50:40 +00:00
parent 76eb32c357
commit be2e56f589
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/wsproxy/GCListener.cc
View File

@ -1,5 +1,7 @@
#include "precompile.h" #include "precompile.h"
#include <mutex>
#include <google/protobuf/message.h> #include <google/protobuf/message.h>
#include <a8/websocketsession.h> #include <a8/websocketsession.h>
#include <a8/tcplistener.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_->bind_port = JsonDataMgr::Instance()->GetConf()->At("listen_port")->AsXValue();
tcp_listener_->Open(); tcp_listener_->Open();
kcp_session_mutex_ = std::make_shared<std::mutex>();
udp_listener_ = std::make_shared<a8::UdpListener>(); udp_listener_ = std::make_shared<a8::UdpListener>();
udp_listener_->on_error = GSUdpListeneron_error; udp_listener_->on_error = GSUdpListeneron_error;
udp_listener_->on_recv_packet = GSUdpListeneron_recv_packet; udp_listener_->on_recv_packet = GSUdpListeneron_recv_packet;

1
server/wsproxy/GCListener.h
View File

@ -39,5 +39,6 @@ class GCListener : public a8::Singleton<GCListener>
private: private:
a8::TcpListener *tcp_listener_ = nullptr; a8::TcpListener *tcp_listener_ = nullptr;
std::shared_ptr<a8::UdpListener> udp_listener_; 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_; std::map<long long, std::shared_ptr<KcpSession>> kcp_session_hash_;
}; };