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

fix(tsdb/cache del): remove commit w.r.t del

This commit is contained in:
Minglei Jin 2024-12-19 13:47:21 +08:00
parent ab58fdd6da
commit 8f5d5e7b59
1 changed files with 4 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
source/dnode/vnode/src/tsdb/tsdbCache.c
View File

@ -2635,24 +2635,15 @@ _exit:
} }
int32_t tsdbCacheDel(STsdb *pTsdb, tb_uid_t suid, tb_uid_t uid, TSKEY sKey, TSKEY eKey) { int32_t tsdbCacheDel(STsdb *pTsdb, tb_uid_t suid, tb_uid_t uid, TSKEY sKey, TSKEY eKey) {
int32_t code = 0, lino = 0; int32_t code = 0, lino = 0;
// fetch schema
STSchema *pTSchema = NULL; STSchema *pTSchema = NULL;
int sver = -1; int sver = -1;
int numCols = pTSchema->numOfCols;
int numKeys = 0;
SArray *remainCols = NULL;
TAOS_CHECK_RETURN(metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, suid, uid, sver, &pTSchema)); TAOS_CHECK_RETURN(metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, suid, uid, sver, &pTSchema));
// build keys & multi get from rocks
int numCols = pTSchema->numOfCols;
int numKeys = 0;
SArray *remainCols = NULL;
code = tsdbCacheCommit(pTsdb);
if (code != TSDB_CODE_SUCCESS) {
tsdbTrace("vgId:%d, %s commit failed at line %d since %s", TD_VID(pTsdb->pVnode), __func__, __LINE__,
tstrerror(code));
}
(void)taosThreadMutexLock(&pTsdb->lruMutex); (void)taosThreadMutexLock(&pTsdb->lruMutex);
for (int i = 0; i < numCols; ++i) { for (int i = 0; i < numCols; ++i) {