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

refact more meta

This commit is contained in:
Hongze Cheng 2022-04-22 12:51:50 +00:00
parent 89c8b768e1
commit 3ed29b7b49
1 changed files with 29 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
source/dnode/vnode/src/meta/metaTable.c
View File

@ -21,6 +21,7 @@ static int metaUpdateNameIdx(SMeta *pMeta, const char *name, tb_uid_t uid);
static int metaCreateNormalTable(SMeta *pMeta, int64_t version, SMetaEntry *pME); static int metaCreateNormalTable(SMeta *pMeta, int64_t version, SMetaEntry *pME);
static int metaCreateChildTable(SMeta *pMeta, int64_t version, SMetaEntry *pME); static int metaCreateChildTable(SMeta *pMeta, int64_t version, SMetaEntry *pME);
static int metaUpdateTtlIdx(SMeta *pMeta, int64_t dtime, tb_uid_t uid); static int metaUpdateTtlIdx(SMeta *pMeta, int64_t dtime, tb_uid_t uid);
static int metaSaveToSkmDb(SMeta *pMeta, tb_uid_t uid, SSchemaWrapper *pSW);
int metaCreateSTable(SMeta *pMeta, int64_t version, SVCreateStbReq *pReq) { int metaCreateSTable(SMeta *pMeta, int64_t version, SVCreateStbReq *pReq) {
SMetaEntry me = {0}; SMetaEntry me = {0};
@ -48,7 +49,7 @@ int metaCreateSTable(SMeta *pMeta, int64_t version, SVCreateStbReq *pReq) {
if (metaSaveToTbDb(pMeta, version, &me) < 0) goto _err; if (metaSaveToTbDb(pMeta, version, &me) < 0) goto _err;
// save to schema.db (TODO) // save to schema.db (TODO)
// if (metaSaveToSkmDb(pMeta) < 0) goto _err; if (metaSaveToSkmDb(pMeta, pReq->suid, &pReq->schema) < 0) goto _err;
// update uid idx // update uid idx
if (metaUpdateUidIdx(pMeta, me.uid, version) < 0) goto _err; if (metaUpdateUidIdx(pMeta, me.uid, version) < 0) goto _err;
@ -211,6 +212,7 @@ static int metaCreateNormalTable(SMeta *pMeta, int64_t version, SMetaEntry *pME)
if (metaSaveToTbDb(pMeta, version, pME) < 0) return -1; if (metaSaveToTbDb(pMeta, version, pME) < 0) return -1;
// save to schema.db // save to schema.db
if (metaSaveToSkmDb(pMeta, pME->uid, &pME->ntbEntry.schema) < 0) return -1;
// update uid.idx // update uid.idx
if (metaUpdateUidIdx(pMeta, pME->uid, version) < 0) return -1; if (metaUpdateUidIdx(pMeta, pME->uid, version) < 0) return -1;
@ -227,3 +229,29 @@ static int metaCreateNormalTable(SMeta *pMeta, int64_t version, SMetaEntry *pME)
return 0; return 0;
} }
static int metaSaveToSkmDb(SMeta *pMeta, tb_uid_t uid, SSchemaWrapper *pSW) {
SCoder coder = {0};
void *pVal = NULL;
int vLen = 0;
int rcode = 0;
SSkmDbKey skmDbKey = {.uid = uid, .sver = pSW->sver};
// encode schema
if (tEncodeSize(tEncodeSSchemaWrapper, pSW, vLen) < 0) return -1;
pVal = TCODER_MALLOC(&coder, vLen);
if (pVal == NULL) {
rcode = -1;
terrno = TSDB_CODE_OUT_OF_MEMORY;
goto _exit;
}
if (tdbDbInsert(pMeta->pSkmDb, &skmDbKey, sizeof(skmDbKey), pVal, vLen, NULL) < 0) {
rcode = -1;
goto _exit;
}
_exit:
tCoderClear(&coder);
return 0;
}