refact

source/libs/CMakeLists.txt

 add_subdirectory(transport)
 add_subdirectory(sync)
-add_subdirectory(tkv)
+add_subdirectory(tdb)
 add_subdirectory(index)
 add_subdirectory(wal)
 add_subdirectory(parser)

source/libs/tkv/CMakeLists.txt → source/libs/tdb/CMakeLists.txt

-aux_source_directory(src TKV_SRC)
-add_library(tkv STATIC ${TKV_SRC})
+aux_source_directory(src TDB_SRC)
+add_library(tdb STATIC ${TDB_SRC})
 # target_include_directories(
 #     tkv
 #     PUBLIC "${CMAKE_SOURCE_DIR}/include/libs/tkv"
 #     PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc"
 # )
 target_include_directories(
-    tkv
+    tdb
     PUBLIC "${CMAKE_CURRENT_SOURCE_DIR}/inc"
     PUBLIC "${CMAKE_CURRENT_SOURCE_DIR}/src/inc"
 )
 target_link_libraries(
-    tkv
+    tdb
     PUBLIC os
     PUBLIC util
 )
\ No newline at end of file

source/libs/tkv/inc/tkv.h → source/libs/tdb/inc/tdb.h

@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_H_
-#define _TD_TKV_H_
+#ifndef _TD_TDB_H_
+#define _TD_TDB_H_
 
 #include "os.h"
 
@@ -28,7 +28,7 @@ typedef struct TDB_ENV TDB_ENV;
 
 // SKey
 typedef struct {
-  void *   bdata;
+  void*    bdata;
   uint32_t size;
 } TDB_KEY, TDB_VALUE;
 
@@ -36,4 +36,4 @@ typedef struct {
 }
 #endif
 
-#endif /*_TD_TKV_H_*/
+#endif /*_TD_TDB_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvBtree.h → source/libs/tdb/src/inc/tdbBtree.h

@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_BTREE_H_
-#define _TD_TKV_BTREE_H_
+#ifndef _TD_TDB_BTREE_H_
+#define _TD_TDB_BTREE_H_
 
 #include "tkvDef.h"
 
@@ -24,10 +24,10 @@ extern "C" {
 
 typedef struct {
   pgid_t root;  // root page number
-} STkvBtree;
+} TDB_BTREE;
 
 #ifdef __cplusplus
 }
 #endif
 
-#endif /*_TD_TKV_BTREE_H_*/
+#endif /*_TD_TDB_BTREE_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvBufPool.h → source/libs/tdb/src/inc/tdbBufPool.h

@@ -13,10 +13,10 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_BUF_POOL_H_
-#define _TD_TKV_BUF_POOL_H_
+#ifndef _TD_TDB_BUF_POOL_H_
+#define _TD_TDB_BUF_POOL_H_
 
-#include "tkvPage.h"
+#include "tdbPage.h"
 
 #ifdef __cplusplus
 extern "C" {
@@ -26,9 +26,9 @@ typedef struct STkvBufPool STkvBufPool;
 
 int       tbpOpen(STkvBufPool **ppTkvBufPool);
 int       tbpClose(STkvBufPool *pTkvBufPool);
-STkvPage *tbpNewPage(STkvBufPool *pTkvBufPool);
+STdbPage *tbpNewPage(STkvBufPool *pTkvBufPool);
 int       tbpDelPage(STkvBufPool *pTkvBufPool);
-STkvPage *tbpFetchPage(STkvBufPool *pTkvBufPool, pgid_t pgid);
+STdbPage *tbpFetchPage(STkvBufPool *pTkvBufPool, pgid_t pgid);
 int       tbpUnpinPage(STkvBufPool *pTkvBufPool, pgid_t pgid);
 void      tbpFlushPages(STkvBufPool *pTkvBufPool);
 
@@ -36,4 +36,4 @@ void      tbpFlushPages(STkvBufPool *pTkvBufPool);
 }
 #endif
 
-#endif /*_TD_TKV_BUF_POOL_H_*/
+#endif /*_TD_TDB_BUF_POOL_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvDB.h → source/libs/tdb/src/inc/tdbDB.h

