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

add ext_len

Browse Source
This commit is contained in:
aozhiwei 2019-06-01 16:18:56 +08:00
parent 7af5d3b84a
commit 35fc91f982
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cpp/protoutils.cc
View File

@ -81,7 +81,6 @@ namespace f8
::google::protobuf::Message& msg) ::google::protobuf::Message& msg)
{ {
int packlen = msg.ByteSize(); int packlen = msg.ByteSize();
assert(packlen < 1024 * 60);
char* buff = (char*)malloc(sizeof(PackHead) + packlen); char* buff = (char*)malloc(sizeof(PackHead) + packlen);
PackHead* head = (PackHead*)buff; PackHead* head = (PackHead*)buff;
@ -89,7 +88,7 @@ namespace f8
head->msgid = msgid; head->msgid = msgid;
head->seqid = seqid; head->seqid = seqid;
head->magic_code = MAGIC_CODE; head->magic_code = MAGIC_CODE;
head->rpc_error_code = 0; head->ext_len = packlen >> 16;
msg.SerializeToArray(buff + sizeof(PackHead), packlen); msg.SerializeToArray(buff + sizeof(PackHead), packlen);
tcp_client->SendBuff(buff, sizeof(PackHead) + packlen); tcp_client->SendBuff(buff, sizeof(PackHead) + packlen);
free(buff); free(buff);
@ -119,7 +118,6 @@ namespace f8
unsigned short msgid, ::google::protobuf::Message& msg) unsigned short msgid, ::google::protobuf::Message& msg)
{ {
int packlen = msg.ByteSize(); int packlen = msg.ByteSize();
assert(packlen < 1024 * 60);
char* buff = (char*)malloc(sizeof(PackHead) + packlen); char* buff = (char*)malloc(sizeof(PackHead) + packlen);
PackHead* head = (PackHead*)buff; PackHead* head = (PackHead*)buff;
@ -127,7 +125,7 @@ namespace f8
head->msgid = msgid; head->msgid = msgid;
head->seqid = seqid; head->seqid = seqid;
head->magic_code = MAGIC_CODE; head->magic_code = MAGIC_CODE;
head->rpc_error_code = 0; head->rpc_ext_len = packlen >> 16;
msg.SerializeToArray(buff + sizeof(PackHead), packlen); msg.SerializeToArray(buff + sizeof(PackHead), packlen);
tcp_listener->SendClientMsg(socket_handle, buff, sizeof(PackHead) + packlen); tcp_listener->SendClientMsg(socket_handle, buff, sizeof(PackHead) + packlen);
free(buff); free(buff);
@ -157,7 +155,6 @@ namespace f8
unsigned short msgid, ::google::protobuf::Message& msg) unsigned short msgid, ::google::protobuf::Message& msg)
{ {
int packlen = msg.ByteSize(); int packlen = msg.ByteSize();
assert(packlen < 1024 * 60);
char* buff = (char*)malloc(sizeof(PackHead) + packlen); char* buff = (char*)malloc(sizeof(PackHead) + packlen);
PackHead* head = (PackHead*)buff; PackHead* head = (PackHead*)buff;
@ -165,7 +162,7 @@ namespace f8
head->msgid = msgid; head->msgid = msgid;
head->seqid = seqid; head->seqid = seqid;
head->magic_code = MAGIC_CODE; head->magic_code = MAGIC_CODE;
head->rpc_error_code = 0; head->ext_len = packlen >> 16;
msg.SerializeToArray(buff + sizeof(PackHead), packlen); msg.SerializeToArray(buff + sizeof(PackHead), packlen);
tcp_listener->BroadcastMsg(buff, sizeof(PackHead) + packlen); tcp_listener->BroadcastMsg(buff, sizeof(PackHead) + packlen);
free(buff); free(buff);

2
cpp/protoutils.h
View File

@ -24,7 +24,7 @@ namespace f8
unsigned short msgid; unsigned short msgid;
unsigned int seqid; unsigned int seqid;
unsigned short magic_code; unsigned short magic_code;
unsigned short rpc_error_code; unsigned short ext_len;
}; };
//大包消息头部 //大包消息头部