diff --git a/server/wsproxy/downstream.cc b/server/wsproxy/downstream.cc index f3aab6e..d5a9af1 100644 --- a/server/wsproxy/downstream.cc +++ b/server/wsproxy/downstream.cc @@ -58,14 +58,16 @@ void DownStream::OnClose() void DownStream::ProcCMMsg(f8::MsgHdr& hdr, int tag) { if (hdr.msgid == ss::_SS_CMPing) { - ss::SS_Ping msg; + ss::SS_SMPing msg; if (IsLongSession() && tag == ST_Tcp) { GCListener::Instance()->SendMsgEx(socket_handle_, ss::_SS_CMPing, msg); if (!long_session_wp_.expired()) { long_session_wp_.lock()->UpdatePing(); } } else { - + if (!long_session_wp_.expired()) { + msg.set_source(1); + } } return; }