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

refactor(sync): reduce cache size

This commit is contained in:
Minghao Li 2022-11-17 17:19:26 +08:00
parent 9a8895ec5a
commit cf76b418f9
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/sync/src/syncRaftLog.c
View File

@ -325,15 +325,12 @@ static int32_t raftLogTruncate(struct SSyncLogStore* pLogStore, SyncIndex fromIn
// delete from cache // delete from cache
for (SyncIndex index = fromIndex; index <= wallastVer; ++index) { for (SyncIndex index = fromIndex; index <= wallastVer; ++index) {
SLRUCache* pCache = pData->pSyncNode->pLogStore->pCache; SLRUCache* pCache = pData->pSyncNode->pLogStore->pCache;
taosLRUCacheErase(pData->pSyncNode->pLogStore->pCache, &index, sizeof(index));
#if 0
LRUHandle* h = taosLRUCacheLookup(pCache, &index, sizeof(index)); LRUHandle* h = taosLRUCacheLookup(pCache, &index, sizeof(index));
if (h) { if (h) {
sNTrace(pData->pSyncNode, "cache delete index:%" PRId64, index); sNTrace(pData->pSyncNode, "cache delete index:%" PRId64, index);
taosLRUCacheRelease(pData->pSyncNode->pLogStore->pCache, h, true); taosLRUCacheRelease(pData->pSyncNode->pLogStore->pCache, h, true);
} }
#endif
} }
int32_t code = walRollback(pWal, fromIndex); int32_t code = walRollback(pWal, fromIndex);