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

add self check info

This commit is contained in:
Yihao Deng 2024-06-26 01:26:39 +00:00
parent 061648071e
commit ac351c5b58
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -4230,23 +4230,24 @@ void strArrayDebugInfo(SArray* pArr, char** buf) {
*buf = p; *buf = p;
} }
void dbChkpDebugInfo(SDbChkp* pDb) { void dbChkpDebugInfo(SDbChkp* pDb) {
// stTrace("chkp get file list: curr"); if (stDebugFlag & DEBUG_INFO) {
char* p[4] = {NULL}; char* p[4] = {NULL};
hashTableToDebug(pDb->pSstTbl[pDb->idx], &p[0]); hashTableToDebug(pDb->pSstTbl[pDb->idx], &p[0]);
stTrace("chkp previous file: [%s]", p[0]); stTrace("chkp previous file: [%s]", p[0]);
hashTableToDebug(pDb->pSstTbl[1 - pDb->idx], &p[1]); hashTableToDebug(pDb->pSstTbl[1 - pDb->idx], &p[1]);
stTrace("chkp curr file: [%s]", p[1]); stTrace("chkp curr file: [%s]", p[1]);
strArrayDebugInfo(pDb->pAdd, &p[2]); strArrayDebugInfo(pDb->pAdd, &p[2]);
stTrace("chkp newly addded file: [%s]", p[2]); stTrace("chkp newly addded file: [%s]", p[2]);
strArrayDebugInfo(pDb->pDel, &p[3]); strArrayDebugInfo(pDb->pDel, &p[3]);
stTrace("chkp newly deleted file: [%s]", p[3]); stTrace("chkp newly deleted file: [%s]", p[3]);
for (int i = 0; i < 4; i++) { for (int i = 0; i < 4; i++) {
taosMemoryFree(p[i]); taosMemoryFree(p[i]);
}
} }
} }
int32_t dbChkpGetDelta(SDbChkp* p, int64_t chkpId, SArray* list) { int32_t dbChkpGetDelta(SDbChkp* p, int64_t chkpId, SArray* list) {