diff --git a/2.0/src/query/tests/resultBufferTest.cpp b/2.0/src/query/tests/resultBufferTest.cpp index 4c523a52bf..b7173ece46 100644 --- a/2.0/src/query/tests/resultBufferTest.cpp +++ b/2.0/src/query/tests/resultBufferTest.cpp @@ -22,33 +22,33 @@ void simpleTest() { tFilePage* pBufPage = getNewDataBuf(pResultBuf, groupId, &pageId); ASSERT_TRUE(pBufPage != NULL); - ASSERT_EQ(getResBufSize(pResultBuf), 1024); + ASSERT_EQ(getTotalBufSize(pResultBuf), 1024); SIDList list = getDataBufPagesIdList(pResultBuf, groupId); ASSERT_EQ(taosArrayGetSize(list), 1); ASSERT_EQ(getNumOfResultBufGroupId(pResultBuf), 1); - releaseResBufPage(pResultBuf, pBufPage); + releaseBufPage(pResultBuf, pBufPage); tFilePage* pBufPage1 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t = getResBufPage(pResultBuf, pageId); + tFilePage* t = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t == pBufPage1); tFilePage* pBufPage2 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t1 = getResBufPage(pResultBuf, pageId); + tFilePage* t1 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t1 == pBufPage2); tFilePage* pBufPage3 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t2 = getResBufPage(pResultBuf, pageId); + tFilePage* t2 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t2 == pBufPage3); tFilePage* pBufPage4 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t3 = getResBufPage(pResultBuf, pageId); + tFilePage* t3 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t3 == pBufPage4); tFilePage* pBufPage5 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t4 = getResBufPage(pResultBuf, pageId); + tFilePage* t4 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t4 == pBufPage5); destroyResultBuf(pResultBuf); @@ -68,31 +68,31 @@ void writeDownTest() { *(int32_t*)(pBufPage->data) = nx; writePageId = pageId; - releaseResBufPage(pResultBuf, pBufPage); + releaseBufPage(pResultBuf, pBufPage); tFilePage* pBufPage1 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t1 = getResBufPage(pResultBuf, pageId); + tFilePage* t1 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t1 == pBufPage1); ASSERT_TRUE(pageId == 1); tFilePage* pBufPage2 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t2 = getResBufPage(pResultBuf, pageId); + tFilePage* t2 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t2 == pBufPage2); ASSERT_TRUE(pageId == 2); tFilePage* pBufPage3 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t3 = getResBufPage(pResultBuf, pageId); + tFilePage* t3 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t3 == pBufPage3); ASSERT_TRUE(pageId == 3); tFilePage* pBufPage4 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t4 = getResBufPage(pResultBuf, pageId); + tFilePage* t4 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t4 == pBufPage4); ASSERT_TRUE(pageId == 4); - releaseResBufPage(pResultBuf, t4); + releaseBufPage(pResultBuf, t4); // flush the written page to disk, and read it out again - tFilePage* pBufPagex = getResBufPage(pResultBuf, writePageId); + tFilePage* pBufPagex = getBufPage(pResultBuf, writePageId); ASSERT_EQ(*(int32_t*)pBufPagex->data, nx); SArray* pa = getDataBufPagesIdList(pResultBuf, groupId); @@ -112,41 +112,41 @@ void recyclePageTest() { tFilePage* pBufPage = getNewDataBuf(pResultBuf, groupId, &pageId); ASSERT_TRUE(pBufPage != NULL); - releaseResBufPage(pResultBuf, pBufPage); + releaseBufPage(pResultBuf, pBufPage); tFilePage* pBufPage1 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t1 = getResBufPage(pResultBuf, pageId); + tFilePage* t1 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t1 == pBufPage1); ASSERT_TRUE(pageId == 1); tFilePage* pBufPage2 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t2 = getResBufPage(pResultBuf, pageId); + tFilePage* t2 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t2 == pBufPage2); ASSERT_TRUE(pageId == 2); tFilePage* pBufPage3 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t3 = getResBufPage(pResultBuf, pageId); + tFilePage* t3 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t3 == pBufPage3); ASSERT_TRUE(pageId == 3); tFilePage* pBufPage4 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t4 = getResBufPage(pResultBuf, pageId); + tFilePage* t4 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t4 == pBufPage4); ASSERT_TRUE(pageId == 4); - releaseResBufPage(pResultBuf, t4); + releaseBufPage(pResultBuf, t4); tFilePage* pBufPage5 = getNewDataBuf(pResultBuf, groupId, &pageId); - tFilePage* t5 = getResBufPage(pResultBuf, pageId); + tFilePage* t5 = getBufPage(pResultBuf, pageId); ASSERT_TRUE(t5 == pBufPage5); ASSERT_TRUE(pageId == 5); // flush the written page to disk, and read it out again - tFilePage* pBufPagex = getResBufPage(pResultBuf, writePageId); + tFilePage* pBufPagex = getBufPage(pResultBuf, writePageId); *(int32_t*)(pBufPagex->data) = nx; writePageId = pageId; // update the data - releaseResBufPage(pResultBuf, pBufPagex); + releaseBufPage(pResultBuf, pBufPagex); - tFilePage* pBufPagex1 = getResBufPage(pResultBuf, 1); + tFilePage* pBufPagex1 = getBufPage(pResultBuf, 1); SArray* pa = getDataBufPagesIdList(pResultBuf, groupId); ASSERT_EQ(taosArrayGetSize(pa), 6); diff --git a/include/util/tpagedfile.h b/include/util/tpagedbuf.h similarity index 97% rename from include/util/tpagedfile.h rename to include/util/tpagedbuf.h index 9152e8685d..c8743b00e0 100644 --- a/include/util/tpagedfile.h +++ b/include/util/tpagedbuf.h @@ -13,8 +13,8 @@ * along with this program. If not, see . */ -#ifndef TDENGINE_TPAGEDFILE_H -#define TDENGINE_TPAGEDFILE_H +#ifndef TDENGINE_TPAGEDBUF_H +#define TDENGINE_TPAGEDBUF_H #ifdef __cplusplus extern "C" { @@ -146,4 +146,4 @@ void setBufPageDirty(SPageInfo* pPageInfo, bool dirty); } #endif -#endif // TDENGINE_TPAGEDFILE_H +#endif // TDENGINE_TPAGEDBUF_H diff --git a/source/client/src/clientImpl.c b/source/client/src/clientImpl.c index 609ffb57ae..b26af371f6 100644 --- a/source/client/src/clientImpl.c +++ b/source/client/src/clientImpl.c @@ -9,7 +9,7 @@ #include "tglobal.h" #include "tmsgtype.h" #include "tnote.h" -#include "tpagedfile.h" +#include "tpagedbuf.h" #include "tref.h" #define CHECK_CODE_GOTO(expr, label) \ diff --git a/source/libs/executor/inc/executil.h b/source/libs/executor/inc/executil.h index 130e46fc4c..cfb225fc51 100644 --- a/source/libs/executor/inc/executil.h +++ b/source/libs/executor/inc/executil.h @@ -16,8 +16,8 @@ #define TDENGINE_QUERYUTIL_H #include "common.h" -#include "tpagedfile.h" #include "tbuffer.h" +#include "tpagedbuf.h" #define SET_RES_WINDOW_KEY(_k, _ori, _len, _uid) \ do { \ diff --git a/source/libs/executor/inc/executorimpl.h b/source/libs/executor/inc/executorimpl.h index 3783608d97..5f5abca2f7 100644 --- a/source/libs/executor/inc/executorimpl.h +++ b/source/libs/executor/inc/executorimpl.h @@ -27,14 +27,14 @@ extern "C" { #include "dataSinkMgt.h" #include "executil.h" +#include "executor.h" #include "planner.h" #include "taosdef.h" #include "tarray.h" #include "tfilter.h" #include "thash.h" #include "tlockfree.h" -#include "tpagedfile.h" -#include "executor.h" +#include "tpagedbuf.h" struct SColumnFilterElem; diff --git a/source/libs/function/inc/tpercentile.h b/source/libs/function/inc/tpercentile.h index 33fe5ccd20..dfb52f7694 100644 --- a/source/libs/function/inc/tpercentile.h +++ b/source/libs/function/inc/tpercentile.h @@ -20,7 +20,7 @@ extern "C" { #endif -#include "tpagedfile.h" +#include "tpagedbuf.h" #include "ttszip.h" typedef struct MinMaxEntry { diff --git a/source/libs/function/src/tpercentile.c b/source/libs/function/src/tpercentile.c index e9c5518de8..40731adc58 100644 --- a/source/libs/function/src/tpercentile.c +++ b/source/libs/function/src/tpercentile.c @@ -15,10 +15,10 @@ #include #include "os.h" -#include "tpercentile.h" -#include "tpagedfile.h" #include "taosdef.h" #include "tcompare.h" +#include "tpagedbuf.h" +#include "tpercentile.h" #include "ttypes.h" #define DEFAULT_NUM_OF_SLOT 1024 diff --git a/source/util/src/tpagedfile.c b/source/util/src/tpagedbuf.c similarity index 99% rename from source/util/src/tpagedfile.c rename to source/util/src/tpagedbuf.c index 4231e99766..096c185d48 100644 --- a/source/util/src/tpagedfile.c +++ b/source/util/src/tpagedbuf.c @@ -1,8 +1,8 @@ -#include "tpagedfile.h" -#include "thash.h" +#include "tpagedbuf.h" #include "stddef.h" #include "taoserror.h" #include "tcompression.h" +#include "thash.h" #define GET_DATA_PAYLOAD(_p) ((char *)(_p)->pData + POINTER_BYTES) #define NO_IN_MEM_AVAILABLE_PAGES(_b) (listNEles((_b)->lruList) >= (_b)->inMemPages)