Merge pull request #9533 from taosdata/feature/vnode

Feature/vnode

include/common/tmsg.h

@@ -23,6 +23,7 @@ extern "C" {
 #include "encode.h"
 #include "taosdef.h"
 #include "taoserror.h"
+#include "tarray.h"
 #include "tcoding.h"
 #include "tdataformat.h"
 #include "tlist.h"
@@ -1271,6 +1272,11 @@ typedef struct SVCreateTbReq {
   };
 } SVCreateTbReq;
 
+typedef struct {
+  uint64_t ver;  // use a general definition
+  SArray*  pArray;
+} SVCreateTbBatchReq;
+
 int   tmsgSVCreateTbReqEncode(SMsgEncoder* pCoder, SVCreateTbReq* pReq);
 int   tmsgSVCreateTbReqDecode(SMsgDecoder* pCoder, SVCreateTbReq* pReq);
 int   tSerializeSVCreateTbReq(void** buf, const SVCreateTbReq* pReq);

include/dnode/vnode/meta/meta.h

@@ -59,9 +59,9 @@ STbCfg *        metaGetTbInfoByUid(SMeta *pMeta, tb_uid_t uid);
 STbCfg *        metaGetTbInfoByName(SMeta *pMeta, char *tbname, tb_uid_t *uid);
 SSchemaWrapper *metaGetTableSchema(SMeta *pMeta, tb_uid_t uid, int32_t sver, bool isinline);
 
-SMTbCursor *   metaOpenTbCursor(SMeta *pMeta);
-void           metaCloseTbCursor(SMTbCursor *pTbCur);
-char *metaTbCursorNext(SMTbCursor *pTbCur);
+SMTbCursor *metaOpenTbCursor(SMeta *pMeta);
+void        metaCloseTbCursor(SMTbCursor *pTbCur);
+char *      metaTbCursorNext(SMTbCursor *pTbCur);
 
 // Options
 void metaOptionsInit(SMetaCfg *pMetaCfg);