diff --git a/src/inc/tsdb.h b/src/inc/tsdb.h index 85f9b3bdc7f1cf806309f597ffad6955151b4c36..f7bab2fd733a4828bf9c11ffcf789286546618b2 100644 --- a/src/inc/tsdb.h +++ b/src/inc/tsdb.h @@ -314,6 +314,14 @@ void tsdbCleanupQueryHandle(TsdbQueryHandleT queryHandle); */ void tsdbReportStat(void *repo, int64_t *totalPoints, int64_t *totalStorage, int64_t *compStorage); +// ------------------ tsdbScan.c +typedef void *STsdbScanH; + +STsdbScanH tsdbNewScanHandle(); +void tsdbFreeScanHandle(STsdbScanH pScanH); +void tsdbSetScanLogStream(STsdbScanH pScanH, FILE *fLogStream); +int tsdbScanFGroup(STsdbScanH pScanH, char *rootDir, int fid); + #ifdef __cplusplus } #endif diff --git a/src/tsdb/inc/tsdbMain.h b/src/tsdb/inc/tsdbMain.h index 256b8189f8fc69345b27fdf702fb705d22ac3c10..aa4ffabd0e77b502a662930b3c7c098701c016ef 100644 --- a/src/tsdb/inc/tsdbMain.h +++ b/src/tsdb/inc/tsdbMain.h @@ -562,16 +562,6 @@ STsdbMeta* tsdbGetMeta(TSDB_REPO_T* pRepo); STsdbFileH* tsdbGetFile(TSDB_REPO_T* pRepo); int tsdbCheckCommit(STsdbRepo* pRepo); -// ------------------ tsdbScan.c -int tsdbScanFGroup(STsdbScanHandle* pScanHandle, char* rootDir, int fid); -STsdbScanHandle* tsdbNewScanHandle(); -void tsdbSetScanLogStream(STsdbScanHandle* pScanHandle, FILE* fLogStream); -int tsdbSetAndOpenScanFile(STsdbScanHandle* pScanHandle, char* rootDir, int fid); -int tsdbScanSCompIdx(STsdbScanHandle* pScanHandle); -int tsdbScanSCompBlock(STsdbScanHandle* pScanHandle, int idx); -int tsdbCloseScanFile(STsdbScanHandle* pScanHandle); -void tsdbFreeScanHandle(STsdbScanHandle* pScanHandle); - #ifdef __cplusplus } #endif diff --git a/src/tsdb/src/tsdbScan.c b/src/tsdb/src/tsdbScan.c index 91f67878740c90d56a8c5c124be23c1f53e7da40..0f0d4bf52922d7a57b4cf3a8fbd49817a9ad843e 100644 --- a/src/tsdb/src/tsdbScan.c +++ b/src/tsdb/src/tsdbScan.c @@ -17,20 +17,9 @@ #ifndef _TSDB_PLUGINS -int tsdbScanFGroup(STsdbScanHandle* pScanHandle, char* rootDir, int fid) { return 0; } - -STsdbScanHandle* tsdbNewScanHandle() { return NULL; } - -void tsdbSetScanLogStream(STsdbScanHandle* pScanHandle, FILE* fLogStream) {} - -int tsdbSetAndOpenScanFile(STsdbScanHandle* pScanHandle, char* rootDir, int fid) { return 0; } - -int tsdbScanSCompIdx(STsdbScanHandle* pScanHandle) { return 0; } - -int tsdbScanSCompBlock(STsdbScanHandle* pScanHandle, int idx) { return 0; } - -int tsdbCloseScanFile(STsdbScanHandle* pScanHandle) { return 0; } - -void tsdbFreeScanHandle(STsdbScanHandle* pScanHandle) {} +STsdbScanH tsdbNewScanHandle() { return NULL; } +void tsdbFreeScanHandle(STsdbScanH pScanHandle) {} +void tsdbSetScanLogStream(STsdbScanH pScanHandle, FILE *fLogStream) { return; } +int tsdbScanFGroup(STsdbScanH pScanHandle, char *rootDir, int fid) { return 0; } #endif \ No newline at end of file