From 8287a34ccb1230970be4a16c5fb4cea4c6a904ab Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Tue, 12 Oct 2021 15:23:36 +0800 Subject: [PATCH] more progress --- source/server/vnode/meta/src/meta.c | 7 ++++--- source/server/vnode/meta/test/metaTests.cpp | 6 +++--- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/source/server/vnode/meta/src/meta.c b/source/server/vnode/meta/src/meta.c index b3d33c7b87..000b2ca9b0 100644 --- a/source/server/vnode/meta/src/meta.c +++ b/source/server/vnode/meta/src/meta.c @@ -145,19 +145,20 @@ int metaCreateTable(SMeta *pMeta, STableOpts *pTableOpts) { taosHashPut(pMeta->pTableObjHash, &(pTableObj->pTable->uid), sizeof(tb_uid_t), &pTableObj, sizeof(pTableObj)); wopt = rocksdb_writeoptions_create(); + rocksdb_writeoptions_disable_WAL(wopt, 1); // Add to tbname db rocksdb_put(pMeta->tbnameDb, wopt, pTableOpts->name, strlen(pTableOpts->name), &pTableObj->pTable->uid, sizeof(tb_uid_t), &err); // Add to schema db - char id[12]; - char buf[256]; + char id[12]; + char buf[256]; void *pBuf = buf; *(tb_uid_t *)id = pTableObj->pTable->uid; *(int32_t *)(id + sizeof(tb_uid_t)) = schemaVersion(pTableOpts->pSchema); int size = tdEncodeSchema(&pBuf, pTableOpts->pSchema); - + rocksdb_put(pMeta->schemaDb, wopt, id, 12, buf, size, &err); rocksdb_writeoptions_destroy(wopt); diff --git a/source/server/vnode/meta/test/metaTests.cpp b/source/server/vnode/meta/test/metaTests.cpp index f81302fc91..47ca49b70a 100644 --- a/source/server/vnode/meta/test/metaTests.cpp +++ b/source/server/vnode/meta/test/metaTests.cpp @@ -31,7 +31,7 @@ TEST(MetaTest, meta_open_test) { metaClose(meta); std::cout << "Meta is closed!" << std::endl; - // // Destroy Meta - // metaDestroy("meta"); - // std::cout << "Meta is destroyed!" << std::endl; + // Destroy Meta + metaDestroy("meta"); + std::cout << "Meta is destroyed!" << std::endl; } \ No newline at end of file -- GitLab