add some read del data code
This commit is contained in:
parent
f6cd94d781
commit
b8899c82fe
|
@ -345,8 +345,14 @@ int32_t tsdbReadDelData(SDelFReader *pReader, SDelIdx *pDelIdx, SArray *aDelData
|
||||||
ASSERT(pHdr->suid == pDelIdx->suid);
|
ASSERT(pHdr->suid == pDelIdx->suid);
|
||||||
ASSERT(pHdr->uid == pDelIdx->uid);
|
ASSERT(pHdr->uid == pDelIdx->uid);
|
||||||
n += sizeof(*pHdr);
|
n += sizeof(*pHdr);
|
||||||
|
taosArrayClear(aDelData);
|
||||||
while (n < size - sizeof(TSCKSUM)) {
|
while (n < size - sizeof(TSCKSUM)) {
|
||||||
n += tGetDelData(*ppBuf + n, pDelData);
|
n += tGetDelData(*ppBuf + n, pDelData);
|
||||||
|
|
||||||
|
if (taosArrayPush(aDelData, pDelData) == NULL) {
|
||||||
|
code = TSDB_CODE_OUT_OF_MEMORY;
|
||||||
|
goto _err;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
ASSERT(n == size - sizeof(TSCKSUM));
|
ASSERT(n == size - sizeof(TSCKSUM));
|
||||||
|
|
Loading…
Reference in New Issue