diff --git a/source/dnode/vnode/src/inc/meta.h b/source/dnode/vnode/src/inc/meta.h index c329bc8812..c05953c67d 100644 --- a/source/dnode/vnode/src/inc/meta.h +++ b/source/dnode/vnode/src/inc/meta.h @@ -61,6 +61,7 @@ static FORCE_INLINE tb_uid_t metaGenerateUid(SMeta* pMeta) { return tGenIdPI64() // metaTable ================== int32_t metaHandleEntry2(SMeta* pMeta, const SMetaEntry* pEntry); +void metaHandleSyncEntry(SMeta* pMeta, const SMetaEntry* pEntry); // metaCache ================== int32_t metaCacheOpen(SMeta* pMeta); diff --git a/source/dnode/vnode/src/meta/metaEntry2.c b/source/dnode/vnode/src/meta/metaEntry2.c index 20744577a7..4e2c93ec2f 100644 --- a/source/dnode/vnode/src/meta/metaEntry2.c +++ b/source/dnode/vnode/src/meta/metaEntry2.c @@ -1915,3 +1915,12 @@ int32_t metaHandleEntry2(SMeta *pMeta, const SMetaEntry *pEntry) { } TAOS_RETURN(code); } + +void metaHandleSyncEntry(SMeta *pMeta, const SMetaEntry *pEntry) { + int32_t code = TSDB_CODE_SUCCESS; + code = metaHandleEntry2(pMeta, pEntry); + if (code) { + metaErr(TD_VID(pMeta->pVnode), code); + } + return; +} \ No newline at end of file diff --git a/source/dnode/vnode/src/meta/metaSnapshot.c b/source/dnode/vnode/src/meta/metaSnapshot.c index 8fe7d3823a..7374b9ceb5 100644 --- a/source/dnode/vnode/src/meta/metaSnapshot.c +++ b/source/dnode/vnode/src/meta/metaSnapshot.c @@ -197,8 +197,7 @@ int32_t metaSnapWrite(SMetaSnapWriter* pWriter, uint8_t* pData, uint32_t nData) code = metaDecodeEntry(pDecoder, &metaEntry); TSDB_CHECK_CODE(code, lino, _exit); - code = metaHandleEntry2(pMeta, &metaEntry); - TSDB_CHECK_CODE(code, lino, _exit); + metaHandleSyncEntry(pMeta, &metaEntry); _exit: if (code) {