more

include/common/tmsg.h

@@ -1127,17 +1127,17 @@ typedef struct SVCreateTbReq {
 
 static FORCE_INLINE int tSerializeSVCreateTbReq(void** buf, const SVCreateTbReq* pReq) {
   int      tlen = 0;
-  uint8_t* pBuf = (uint8_t*)(*buf);
-
-  if (TD_RT_ENDIAN() == TD_LITTLE_ENDIAN) {
-    pBuf += tPut(pBuf, pReq->ver, uint64_t);
-    pBuf += tPut(pBuf, pReq->ttl, uint32_t);
-    pBuf += tPut(pBuf, pReq->keep, uint32_t);
-  } else {
-    pBuf += tPutl(pBuf, pReq->ver, uint64_t);
-    pBuf += tPutl(pBuf, pReq->ttl, uint32_t);
-    pBuf += tPutl(pBuf, pReq->keep, uint32_t);
-  }
+  // uint8_t* pBuf = (uint8_t*)(*buf);
+
+  // if (TD_RT_ENDIAN() == TD_LITTLE_ENDIAN) {
+  //   pBuf += tPut(pBuf, pReq->ver, uint64_t);
+  //   pBuf += tPut(pBuf, pReq->ttl, uint32_t);
+  //   pBuf += tPut(pBuf, pReq->keep, uint32_t);
+  // } else {
+  //   pBuf += tPutl(pBuf, pReq->ver, uint64_t);
+  //   pBuf += tPutl(pBuf, pReq->ttl, uint32_t);
+  //   pBuf += tPutl(pBuf, pReq->keep, uint32_t);
+  // }
 
   tlen += taosEncodeFixedU64(buf, pReq->ver);
   tlen += taosEncodeString(buf, pReq->name);

include/util/tcoding.h

@@ -218,9 +218,9 @@ extern "C" {
 #define tGetb(BUF, VAL, TYPE) tGet_##TYPE##_b(BUF, VAL, TYPE)
 
 /* ------------------------ VARIANT-LENGTH ENCODING ------------------------ */
-#define vPutU(BUF, VAL)                                        \
+#define vPut(BUF, VAL, SIGN)                                   \
   ({                                                           \
-    uint64_t tmp = (VAL);                                      \
+    uint64_t tmp = (SIGN) ? ZIGZAGE(int64_t, VAL) : (VAL);     \
     int      i = 0;                                            \
     while ((VAL) >= ENCODE_LIMIT) {                            \
       ((uint8_t *)(BUF))[i] = (uint8_t)((tmp) | ENCODE_LIMIT); \
@@ -231,16 +231,27 @@ extern "C" {
     i + 1;                                                     \
   })
 
-#define vGetU(BUF, VAL)
-
-#define vPutI(BUF, VAL, TYPE)          \
-  ({                                   \
-    uint64_t tmp = ZIGZAGE(TYPE, VAL); \
-    vPutU(BUF, tmp);                   \
+#define vGet(BUF, VAL, SIGN)                              \
+  ({                                                      \
+    uint64_t tmp;                                         \
+    uint64_t tval = 0;                                    \
+    int      i = 0;                                       \
+    while (true) {                                        \
+      tmp = (uint64_t)(((uint8_t *)(BUF))[i]);            \
+      if (tmp < ENCODE_LIMIT) {                           \
+        tval |= (tval << (7 * i));                        \
+        break;                                            \
+      } else {                                            \
+        tval |= ((tval & (ENCODE_LIMIT - 1)) << (7 * i)); \
+        i++;                                              \
+      }                                                   \
+    }                                                     \
+    if (SIGN) {                                           \
+      (VAL) = ZIGZAGD(int64_t, tmp);                      \
+    }                                                     \
+    i;                                                    \
   })
 
-#define vGetI(BUF, VAL, TYPE)
-
 /* ------------------------ OTHER TYPE ENCODING ------------------------ */
 
 /* ------------------------ LEGACY CODES ------------------------ */