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 2019-01-16 16:44:40 +08:00
parent c82e25b233
commit 8fd4151a1b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/wsproxy/target_conn.cc
View File

@ -126,7 +126,7 @@ void TargetConn::on_socketread(a8::TcpClient* sender, char* buf, unsigned int le
while (recv_bufflen_ - offset >= sizeof(f8::WSProxyPackHead_S)) { while (recv_bufflen_ - offset >= sizeof(f8::WSProxyPackHead_S)) {
f8::WSProxyPackHead_S* p = (f8::WSProxyPackHead_S*) &recv_buff_[offset]; f8::WSProxyPackHead_S* p = (f8::WSProxyPackHead_S*) &recv_buff_[offset];
if (p->magic_code == f8::MAGIC_CODE) { if (p->magic_code == f8::MAGIC_CODE) {
if (recv_bufflen_ - offset < sizeof(f8::PackHead) + p->packlen) { if (recv_bufflen_ - offset < sizeof(f8::WSProxyPackHead_S) + p->packlen) {
break; break;
} }
App::Instance()->AddSocketMsg(SF_TargetServer, App::Instance()->AddSocketMsg(SF_TargetServer,
@ -136,7 +136,7 @@ void TargetConn::on_socketread(a8::TcpClient* sender, char* buf, unsigned int le
p->seqid, p->seqid,
&recv_buff_[offset + sizeof(f8::WSProxyPackHead_S)], &recv_buff_[offset + sizeof(f8::WSProxyPackHead_S)],
p->packlen); p->packlen);
offset += sizeof(f8::PackHead) + p->packlen; offset += sizeof(f8::WSProxyPackHead_S) + p->packlen;
} else { } else {
warning = true; warning = true;
offset++; offset++;