From 8890f5c950e4133b6d1169c300cae1c71499e479 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 22 Sep 2023 12:51:29 +0000 Subject: [PATCH] add cvt state --- source/libs/stream/src/streamMeta.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index e516678941..2a76f178a7 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -140,7 +140,7 @@ enum STREAM_STATE_VER { STREAM_STATA_NEED_CONVERT, }; -int32_t streamMetaCheckStateCompatible(SStreamMeta* pMeta) { +int32_t streamMetaCheckBackendCompatible(SStreamMeta* pMeta) { int8_t ret = STREAM_STATA_COMPATIBLE; TBC* pCur = NULL; @@ -180,7 +180,7 @@ int32_t streamMetaCheckStateCompatible(SStreamMeta* pMeta) { return ret; } -int32_t streamMetaDoStateBackendConvertImpl(SStreamMeta* pMeta) { +int32_t streamMetaConvertBackendFormat(SStreamMeta* pMeta) { int32_t code = 0; int64_t chkpId = streamGetLatestCheckpointId(pMeta); SBackendWrapper* pBackend = streamBackendInit(pMeta->path, chkpId); @@ -201,14 +201,14 @@ _EXIT: streamBackendCleanup((void*)pBackend); return code; } -int32_t streamMetaMayDoStateBackendConvert(SStreamMeta* pMeta) { - int8_t compatible = streamMetaCheckStateCompatible(pMeta); +int32_t streamMetaMayConvertBackendFormat(SStreamMeta* pMeta) { + int8_t compatible = streamMetaCheckBackendCompatible(pMeta); if (compatible == STREAM_STATA_COMPATIBLE) { return 0; } else if (compatible == STREAM_STATA_NEED_CONVERT) { qInfo("stream state need covert backend format"); - return streamMetaDoStateBackendConvertImpl(pMeta); + return streamMetaConvertBackendFormat(pMeta); } else if (compatible == STREAM_STATA_NO_COMPATIBLE) { qError( "stream read incompatible data, rm %s/vnode/vnode*/tq/stream if taosd cannot start, and rebuild stream " @@ -250,7 +250,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF goto _err; } - if (streamMetaMayDoStateBackendConvert(pMeta) < 0) { + if (streamMetaMayConvertBackendFormat(pMeta) < 0) { goto _err; }