more TDB

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

@@ -13,16 +13,33 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#include "meta.h"
+#include "metaDef.h"
 
 #include "tdb.h"
 
 struct SMetaDB {
-  // TODO
+  TENV *pEnv;
+  TDB * pTbDB;
+  TDB * pSchemaDB;
+  TDB * pNameIdx;
+  TDB * pStbIdx;
+  TDB * pNtbIdx;
+  TDB * pCtbIdx;
+  // tag index hash table
+  // suid+colid --> TDB *
+  struct {
+  } tagIdxHt;
 };
 
 int metaOpenDB(SMeta *pMeta) {
-  // TODO
+  SMetaDB *pDb;
+
+  pDb = (SMetaDB *)calloc(1, sizeof(*pDb));
+  if (pDb == NULL) {
+    return -1;
+  }
+
+  pMeta->pDB = pDb;
   return 0;
 }
 

source/libs/tdb/inc/tdb.h

@@ -27,6 +27,7 @@ typedef struct STDbEnv    TENV;
 typedef struct STDbCurosr TDBC;
 
 // TEVN
+int tdbEnvCreate(TENV **ppEnv);
 int tdbEnvOpen(TENV **ppEnv);
 int tdbEnvClose(TENV *pEnv);
 

source/libs/tdb/src/db/tdbEnv.c

@@ -23,13 +23,22 @@ struct STDbEnv {
   SPgCache pgc;  // page cache
 };
 
+static int tdbEnvDestroy(TENV *pEnv);
+
+int tdbEnvCreate(TENV **ppEnv) {
+  // TODO
+  return 0;
+}
+
 int tdbEnvOpen(TENV **ppEnv) {
   // TODO
   return 0;
 }
 
 int tdbEnvClose(TENV *pEnv) {
-  // TODO
+  if (pEnv == NULL) return 0;
+  /* TODO */
+  tdbEnvDestroy(pEnv);
   return 0;
 }
 
@@ -38,4 +47,9 @@ SPgFile *tdbEnvGetPageFile(TENV *pEnv, const uint8_t fileid[]) {
   return NULL;
 }
 
-SPgCache *tdbEnvGetPgCache(TENV *pEnv) { return &(pEnv->pgc); }
\ No newline at end of file
+SPgCache *tdbEnvGetPgCache(TENV *pEnv) { return &(pEnv->pgc); }
+
+static int tdbEnvDestroy(TENV *pEnv) {
+  // TODO
+  return 0;
+}
\ No newline at end of file