diff --git a/src/vnode/CMakeLists.txt b/src/vnode/CMakeLists.txt index 22770e379906aeb5d226a38b05e45da144323dc2..8224507f1c68576a0c9fe5f627eb5cb9539eea8f 100644 --- a/src/vnode/CMakeLists.txt +++ b/src/vnode/CMakeLists.txt @@ -6,4 +6,4 @@ add_subdirectory(tsdb) enable_testing() -add_subdirectory(tests) \ No newline at end of file +# add_subdirectory(tests) \ No newline at end of file diff --git a/src/vnode/tests/CMakeLists.txt b/src/vnode/tests/CMakeLists.txt deleted file mode 100644 index 786fa9a66f8959ca6faa1278f59c903939218e05..0000000000000000000000000000000000000000 --- a/src/vnode/tests/CMakeLists.txt +++ /dev/null @@ -1,3 +0,0 @@ -add_subdirectory(common) - -add_subdirectory(tsdb) \ No newline at end of file diff --git a/src/vnode/tests/common/CMakeLists.txt b/src/vnode/tests/common/CMakeLists.txt deleted file mode 100644 index 093768be1a1398932d66825f2f2dcf4151ae1d65..0000000000000000000000000000000000000000 --- a/src/vnode/tests/common/CMakeLists.txt +++ /dev/null @@ -1,14 +0,0 @@ -aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SOURCE_LIST) - -message(STATUS "COMMON: ${SOURCE_LIST}") - -add_executable(commonTests ${SOURCE_LIST}) - -target_link_libraries(commonTests gtest gtest_main pthread common) - -add_test( - NAME - unit - COMMAND - ${CMAKE_CURRENT_BINARY_DIR}/commonTests -) \ No newline at end of file diff --git a/src/vnode/tests/common/commonDataTests.cpp b/src/vnode/tests/common/commonDataTests.cpp deleted file mode 100644 index 7becb8699c117d50e19d4f5a8ed8944a82da794e..0000000000000000000000000000000000000000 --- a/src/vnode/tests/common/commonDataTests.cpp +++ /dev/null @@ -1,7 +0,0 @@ -#include - -#include "dataformat.h" - -TEST(commonDataTests, createDataRow) { - EXPECT_EQ(1, 2/2); -} \ No newline at end of file diff --git a/src/vnode/tests/common/commonSChemaTests.cpp b/src/vnode/tests/common/commonSChemaTests.cpp deleted file mode 100644 index 44fd384b61c567487477b3c60e24630c4b4e935c..0000000000000000000000000000000000000000 --- a/src/vnode/tests/common/commonSChemaTests.cpp +++ /dev/null @@ -1,9 +0,0 @@ -#include -#include -#include - -#include "schema.h" - -TEST(commonSchemaTests, createSchema) { - EXPECT_EQ(1, 2/2); -} \ No newline at end of file diff --git a/src/vnode/tests/tsdb/tsdbTests.cpp b/src/vnode/tests/tsdb/tsdbTests.cpp deleted file mode 100644 index a7d558d38c5ae585f8be4610d96d252522f1319e..0000000000000000000000000000000000000000 --- a/src/vnode/tests/tsdb/tsdbTests.cpp +++ /dev/null @@ -1,37 +0,0 @@ -#include -#include - -#include "tsdb.h" - -TEST(TsdbTest, createTsdbRepo) { - STsdbCfg *pCfg = tsdbCreateDefaultCfg(); - - - tsdb_repo_t *pRepo = tsdbCreateRepo("/root/mnt/test/vnode0", pCfg, NULL); - - tsdbFreeCfg(pCfg); - - ASSERT_NE(pRepo, nullptr); - - STableCfg config; - config.tableId.tid = 0; - config.tableId.uid = 10889498868728187539; - config.numOfCols = 2; - config.schema = (SSchema *)malloc(sizeof(SSchema) + sizeof(SColumn) * config.numOfCols); - config.schema->version = 0; - config.schema->numOfCols = 2; - config.schema->numOfTags = 0; - config.schema->colIdCounter = 1; - for (int i = 0; i < config.numOfCols; i++) { - SColumn *pCol = config.schema->columns + i; - pCol->type = TD_DATATYPE_BIGINT; - pCol->colId = config.schema->colIdCounter++; - pCol->offset = 10; - pCol->colName = strdup("col1"); - } - config.tagValues = NULL; - - tsdbCreateTable(pRepo, &config); - - tsdbCloseRepo(pRepo); -} \ No newline at end of file diff --git a/src/vnode/tsdb/CMakeLists.txt b/src/vnode/tsdb/CMakeLists.txt index 91c7d571e8ce8937d75df1289d4c059c60e0c618..9736f2cb88dad4aa2ba502d602ea5da4821eed75 100644 --- a/src/vnode/tsdb/CMakeLists.txt +++ b/src/vnode/tsdb/CMakeLists.txt @@ -8,4 +8,6 @@ target_include_directories(tsdb PUBLIC "${CMAKE_SOURCE_DIR}/src/inc" PUBLIC "${CMAKE_SOURCE_DIR}/src/util/inc" PUBLIC "${CMAKE_SOURCE_DIR}/src/os/linux/inc" - ) \ No newline at end of file + ) + +add_subdirectory(tests) \ No newline at end of file diff --git a/src/vnode/tsdb/inc/tsdbMeta.h b/src/vnode/tsdb/inc/tsdbMeta.h index 833e5b134a2e2ae1e7e49deaf11aa11e9e7f0331..12edfece8c467dbf0ecd9bcacf08bbec99ac043e 100644 --- a/src/vnode/tsdb/inc/tsdbMeta.h +++ b/src/vnode/tsdb/inc/tsdbMeta.h @@ -116,6 +116,7 @@ int32_t tsdbCreateTableImpl(STsdbMeta *pMeta, STableCfg *pCfg); int32_t tsdbDropTableImpl(STsdbMeta *pMeta, STableId tableId); STable *tsdbIsValidTableToInsert(STsdbMeta *pMeta, STableId tableId); int32_t tsdbInsertRowToTableImpl(SSkipListNode *pNode, STable *pTable); +STable *tsdbGetTableByUid(STsdbMeta *pMeta, int64_t uid); #ifdef __cplusplus } diff --git a/src/vnode/tsdb/src/tsdbMeta.c b/src/vnode/tsdb/src/tsdbMeta.c index a780deb7df40d887ec7b7b2db6c2cd32addcc959..bbb813ad74282d4d0cd57417d3a082c6bb87e9c7 100644 --- a/src/vnode/tsdb/src/tsdbMeta.c +++ b/src/vnode/tsdb/src/tsdbMeta.c @@ -12,7 +12,6 @@ static int tsdbFreeTable(STable *pTable); static int32_t tsdbCheckTableCfg(STableCfg *pCfg); -static STable *tsdbGetTableByUid(STsdbMeta *pMeta, int64_t uid); static int tsdbAddTableToMeta(STsdbMeta *pMeta, STable *pTable); static int tsdbAddTableIntoMap(STsdbMeta *pMeta, STable *pTable); static int tsdbAddTableIntoIndex(STsdbMeta *pMeta, STable *pTable); @@ -206,7 +205,7 @@ static int32_t tsdbCheckTableCfg(STableCfg *pCfg) { return 0; } -static STable *tsdbGetTableByUid(STsdbMeta *pMeta, int64_t uid) { +STable *tsdbGetTableByUid(STsdbMeta *pMeta, int64_t uid) { return (STable *)taosGetDataFromHashTable(pMeta->tableMap, (char *)(&uid), sizeof(uid)); } diff --git a/src/vnode/tests/tsdb/CMakeLists.txt b/src/vnode/tsdb/tests/CMakeLists.txt similarity index 86% rename from src/vnode/tests/tsdb/CMakeLists.txt rename to src/vnode/tsdb/tests/CMakeLists.txt index a942dd917e7cb52c9c41162dffe7206d7f16e69c..1026ee0d9c4865a06ab6711fe3a850ff0693389a 100644 --- a/src/vnode/tests/tsdb/CMakeLists.txt +++ b/src/vnode/tsdb/tests/CMakeLists.txt @@ -1,7 +1,5 @@ aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SOURCE_LIST) -message(STATUS "TSDB: ${SOURCE_LIST}") - add_executable(tsdbTests ${SOURCE_LIST}) target_link_libraries(tsdbTests gtest gtest_main pthread tsdb) diff --git a/src/vnode/tsdb/tests/tsdbTests.cpp b/src/vnode/tsdb/tests/tsdbTests.cpp new file mode 100644 index 0000000000000000000000000000000000000000..33a557aeaf1b5f83deb9e48c4e09f882bb646f6e --- /dev/null +++ b/src/vnode/tsdb/tests/tsdbTests.cpp @@ -0,0 +1,65 @@ +#include +#include + +#include "tsdbMeta.h" + +TEST(TsdbTest, createTable) { + STsdbMeta *pMeta = tsdbCreateMeta(100); + ASSERT_NE(pMeta, nullptr); + + STableCfg config; + config.tableId.tid = 0; + config.tableId.uid = 98868728187539L; + config.numOfCols = 2; + config.schema = (SSchema *)malloc(sizeof(SSchema) + sizeof(SColumn) * config.numOfCols); + config.schema->version = 0; + config.schema->numOfCols = 2; + config.schema->numOfTags = 0; + config.schema->colIdCounter = 1; + for (int i = 0; i < config.numOfCols; i++) { + SColumn *pCol = config.schema->columns + i; + pCol->type = TD_DATATYPE_BIGINT; + pCol->colId = config.schema->colIdCounter++; + pCol->offset = 10; + pCol->colName = strdup("col1"); + } + config.tagValues = nullptr; + + tsdbCreateTableImpl(pMeta, &config), 0; + + STable *pTable = tsdbGetTableByUid(pMeta, config.tableId.uid); + ASSERT_NE(pTable, nullptr); +} + +TEST(TsdbTest, DISABLED_createTsdbRepo) { + STsdbCfg *pCfg = tsdbCreateDefaultCfg(); + + + tsdb_repo_t *pRepo = tsdbCreateRepo("/root/mnt/test/vnode0", pCfg, NULL); + + tsdbFreeCfg(pCfg); + + ASSERT_NE(pRepo, nullptr); + + STableCfg config; + config.tableId.tid = 0; + config.tableId.uid = 10889498868728187539; + config.numOfCols = 2; + config.schema = (SSchema *)malloc(sizeof(SSchema) + sizeof(SColumn) * config.numOfCols); + config.schema->version = 0; + config.schema->numOfCols = 2; + config.schema->numOfTags = 0; + config.schema->colIdCounter = 1; + for (int i = 0; i < config.numOfCols; i++) { + SColumn *pCol = config.schema->columns + i; + pCol->type = TD_DATATYPE_BIGINT; + pCol->colId = config.schema->colIdCounter++; + pCol->offset = 10; + pCol->colName = strdup("col1"); + } + config.tagValues = NULL; + + tsdbCreateTable(pRepo, &config); + + tsdbCloseRepo(pRepo); +} \ No newline at end of file