From 9cc076ac83b632a3b18deab100a2b3711d18c08e Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 8 Apr 2022 16:36:30 +0800 Subject: [PATCH] handle except --- source/common/src/tmsg.c | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c index 4923d09c9e..b79702e2bf 100644 --- a/source/common/src/tmsg.c +++ b/source/common/src/tmsg.c @@ -788,6 +788,7 @@ int32_t tSerializeSMDropSmaReq(void *buf, int32_t bufLen, SMDropSmaReq *pReq) { if (tStartEncode(&encoder) < 0) return -1; if (tEncodeCStr(&encoder, pReq->name) < 0) return -1; + if (tEncodeI8(&encoder, pReq->igNotExists) < 0) return -1; tEndEncode(&encoder); @@ -838,6 +839,10 @@ int32_t tSerializeSMDropFullTextReq(void *buf, int32_t bufLen, SMDropFullTextReq if (tStartEncode(&encoder) < 0) return -1; + if (tEncodeCStr(&encoder, pReq->name) < 0) return -1; + + if (tEncodeI8(&encoder, pReq->igNotExists) < 0) return -1; + tEndEncode(&encoder); int32_t tlen = encoder.pos; tCoderClear(&encoder); @@ -847,6 +852,8 @@ int32_t tDeserializeSMDropFullTextReq(void *buf, int32_t bufLen, SMDropFullTextR SCoder decoder = {0}; tCoderInit(&decoder, TD_LITTLE_ENDIAN, buf, bufLen, TD_DECODER); if (tStartDecode(&decoder) < 0) return -1; + if (tDecodeCStrTo(&decoder, pReq->name) < 0) return -1; + if (tDecodeI8(&decoder, &pReq->igNotExists) < 0) return -1; tEndDecode(&decoder); tCoderClear(&decoder);