@@ -13,11 +13,11 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_DB_H_
-#define _TD_TKV_DB_H_
+#ifndef _TD_TDB_DB_H_
+#define _TD_TDB_DB_H_
 
-#include "tkvBtree.h"
-#include "tkvHash.h"
+#include "tdbBtree.h"
+#include "tdbHash.h"
 
 #ifdef __cplusplus
 extern "C" {
@@ -42,4 +42,4 @@ struct TDB {
 }
 #endif
 
-#endif /*_TD_TKV_DB_H_*/
+#endif /*_TD_TDB_DB_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvDef.h → source/libs/tdb/src/inc/tdbDef.h

@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_DEF_H_
-#define _TD_TKV_DEF_H_
+#ifndef _TD_TDB_DEF_H_
+#define _TD_TDB_DEF_H_
 
 #include "os.h"
 
@@ -39,4 +39,4 @@ typedef int32_t pgsize_t;
 }
 #endif
 
-#endif /*_TD_TKV_DEF_H_*/
+#endif /*_TD_TDB_DEF_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvDiskMgr.h → source/libs/tdb/src/inc/tdbDiskMgr.h

@@ -22,7 +22,7 @@ extern "C" {
 
 #include "os.h"
 
-#include "tkvDef.h"
+#include "tdbDef.h"
 
 typedef struct STkvDiskMgr STkvDiskMgr;
 

source/libs/tkv/src/inc/tkvEnv.h → source/libs/tdb/src/inc/tdbEnv.h

@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_TKV_ENV_H_
-#define _TD_TKV_ENV_H_
+#ifndef _TD_TDB_ENV_H_
+#define _TD_TDB_ENV_H_
 
 #ifdef __cplusplus
 extern "C" {
@@ -28,4 +28,4 @@ struct TDB_ENV {
 }
 #endif
 
-#endif /*_TD_TKV_ENV_H_*/
+#endif /*_TD_TDB_ENV_H_*/
\ No newline at end of file

source/libs/tkv/src/inc/tkvHash.h → source/libs/tdb/src/inc/tdbHash.h

@@ -16,15 +16,15 @@
 #ifndef _TD_TKV_HAHS_H_
 #define _TD_TKV_HAHS_H_
 
-#include "tkvDef.h"
+#include "tdbDef.h"
 
 #ifdef __cplusplus
 extern "C" {
 #endif
 
-typedef struct STkvHash {
+typedef struct {
   // TODO
-} STkvHash;
+} TDB_HASH;
 
 #ifdef __cplusplus
 }

source/libs/tkv/src/inc/tkvPage.h → source/libs/tdb/src/inc/tdbPage.h

@@ -17,30 +17,24 @@
 #define _TD_TKV_PAGE_H_
 
 #include "os.h"
-#include "tkvDef.h"
+#include "tdbDef.h"
 
 #ifdef __cplusplus
 extern "C" {
 #endif
 
-typedef struct STkvPage {
+typedef struct {
   pgid_t  pgid;
   int32_t pinCount;
   bool    idDirty;
   char*   pData;
-} STkvPage;
+} STdbPage;
 
 typedef struct {
   uint16_t dbver;
   uint16_t pgsize;
   uint32_t cksm;
-} STkvPgHdr;
-
-// typedef struct {
-//   SPgHdr   chdr;
-//   uint16_t used;     // number of used slots
-//   uint16_t loffset;  // the offset of the starting location of the last slot used
-// } SSlottedPgHdr;
+} STdbPgHdr;
 
 #ifdef __cplusplus
 }

source/libs/tkv/src/tkvBufPool.c → source/libs/tdb/src/tdbBufPool.c

@@ -26,7 +26,7 @@ struct SFrameIdWrapper {
 };
 
 struct STkvBufPool {
-  STkvPage*    pages;
+  STdbPage*    pages;
   STkvDiskMgr* pDiskMgr;
   SHashObj*    pgTb;  // page_id_t --> frame_id_t
   TD_SLIST(SFrameIdWrapper) freeList;

source/libs/tkv/src/tDiskMgr.c → source/libs/tdb/src/tdbDiskMgr.c

@@ -13,7 +13,7 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#include "tkvDiskMgr.h"
+#include "tdbDiskMgr.h"
 
 struct STkvDiskMgr {
   char *   fname;