more

include/dnode/vnode/meta/meta.h

@@ -105,7 +105,7 @@ void metaOptionsClear(SMetaCfg *pOptions);
 #define META_CLEAR_TB_CFG(pTbCfg)
 
 int   metaEncodeTbCfg(void **pBuf, STbCfg *pTbCfg);
-void *metaDecodeTbCfg(void *pBuf, STbCfg **pTbCfg);
+void *metaDecodeTbCfg(void *pBuf, STbCfg *pTbCfg);
 
 #ifdef __cplusplus
 }

source/dnode/vnode/meta/src/metaTbCfg.c

@@ -49,10 +49,55 @@ size_t metaEncodeTbObjFromTbOptions(const STbCfg *pTbOptions, void *pBuf, size_t
 }
 
 int metaEncodeTbCfg(void **pBuf, STbCfg *pTbCfg) {
-  // TODO
-  return 0;
+  int tsize = 0;
+
+  tsize += taosEncodeString(pBuf, pTbCfg->name);
+  tsize += taosEncodeFixedU32(pBuf, pTbCfg->ttl);
+  tsize += taosEncodeFixedU32(pBuf, pTbCfg->keep);
+  tsize += taosEncodeFixedU8(pBuf, pTbCfg->type);
+
+  switch (pTbCfg->type) {
+    case META_SUPER_TABLE:
+      tsize += taosEncodeFixedU64(pBuf, pTbCfg->stbCfg.suid);
+      tsize += tdEncodeSchema(pBuf, pTbCfg->stbCfg.pSchema);
+      tsize += tdEncodeSchema(pBuf, pTbCfg->stbCfg.pTagSchema);
+      break;
+    case META_CHILD_TABLE:
+      tsize += taosEncodeFixedU64(pBuf, pTbCfg->ctbCfg.suid);
+      tsize += tdEncodeKVRow(pBuf, pTbCfg->ctbCfg.pTag);
+      break;
+    case META_NORMAL_TABLE:
+      tsize += tdEncodeSchema(pBuf, pTbCfg->ntbCfg.pSchema);
+      break;
+    default:
+      break;
+  }
+
+  return tsize;
 }
 
-void *metaDecodeTbCfg(void *pBuf, STbCfg **pTbCfg) {
-  // TODO
+void *metaDecodeTbCfg(void *pBuf, STbCfg *pTbCfg) {
+  pBuf = taosDecodeString(pBuf, &(pTbCfg->name));
+  pBuf = taosDecodeFixedU32(pBuf, &(pTbCfg->ttl));
+  pBuf = taosDecodeFixedU32(pBuf, &(pTbCfg->keep));
+  pBuf = taosDecodeFixedU8(pBuf, &(pTbCfg->type));
+
+  switch (pTbCfg->type) {
+    case META_SUPER_TABLE:
+      pBuf = taosDecodeFixedU64(pBuf, &(pTbCfg->stbCfg.suid));
+      pBuf = tdDecodeSchema(pBuf, &(pTbCfg->stbCfg.pSchema));
+      pBuf = tdDecodeSchema(pBuf, &(pTbCfg->stbCfg.pTagSchema));
+      break;
+    case META_CHILD_TABLE:
+      pBuf = taosDecodeFixedU64(pBuf, &(pTbCfg->ctbCfg.suid));
+      pBuf = tdDecodeKVRow(pBuf, &(pTbCfg->ctbCfg.pTag));
+      break;
+    case META_NORMAL_TABLE:
+      pBuf = tdDecodeSchema(pBuf, &(pTbCfg->ntbCfg.pSchema));
+      break;
+    default:
+      break;
+  }
+
+  return pBuf;
 }
\ No newline at end of file