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

rename room -> target

Browse Source
This commit is contained in:
aozhiwei 2019-01-16 15:02:24 +08:00
parent 70ffe731f4
commit 9952d4b44a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/wsproxy/target_conn.cc
View File

@ -94,13 +94,13 @@ void TargetConn::on_error(a8::TcpClient* sender, int errorId)
void TargetConn::on_connect(a8::TcpClient* sender) void TargetConn::on_connect(a8::TcpClient* sender)
{ {
recv_bufflen_ = 0; recv_bufflen_ = 0;
a8::UdpLog::Instance()->Info("room server connected", {}); a8::UdpLog::Instance()->Info("target server connected", {});
} }
void TargetConn::on_disconnect(a8::TcpClient* sender) void TargetConn::on_disconnect(a8::TcpClient* sender)
{ {
recv_bufflen_ = 0; recv_bufflen_ = 0;
a8::UdpLog::Instance()->Info("room server %d disconnected after 10s later reconnect", {instance_id}); a8::UdpLog::Instance()->Info("target server %d disconnected after 10s later reconnect", {instance_id});
App::Instance()->AddIMMsg(IM_TargetConnDisconnect, App::Instance()->AddIMMsg(IM_TargetConnDisconnect,
a8::XParams() a8::XParams()
.SetSender(instance_id) .SetSender(instance_id)
@ -114,7 +114,7 @@ void TargetConn::on_socketread(a8::TcpClient* sender, char* buf, unsigned int le
#endif #endif
if (recv_bufflen_ + len > 2 * PACK_MAX) { if (recv_bufflen_ + len > 2 * PACK_MAX) {
recv_bufflen_ = 0; recv_bufflen_ = 0;
a8::UdpLog::Instance()->Debug("recvied room server too long message", {}); a8::UdpLog::Instance()->Debug("recvied target server too long message", {});
return; return;
} else { } else {
memmove(&recv_buff_[recv_bufflen_], buf, len); memmove(&recv_buff_[recv_bufflen_], buf, len);