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-25 06:06:51 +00:00
parent adfa92a169
commit d7ea1075ab
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/wsproxy/downstream.cc
View File

@ -58,14 +58,16 @@ void DownStream::OnClose()
void DownStream::ProcCMMsg(f8::MsgHdr& hdr, int tag) void DownStream::ProcCMMsg(f8::MsgHdr& hdr, int tag)
{ {
if (hdr.msgid == ss::_SS_CMPing) { if (hdr.msgid == ss::_SS_CMPing) {
ss::SS_Ping msg; ss::SS_SMPing msg;
if (IsLongSession() && tag == ST_Tcp) { if (IsLongSession() && tag == ST_Tcp) {
GCListener::Instance()->SendMsgEx(socket_handle_, ss::_SS_CMPing, msg); GCListener::Instance()->SendMsgEx(socket_handle_, ss::_SS_CMPing, msg);
if (!long_session_wp_.expired()) { if (!long_session_wp_.expired()) {
long_session_wp_.lock()->UpdatePing(); long_session_wp_.lock()->UpdatePing();
} }
} else { } else {
if (!long_session_wp_.expired()) {
msg.set_source(1);
}
} }
return; return;
} }