Merge pull request #19869 from taosdata/FIX/TS-2533-main

enh: reset wal reader after walReadVer

Author: xiao-yu-wang

include/libs/wal/wal.h

@@ -191,6 +191,7 @@ int32_t walApplyVer(SWal *, int64_t ver);
 // read
 SWalReader *walOpenReader(SWal *, SWalFilterCond *pCond);
 void        walCloseReader(SWalReader *pRead);
+void        walReadReset(SWalReader *pReader);
 int32_t     walReadVer(SWalReader *pRead, int64_t ver);
 int32_t     walReadSeekVer(SWalReader *pRead, int64_t ver);
 int32_t     walNextValidMsg(SWalReader *pRead);

source/libs/sync/src/syncRaftLog.c

@@ -249,6 +249,7 @@ int32_t raftLogGetEntry(struct SSyncLogStore* pLogStore, SyncIndex index, SSyncR
 
   int64_t ts2 = taosGetTimestampNs();
   code = walReadVer(pWalHandle, index);
+  walReadReset(pWalHandle);
   int64_t ts3 = taosGetTimestampNs();
 
   // code = walReadVerCached(pWalHandle, index);

source/libs/wal/src/walRead.c

@@ -594,3 +594,12 @@ int32_t walReadVer(SWalReader *pReader, int64_t ver) {
 
   return 0;
 }
+
+void walReadReset(SWalReader *pReader) {
+  taosThreadMutexLock(&pReader->mutex);
+  taosCloseFile(&pReader->pIdxFile);
+  taosCloseFile(&pReader->pLogFile);
+  pReader->curInvalid = 1;
+  pReader->curFileFirstVer = -1;
+  taosThreadMutexUnlock(&pReader->mutex);
+}