xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

enh(rpc):add auth

This commit is contained in:
yihaoDeng 2022-04-21 21:24:27 +08:00
parent fa14caffcd
commit 0f22bf3ef9
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/common/src/tmsg.c
View File

@ -847,9 +847,9 @@ void tFreeSMAltertbReq(SMAltertbReq *pReq) {
int32_t tSerializeSMEpSet(void *buf, int32_t bufLen, SMEpSet *pReq) { int32_t tSerializeSMEpSet(void *buf, int32_t bufLen, SMEpSet *pReq) {
SCoder encoder = {0}; SCoder encoder = {0};
tCoderInit(&encoder, TD_LITTLE_ENDIAN, buf, bufLen, TD_ENCODER); tCoderInit(&encoder, TD_LITTLE_ENDIAN, buf, bufLen, TD_ENCODER);
if (tEncodeSEpSet(&encoder, &pReq->epSet) < 0) { if (tStartEncode(&encoder) < 0) return -1;
return -1; if (tEncodeSEpSet(&encoder, &pReq->epSet) < 0) return -1;
}
tEndEncode(&encoder); tEndEncode(&encoder);
int32_t tlen = encoder.pos; int32_t tlen = encoder.pos;
tCoderClear(&encoder); tCoderClear(&encoder);
@ -858,9 +858,8 @@ int32_t tSerializeSMEpSet(void *buf, int32_t bufLen, SMEpSet *pReq) {
int32_t tDeserializeSMEpSet(void *buf, int32_t bufLen, SMEpSet *pReq) { int32_t tDeserializeSMEpSet(void *buf, int32_t bufLen, SMEpSet *pReq) {
SCoder decoder = {0}; SCoder decoder = {0};
tCoderInit(&decoder, TD_LITTLE_ENDIAN, buf, bufLen, TD_DECODER); tCoderInit(&decoder, TD_LITTLE_ENDIAN, buf, bufLen, TD_DECODER);
if (tDecodeSEpSet(&decoder, &pReq->epSet) < 0) { if (tStartDecode(&decoder) < 0) return -1;
return -1; if (tDecodeSEpSet(&decoder, &pReq->epSet) < 0) return -1;
}
tEndDecode(&decoder); tEndDecode(&decoder);
tCoderClear(&decoder); tCoderClear(&decoder);