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:
aozhiwei 2023-04-23 17:52:27 +08:00
parent 3de96a8575
commit 97ce74378d
3 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/wsproxy/longsession.cc
View File

@ -3,7 +3,10 @@
#include "longsession.h" #include "longsession.h"
#include "kcpsession.h" #include "kcpsession.h"
void LongSession::Init() #include "ss_msgid.pb.h"
#include "ss_proto.pb.h"
void LongSession::Init(f8::MsgHdr& hdr, const ss::SS_CMKcpHandshake& msg)
{ {
} }

7
server/wsproxy/longsession.h
View File

@ -1,12 +1,17 @@
#pragma once #pragma once
namespace ss
{
class SS_CMKcpHandshake;
}
class KcpSession; class KcpSession;
class LongSession class LongSession
{ {
public: public:
void Init(); void Init(f8::MsgHdr& hdr, const ss::SS_CMKcpHandshake& msg);
void UnInit(); void UnInit();
void Update(long long tick); void Update(long long tick);

9
server/wsproxy/longsessionmgr.cc
View File

@ -10,6 +10,7 @@
#include "jsondatamgr.h" #include "jsondatamgr.h"
#include "longsession.h" #include "longsession.h"
#include "kcpsession.h" #include "kcpsession.h"
#include "GCListener.h"
#include "ss_msgid.pb.h" #include "ss_msgid.pb.h"
#include "ss_proto.pb.h" #include "ss_proto.pb.h"
@ -59,7 +60,15 @@ void LongSessionMgr::_SS_CMKcpHandshake(f8::MsgHdr& hdr, const ss::SS_CMKcpHands
return; return;
} }
auto session = std::make_shared<LongSession>(); auto session = std::make_shared<LongSession>();
session->Init(hdr, msg);
socket_handle_hash_[session->GetKcpSession()->GetSocketHandle()] = session;
respmsg.set_conv(session->GetKcpSession()->GetSocketHandle());
{
long long secret_key = session->GetKcpSession()->GetSecretKey();
respmsg.set_secret_key(&secret_key, sizeof(secret_key));
}
GCListener::Instance()->SendMsg(hdr.socket_handle, respmsg);
} }
std::shared_ptr<LongSession> LongSessionMgr::GetSession(int socket_handle) std::shared_ptr<LongSession> LongSessionMgr::GetSession(int socket_handle)