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

use delete_mark to drop check point

This commit is contained in:
liuyao 2023-04-12 13:47:54 +08:00
parent 20f7838c8f
commit 819154e1fc
1 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
source/libs/stream/src/tstreamFileState.c
View File

@ -313,16 +313,6 @@ SStreamSnapshot* getSnapshot(SStreamFileState* pFileState) {
return pFileState->usedBuffs; return pFileState->usedBuffs;
} }
// void streamFileStateDecode(SStreamFileState* pFileState, void* pBuff, int32_t len) {
// pBuff = taosDecodeFixedI64(pBuff, &pFileState->flushMark);
// }
// void streamFileStateEncode(SStreamFileState* pFileState, void** pVal, int32_t* pLen) {
// *pLen = sizeof(TSKEY);
// (*pVal) = taosMemoryCalloc(1, *pLen);
// void* buff = *pVal;
// taosEncodeFixedI64(&buff, pFileState->flushMark);
// }
void streamFileStateDecode(TSKEY* key, void* pBuff, int32_t len) { pBuff = taosDecodeFixedI64(pBuff, key); } void streamFileStateDecode(TSKEY* key, void* pBuff, int32_t len) { pBuff = taosDecodeFixedI64(pBuff, key); }
void streamFileStateEncode(TSKEY* key, void** pVal, int32_t* pLen) { void streamFileStateEncode(TSKEY* key, void** pVal, int32_t* pLen) {
@ -420,7 +410,7 @@ int32_t recoverSnapshot(SStreamFileState* pFileState) {
TSKEY ts; TSKEY ts;
sscanf(val, "%" PRId64 "", &ts); sscanf(val, "%" PRId64 "", &ts);
taosMemoryFree(val); taosMemoryFree(val);
if (ts < pFileState->flushMark) { if (ts < pFileState->deleteMark) {
forceRemoveCheckpoint(pFileState, i); forceRemoveCheckpoint(pFileState, i);
break; break;
} else { } else {