From e2371f9d911ca7ab96fb14896bb7408a0e047f1d Mon Sep 17 00:00:00 2001 From: Minglei Jin Date: Wed, 17 Jul 2024 14:52:42 +0800 Subject: [PATCH] remove unused internal api: walSeekWriteVer --- source/libs/wal/inc/walInt.h | 1 - source/libs/wal/src/walSeek.c | 57 ----------------------------------- 2 files changed, 58 deletions(-) diff --git a/source/libs/wal/inc/walInt.h b/source/libs/wal/inc/walInt.h index 6dc9922981..fa1e0c203b 100644 --- a/source/libs/wal/inc/walInt.h +++ b/source/libs/wal/inc/walInt.h @@ -163,7 +163,6 @@ int walInitWriteFile(SWal* pWal); // seek section end int64_t walGetSeq(); -int walSeekWriteVer(SWal* pWal, int64_t ver); int32_t walRollImpl(SWal* pWal); #ifdef __cplusplus diff --git a/source/libs/wal/src/walSeek.c b/source/libs/wal/src/walSeek.c index 0e452a937b..57fe8d5c19 100644 --- a/source/libs/wal/src/walSeek.c +++ b/source/libs/wal/src/walSeek.c @@ -19,36 +19,6 @@ #include "tref.h" #include "walInt.h" -#if 0 -static int64_t walSeekWritePos(SWal* pWal, int64_t ver) { - int64_t code = 0; - - TdFilePtr pIdxTFile = pWal->pIdxFile; - TdFilePtr pLogTFile = pWal->pLogFile; - - // seek position - int64_t idxOff = walGetVerIdxOffset(pWal, ver); - code = taosLSeekFile(pIdxTFile, idxOff, SEEK_SET); - if (code != 0) { - terrno = TAOS_SYSTEM_ERROR(errno); - return -1; - } - SWalIdxEntry entry; - // TODO:deserialize - code = taosReadFile(pIdxTFile, &entry, sizeof(SWalIdxEntry)); - if (code != 0) { - terrno = TAOS_SYSTEM_ERROR(errno); - return -1; - } - code = taosLSeekFile(pLogTFile, entry.offset, SEEK_SET); - if (code < 0) { - terrno = TAOS_SYSTEM_ERROR(errno); - return -1; - } - return 0; -} -#endif - int walInitWriteFile(SWal* pWal) { TdFilePtr pIdxTFile, pLogTFile; SWalFileInfo* pRet = taosArrayGetLast(pWal->fileInfoSet); @@ -130,30 +100,3 @@ int64_t walChangeWrite(SWal* pWal, int64_t ver) { pWal->writeCur = idx; return fileFirstVer; } - -#if 0 -int walSeekWriteVer(SWal* pWal, int64_t ver) { - int64_t code; - if (ver == pWal->vers.lastVer) { - return 0; - } - if (ver > pWal->vers.lastVer || ver < pWal->vers.firstVer) { - terrno = TSDB_CODE_WAL_INVALID_VER; - return -1; - } - if (ver < pWal->vers.snapshotVer) { - } - if (ver < walGetCurFileFirstVer(pWal) || (ver > walGetCurFileLastVer(pWal))) { - code = walChangeWrite(pWal, ver); - if (code != 0) { - return -1; - } - } - code = walSeekWritePos(pWal, ver); - if (code != 0) { - return -1; - } - - return 0; -} -#endif