From 8d243f7758bf65279be0f3086810aa85ad928b94 Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Mon, 14 Feb 2022 13:38:01 +0800 Subject: [PATCH] refactor tq --- CMakeLists.txt | 2 +- source/dnode/vnode/inc/tq.h | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/CMakeLists.txt b/CMakeLists.txt index f1be916b3b..fd542966cc 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -27,7 +27,7 @@ if(${BUILD_TEST}) endif(${BUILD_TEST}) add_subdirectory(source) add_subdirectory(tools) -#add_subdirectory(tests) +add_subdirectory(tests) add_subdirectory(example) # docs diff --git a/source/dnode/vnode/inc/tq.h b/source/dnode/vnode/inc/tq.h index df755574bf..9d396e0771 100644 --- a/source/dnode/vnode/inc/tq.h +++ b/source/dnode/vnode/inc/tq.h @@ -37,7 +37,7 @@ extern "C" { typedef struct STQ STQ; -// memory allocator supported by vnode +// memory allocator provided by vnode typedef struct STqMemRef { SMemAllocatorFactory* pAllocatorFactory; SMemAllocator* pAllocator; @@ -51,7 +51,7 @@ void tqCleanUp(); STQ* tqOpen(const char* path, SWal* pWal, SMeta* pMeta, STqCfg* tqConfig, SMemAllocatorFactory* allocFac); void tqClose(STQ*); -// void* will be replace by a msg type +// required by vnode int tqPushMsg(STQ*, void* msg, int64_t version); int tqCommit(STQ*); -- GitLab