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-19 03:30:19 +00:00
parent d5f5b10714
commit 50f66d54be
5 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.gitmodules vendored
View File

@ -13,3 +13,6 @@
[submodule "third_party/f8"]
path = third_party/f8
url = git@git.kingsome.cn:server_common/f8.git
[submodule "third_party/kcp"]
path = third_party/kcp
url = git@git.kingsome.cn:libs/kcp.git

2
server/wsproxy/GCListener.cc
View File

@ -245,6 +245,7 @@ private:
if (buflen - offset < sizeof(f8::PackHead) + p->packlen) {
break;
}
//a8::XPrintf("Recv MsgId:%d\n", {p->msgid});
App::Instance()->AddSocketMsg(SF_Client,
socket_handle_,
0,
@ -380,6 +381,7 @@ void GCListener::ProcUdpPacket(a8::UdpPacket* pkt)
auto session = GetKcpSessionByRemoteKey(key);
if (!session) {
++kcp_socket_handle_;
kcp_socket_handle_ = 123;
session = std::make_shared<KcpSession>();
session->Init(udp_listener_.get(), kcp_socket_handle_, pkt);
kcp_session_addr_hash_[key] = session;

3
server/wsproxy/upstream.cc
View File

@ -21,6 +21,9 @@ void UpStream::Init(int instance_id, const std::string& remote_ip, int remote_po
if (remote_ip.empty()) {
abort();
}
#if 0
remote_port = 7611;
#endif
this->instance_id = instance_id;
this->remote_ip = remote_ip;
this->remote_port = remote_port;

2
third_party/a8 vendored

@ -1 +1 @@
Subproject commit 03489644bf6b114254b879d948e66fd53b4f99a5
Subproject commit ac34ca2d3b49af61a38ee8d6d67617fc344c1eaa

1
third_party/kcp vendored Submodule

@ -0,0 +1 @@
Subproject commit 10ee2b30c8739408c0db98211df4ebce7b01c0ed