1
This commit is contained in:
parent
6210196bcd
commit
9ba2696e52
@ -281,6 +281,30 @@ namespace f8
|
||||
return sizeof(WSProxyPackHead_C) + packlen;
|
||||
}
|
||||
|
||||
int Net_SendProxyCMsg(a8::AsyncTcpClient* tcp_client, unsigned short socket_handle,
|
||||
unsigned short msgid, ::google::protobuf::Message& msg)
|
||||
{
|
||||
int packlen = msg.ByteSize();
|
||||
assert(packlen < 1024 * 60);
|
||||
|
||||
char* buff = (char*)malloc(sizeof(WSProxyPackHead_C) + packlen);
|
||||
memset(buff, 0, sizeof(WSProxyPackHead_C));
|
||||
WSProxyPackHead_C* head = (WSProxyPackHead_C*)buff;
|
||||
head->packlen = packlen;
|
||||
head->msgid = msgid;
|
||||
head->seqid = 0;
|
||||
head->magic_code = MAGIC_CODE;
|
||||
head->ip_saddr = 0;
|
||||
head->socket_handle = socket_handle;
|
||||
|
||||
if (packlen > 0) {
|
||||
msg.SerializeToArray(buff + sizeof(WSProxyPackHead_C), packlen);
|
||||
}
|
||||
tcp_client->SendBuff(buff, sizeof(WSProxyPackHead_C) + packlen);
|
||||
free(buff);
|
||||
return sizeof(WSProxyPackHead_C) + packlen;
|
||||
}
|
||||
|
||||
int Net_SendProxyMsg(a8::TcpListener* tcp_listener, int socket_handle,
|
||||
unsigned int seqid, unsigned short error_code,
|
||||
unsigned short msgid, ::google::protobuf::Message& msg)
|
||||
|
@ -129,6 +129,8 @@ namespace f8
|
||||
|
||||
int Net_SendProxyCMsg(a8::TcpClient* tcp_client, unsigned short socket_handle,
|
||||
unsigned short msgid, ::google::protobuf::Message& msg);
|
||||
int Net_SendProxyCMsg(a8::AsyncTcpClient* tcp_client, unsigned short socket_handle,
|
||||
unsigned short msgid, ::google::protobuf::Message& msg);
|
||||
|
||||
int Net_SendProxyMsg(a8::TcpListener* tcp_tlistener, int socket_handle,
|
||||
unsigned int seqid, unsigned short error_code,
|
||||
|
Loading…
x
Reference in New Issue
Block a user