xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

modify test case

This commit is contained in:
wangmm0220 2022-04-06 17:10:51 +08:00
parent f72c983792
commit 4bc0e507da
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
source/libs/executor/test/sortTests.cpp
View File

@ -369,16 +369,17 @@ TEST(testCase, ordered_merge_sort_Test) {
tsortSetFetchRawDataFp(phandle, getSingleColDummyBlock); tsortSetFetchRawDataFp(phandle, getSingleColDummyBlock);
tsortSetComparFp(phandle, docomp); tsortSetComparFp(phandle, docomp);
SGenericSource* p = static_cast<SGenericSource*>(taosMemoryCalloc(10, sizeof(SGenericSource))); SGenericSource* p[10] = {0};
_info* c = static_cast<_info*>(taosMemoryCalloc(10, sizeof(_info))); _info c[10] = {0};
for(int32_t i = 0; i < 10; ++i) { for(int32_t i = 0; i < 10; ++i) {
p[i] = static_cast<SGenericSource*>(taosMemoryCalloc(1, sizeof(SGenericSource)));
c[i].count = 1; c[i].count = 1;
c[i].pageRows = 1000; c[i].pageRows = 1000;
c[i].startVal = i*1000; c[i].startVal = i*1000;
c[i].type = TSDB_DATA_TYPE_INT; c[i].type = TSDB_DATA_TYPE_INT;
p[i].param = c; p[i]->param = &c[i];
tsortAddSource(phandle, &p[i]); tsortAddSource(phandle, p[i]);
} }
int32_t code = tsortOpen(phandle); int32_t code = tsortOpen(phandle);
@ -395,8 +396,9 @@ TEST(testCase, ordered_merge_sort_Test) {
ASSERT_EQ(row++, *(int32_t*) v); ASSERT_EQ(row++, *(int32_t*) v);
} }
taosMemoryFree(p); for(int32_t i = 0; i < 10; ++i) {
taosMemoryFree(c); taosMemoryFree(p[i]);
}
tsortDestroySortHandle(phandle); tsortDestroySortHandle(phandle);
blockDataDestroy(pBlock); blockDataDestroy(pBlock);
} }