提交 249c3376 编写于 作者: H Hongze Cheng

refact TDB

上级 df319ccb
...@@ -23,26 +23,15 @@ extern "C" { ...@@ -23,26 +23,15 @@ extern "C" {
// TODO: use cmake to control the option // TODO: use cmake to control the option
#define TDB_FOR_TDENGINE #define TDB_FOR_TDENGINE
// For memory -----------------
#ifdef TDB_FOR_TDENGINE #ifdef TDB_FOR_TDENGINE
// For memory -----------------
#define tdbOsMalloc taosMemoryMalloc #define tdbOsMalloc taosMemoryMalloc
#define tdbOsCalloc taosMemoryCalloc #define tdbOsCalloc taosMemoryCalloc
#define tdbOsRealloc taosMemoryRealloc #define tdbOsRealloc taosMemoryRealloc
#define tdbOsFree taosMemoryFree #define tdbOsFree taosMemoryFree
#else
#define tdbOsMalloc malloc
#define tdbOsCalloc calloc
#define tdbOsRealloc realloc
#define tdbOsFree free
#endif
// For file and directory ----------------- // For file and directory -----------------
#ifdef TDB_FOR_TDENGINE
/* file */ /* file */
typedef TdFilePtr tdb_fd_t; typedef TdFilePtr tdb_fd_t;
...@@ -67,8 +56,33 @@ typedef TdFilePtr tdb_fd_t; ...@@ -67,8 +56,33 @@ typedef TdFilePtr tdb_fd_t;
#define tdbOsMkdir taosMkDir #define tdbOsMkdir taosMkDir
#define tdbOsRmdir taosRemoveDir #define tdbOsRmdir taosRemoveDir
// For threads and lock -----------------
/* spin lock */
typedef TdThreadSpinlock tdb_spinlock_t;
#define tdbSpinlockInit taosThreadSpinInit
#define tdbSpinlockDestroy taosThreadSpinDestroy
#define tdbSpinlockLock taosThreadSpinLock
#define tdbSpinlockUnlock taosThreadSpinUnlock
#define tdbSpinlockTrylock pthread_spin_trylock
/* mutex lock */
typedef TdThreadMutex tdb_mutex_t;
#define tdbMutexInit taosThreadMutexInit
#define tdbMutexDestroy taosThreadMutexDestroy
#define tdbMutexLock taosThreadMutexLock
#define tdbMutexUnlock taosThreadMutexUnlock
#else #else
// For memory -----------------
#define tdbOsMalloc malloc
#define tdbOsCalloc calloc
#define tdbOsRealloc realloc
#define tdbOsFree free
// For file and directory -----------------
/* file */ /* file */
typedef int tdb_fd_t; typedef int tdb_fd_t;
...@@ -95,30 +109,7 @@ i64 tdbOsWrite(tdb_fd_t fd, const void *pData, i64 nBytes); ...@@ -95,30 +109,7 @@ i64 tdbOsWrite(tdb_fd_t fd, const void *pData, i64 nBytes);
#define tdbOsMkdir mkdir #define tdbOsMkdir mkdir
#define tdbOsRmdir rmdir #define tdbOsRmdir rmdir
#endif
// For threads and lock ----------------- // For threads and lock -----------------
#ifdef TDB_FOR_TDENGINE
/* spin lock */
typedef TdThreadSpinlock tdb_spinlock_t;
#define tdbSpinlockInit taosThreadSpinInit
#define tdbSpinlockDestroy taosThreadSpinDestroy
#define tdbSpinlockLock taosThreadSpinLock
#define tdbSpinlockUnlock taosThreadSpinUnlock
#define tdbSpinlockTrylock pthread_spin_trylock
/* mutex lock */
typedef TdThreadMutex tdb_mutex_t;
#define tdbMutexInit taosThreadMutexInit
#define tdbMutexDestroy taosThreadMutexDestroy
#define tdbMutexLock taosThreadMutexLock
#define tdbMutexUnlock taosThreadMutexUnlock
#else
/* spin lock */ /* spin lock */
typedef pthread_spinlock_t tdb_spinlock_t; typedef pthread_spinlock_t tdb_spinlock_t;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册