[td-225] refactor codes.
This commit is contained in:
parent
398c3e7988
commit
f722d06abe
|
@ -47,7 +47,7 @@ void simpleTest() {
|
||||||
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
||||||
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
||||||
|
|
||||||
tsBufDestory(pTSBuf);
|
tsBufDestroy(pTSBuf);
|
||||||
}
|
}
|
||||||
|
|
||||||
// one large list of ts, the ts list need to be split into several small blocks
|
// one large list of ts, the ts list need to be split into several small blocks
|
||||||
|
@ -71,7 +71,7 @@ void largeTSTest() {
|
||||||
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
||||||
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
||||||
|
|
||||||
tsBufDestory(pTSBuf);
|
tsBufDestroy(pTSBuf);
|
||||||
}
|
}
|
||||||
|
|
||||||
void multiTagsTest() {
|
void multiTagsTest() {
|
||||||
|
@ -101,7 +101,7 @@ void multiTagsTest() {
|
||||||
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
||||||
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
||||||
|
|
||||||
tsBufDestory(pTSBuf);
|
tsBufDestroy(pTSBuf);
|
||||||
}
|
}
|
||||||
|
|
||||||
void multiVnodeTagsTest() {
|
void multiVnodeTagsTest() {
|
||||||
|
@ -139,7 +139,7 @@ void multiVnodeTagsTest() {
|
||||||
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
EXPECT_EQ(pTSBuf->tsData.len, 0);
|
||||||
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
EXPECT_EQ(pTSBuf->block.numOfElem, num);
|
||||||
|
|
||||||
tsBufDestory(pTSBuf);
|
tsBufDestroy(pTSBuf);
|
||||||
}
|
}
|
||||||
|
|
||||||
void loadDataTest() {
|
void loadDataTest() {
|
||||||
|
@ -386,8 +386,8 @@ void mergeDiffVnodeBufferTest() {
|
||||||
|
|
||||||
tsBufDisplay(pTSBuf1);
|
tsBufDisplay(pTSBuf1);
|
||||||
|
|
||||||
tsBufDestory(pTSBuf2);
|
tsBufDestroy(pTSBuf2);
|
||||||
tsBufDestory(pTSBuf1);
|
tsBufDestroy(pTSBuf1);
|
||||||
}
|
}
|
||||||
|
|
||||||
void mergeIdenticalVnodeBufferTest() {
|
void mergeIdenticalVnodeBufferTest() {
|
||||||
|
@ -432,8 +432,8 @@ void mergeIdenticalVnodeBufferTest() {
|
||||||
printf("%d-%" PRIu64 "-%" PRIu64 "\n", elem.vnode, elem.tag, elem.ts);
|
printf("%d-%" PRIu64 "-%" PRIu64 "\n", elem.vnode, elem.tag, elem.ts);
|
||||||
}
|
}
|
||||||
|
|
||||||
tsBufDestory(pTSBuf1);
|
tsBufDestroy(pTSBuf1);
|
||||||
tsBufDestory(pTSBuf2);
|
tsBufDestroy(pTSBuf2);
|
||||||
}
|
}
|
||||||
} // namespace
|
} // namespace
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue