提交 895607f0 编写于 作者: H Hongze Cheng

refact

上级 7f5eaf9e
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_BUFFER_H_ #ifndef _TD_TSDB_BUFFER_H_
#define _TD_TSDB_BUFFER_H_ #define _TD_TSDB_BUFFER_H_
#ifdef __cplusplus
extern "C" {
#endif
typedef struct { typedef struct {
int64_t blockId; int64_t blockId;
int offset; int offset;
...@@ -44,8 +40,4 @@ int tsdbOpenBufPool(STsdbRepo* pRepo); ...@@ -44,8 +40,4 @@ int tsdbOpenBufPool(STsdbRepo* pRepo);
void tsdbCloseBufPool(STsdbRepo* pRepo); void tsdbCloseBufPool(STsdbRepo* pRepo);
SListNode* tsdbAllocBufBlockFromPool(STsdbRepo* pRepo); SListNode* tsdbAllocBufBlockFromPool(STsdbRepo* pRepo);
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_BUFFER_H_ */ #endif /* _TD_TSDB_BUFFER_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_COMMIT_H_ #ifndef _TD_TSDB_COMMIT_H_
#define _TD_TSDB_COMMIT_H_ #define _TD_TSDB_COMMIT_H_
#ifdef __cplusplus
extern "C" {
#endif
typedef struct { typedef struct {
int minFid; int minFid;
int midFid; int midFid;
...@@ -50,8 +46,4 @@ static FORCE_INLINE int tsdbGetFidLevel(int fid, SRtn *pRtn) { ...@@ -50,8 +46,4 @@ static FORCE_INLINE int tsdbGetFidLevel(int fid, SRtn *pRtn) {
} }
} }
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_COMMIT_H_ */ #endif /* _TD_TSDB_COMMIT_H_ */
\ No newline at end of file
...@@ -16,14 +16,6 @@ ...@@ -16,14 +16,6 @@
#ifndef _TD_TSDB_COMMIT_QUEUE_H_ #ifndef _TD_TSDB_COMMIT_QUEUE_H_
#define _TD_TSDB_COMMIT_QUEUE_H_ #define _TD_TSDB_COMMIT_QUEUE_H_
#ifdef __cplusplus
extern "C" {
#endif
int tsdbScheduleCommit(STsdbRepo *pRepo); int tsdbScheduleCommit(STsdbRepo *pRepo);
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_COMMIT_QUEUE_H_ */ #endif /* _TD_TSDB_COMMIT_QUEUE_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_FS_H_ #ifndef _TD_TSDB_FS_H_
#define _TD_TSDB_FS_H_ #define _TD_TSDB_FS_H_
#ifdef __cplusplus
extern "C" {
#endif
#define TSDB_FS_VERSION 0 #define TSDB_FS_VERSION 0
// ================== CURRENT file header info // ================== CURRENT file header info
...@@ -112,8 +108,4 @@ static FORCE_INLINE int tsdbUnLockFS(STsdbFS* pFs) { ...@@ -112,8 +108,4 @@ static FORCE_INLINE int tsdbUnLockFS(STsdbFS* pFs) {
return 0; return 0;
} }
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_FS_H_ */ #endif /* _TD_TSDB_FS_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TS_TSDB_FILE_H_ #ifndef _TS_TSDB_FILE_H_
#define _TS_TSDB_FILE_H_ #define _TS_TSDB_FILE_H_
#ifdef __cplusplus
extern "C" {
#endif
#define TSDB_FILE_HEAD_SIZE 512 #define TSDB_FILE_HEAD_SIZE 512
#define TSDB_FILE_DELIMITER 0xF00AFA0F #define TSDB_FILE_DELIMITER 0xF00AFA0F
#define TSDB_FILE_INIT_MAGIC 0xFFFFFFFF #define TSDB_FILE_INIT_MAGIC 0xFFFFFFFF
...@@ -350,8 +346,4 @@ static FORCE_INLINE void tsdbGetFidKeyRange(int days, int8_t precision, int fid, ...@@ -350,8 +346,4 @@ static FORCE_INLINE void tsdbGetFidKeyRange(int days, int8_t precision, int fid,
*maxKey = *minKey + days * tsMsPerDay[precision] - 1; *maxKey = *minKey + days * tsMsPerDay[precision] - 1;
} }
#ifdef __cplusplus
}
#endif
#endif /* _TS_TSDB_FILE_H_ */ #endif /* _TS_TSDB_FILE_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_LOG_H_ #ifndef _TD_TSDB_LOG_H_
#define _TD_TSDB_LOG_H_ #define _TD_TSDB_LOG_H_
#ifdef __cplusplus
extern "C" {
#endif
extern int32_t tsdbDebugFlag; extern int32_t tsdbDebugFlag;
#define tsdbFatal(...) do { if (tsdbDebugFlag & DEBUG_FATAL) { taosPrintLog("TDB FATAL ", 255, __VA_ARGS__); }} while(0) #define tsdbFatal(...) do { if (tsdbDebugFlag & DEBUG_FATAL) { taosPrintLog("TDB FATAL ", 255, __VA_ARGS__); }} while(0)
...@@ -29,8 +25,4 @@ extern int32_t tsdbDebugFlag; ...@@ -29,8 +25,4 @@ extern int32_t tsdbDebugFlag;
#define tsdbDebug(...) do { if (tsdbDebugFlag & DEBUG_DEBUG) { taosPrintLog("TDB ", tsdbDebugFlag, __VA_ARGS__); }} while(0) #define tsdbDebug(...) do { if (tsdbDebugFlag & DEBUG_DEBUG) { taosPrintLog("TDB ", tsdbDebugFlag, __VA_ARGS__); }} while(0)
#define tsdbTrace(...) do { if (tsdbDebugFlag & DEBUG_TRACE) { taosPrintLog("TDB ", tsdbDebugFlag, __VA_ARGS__); }} while(0) #define tsdbTrace(...) do { if (tsdbDebugFlag & DEBUG_TRACE) { taosPrintLog("TDB ", tsdbDebugFlag, __VA_ARGS__); }} while(0)
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_LOG_H_ */ #endif /* _TD_TSDB_LOG_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_MEMTABLE_H_ #ifndef _TD_TSDB_MEMTABLE_H_
#define _TD_TSDB_MEMTABLE_H_ #define _TD_TSDB_MEMTABLE_H_
#ifdef __cplusplus
extern "C" {
#endif
typedef struct { typedef struct {
int rowsInserted; int rowsInserted;
int rowsUpdated; int rowsUpdated;
...@@ -111,9 +107,4 @@ static FORCE_INLINE TKEY tsdbNextIterTKey(SSkipListIterator* pIter) { ...@@ -111,9 +107,4 @@ static FORCE_INLINE TKEY tsdbNextIterTKey(SSkipListIterator* pIter) {
return dataRowTKey(row); return dataRowTKey(row);
} }
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_MEMTABLE_H_ */ #endif /* _TD_TSDB_MEMTABLE_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_META_H_ #ifndef _TD_TSDB_META_H_
#define _TD_TSDB_META_H_ #define _TD_TSDB_META_H_
#ifdef __cplusplus
extern "C" {
#endif
#define TSDB_MAX_TABLE_SCHEMAS 16 #define TSDB_MAX_TABLE_SCHEMAS 16
typedef struct STable { typedef struct STable {
...@@ -145,8 +141,4 @@ static FORCE_INLINE TSKEY tsdbGetTableLastKeyImpl(STable* pTable) { ...@@ -145,8 +141,4 @@ static FORCE_INLINE TSKEY tsdbGetTableLastKeyImpl(STable* pTable) {
return pTable->lastKey; return pTable->lastKey;
} }
#ifdef __cplusplus
}
#endif
#endif /* _TD_TSDB_META_H_ */ #endif /* _TD_TSDB_META_H_ */
\ No newline at end of file
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
#ifndef _TD_TSDB_READ_IMPL_H_ #ifndef _TD_TSDB_READ_IMPL_H_
#define _TD_TSDB_READ_IMPL_H_ #define _TD_TSDB_READ_IMPL_H_
#ifdef __cplusplus
extern "C" {
#endif
typedef struct SReadH SReadH; typedef struct SReadH SReadH;
typedef struct { typedef struct {
...@@ -134,8 +130,4 @@ static FORCE_INLINE int tsdbMakeRoom(void **ppBuf, size_t size) { ...@@ -134,8 +130,4 @@ static FORCE_INLINE int tsdbMakeRoom(void **ppBuf, size_t size) {
return 0; return 0;
} }
#ifdef __cplusplus
}
#endif
#endif /*_TD_TSDB_READ_IMPL_H_*/ #endif /*_TD_TSDB_READ_IMPL_H_*/
\ No newline at end of file
...@@ -16,15 +16,15 @@ ...@@ -16,15 +16,15 @@
#ifndef _TD_TSDB_INT_H_ #ifndef _TD_TSDB_INT_H_
#define _TD_TSDB_INT_H_ #define _TD_TSDB_INT_H_
// TODO: remove the include // // TODO: remove the include
#include <errno.h> // #include <errno.h>
#include <fcntl.h> // #include <fcntl.h>
#include <limits.h> // #include <limits.h>
#include <inttypes.h> // #include <inttypes.h>
#include <sys/stat.h> // #include <sys/stat.h>
#include <sys/types.h> // #include <sys/types.h>
#include <semaphore.h> // #include <semaphore.h>
#include <dirent.h> // #include <dirent.h>
#include "os.h" #include "os.h"
#include "tlog.h" #include "tlog.h"
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册