From 966b0179863c60476dfe7c6683ee8e4efa4d4d57 Mon Sep 17 00:00:00 2001 From: Yihao Deng Date: Tue, 23 Jul 2024 09:08:17 +0000 Subject: [PATCH] refactor index --- source/libs/index/test/fstTest.cc | 6 ++++-- source/libs/index/test/indexTests.cc | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/source/libs/index/test/fstTest.cc b/source/libs/index/test/fstTest.cc index adf783d2eb..dc0b07d9af 100644 --- a/source/libs/index/test/fstTest.cc +++ b/source/libs/index/test/fstTest.cc @@ -607,7 +607,8 @@ void validateTFile(char* arg) { // std::vector threads; SIndex* index = (SIndex*)taosMemoryCalloc(1, sizeof(SIndex)); index->path = taosStrdup(arg); - TFileReader* reader = tfileReaderOpen(index, 0, 20000000, "tag1"); + TFileReader* reader = NULL; + int32_t code = tfileReaderOpen(index, 0, 20000000, "tag1", &reader); for (int i = 0; i < NUM_OF_THREAD; i++) { threads[i] = std::thread(fst_get, reader->fst); @@ -626,7 +627,8 @@ void iterTFileReader(char* path, char* uid, char* colName, char* ver) { uint64_t suid = atoi(uid); int version = atoi(ver); - TFileReader* reader = tfileReaderOpen(NULL, suid, version, colName); + TFileReader* reader = NULL; + int32_t code = tfileReaderOpen(NULL, suid, version, colName, &reader); Iterate* iter = tfileIteratorCreate(reader); bool tn = iter ? iter->next(iter) : false; diff --git a/source/libs/index/test/indexTests.cc b/source/libs/index/test/indexTests.cc index bbd2ea6fae..1c5a04d22d 100644 --- a/source/libs/index/test/indexTests.cc +++ b/source/libs/index/test/indexTests.cc @@ -392,7 +392,7 @@ class TFileObj { IFileCtx* ctx = idxFileCtxCreate(TFILE, path.c_str(), false, 64 * 1024 * 1024); ctx->lru = taosLRUCacheInit(1024 * 1024 * 4, -1, .5); - writer_ = tfileWriterCreate(ctx, &header); + int32_t code = tfileWriterCreate(ctx, &header, &writer_); return writer_ != NULL ? true : false; } bool InitReader() {