fix(wal): deal with read context after found next valid item

src/sync/src/syncRetrieve.c

@@ -224,6 +224,8 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) {
       sError("sfd:%d, wal corrupted and skip failed crc check, code:%d", sfd, code);
       return -1;
     }
+    // found next valid item
+    if (pHead->sver != 0) return sizeof(SWalHead) + pHead->len;
   }
 
   if (pHead->len < 0 || pHead->len > WAL_MAX_SIZE - sizeof(SWalHead)) {
@@ -233,6 +235,8 @@ static int32_t syncReadOneWalRecord(int32_t sfd, SWalHead *pHead) {
       sError("sfd:%d, wal corrupted and skip failed length check, code:%d", sfd, code);
       return -1;
     }
+    // found next valid item
+    if (pHead->sver != 0) return sizeof(SWalHead) + pHead->len;
   }
 
   // read body

src/wal/src/walWrite.c

@@ -445,6 +445,8 @@ static int32_t walRestoreWalFile(SWal *pWal, void *pVnode, FWalWrite writeFp, ch
       break;
     }
 
+    bool contAlreadyRead = false;
+
     // sver == 0 is old wal format, other is new wal
     if (pHead->sver == 0 && !walValidateChecksum(pHead)) {
       wError("vgId:%d, file:%s, old wal head cksum is messed up, hver:%" PRIu64 " len:%d offset:%" PRId64, pWal->vgId, name,
@@ -454,6 +456,7 @@ static int32_t walRestoreWalFile(SWal *pWal, void *pVnode, FWalWrite writeFp, ch
         walFtruncate(pWal, tfd, offset);
         break;
       }
+      if (pHead->sver != 0) contAlreadyRead = true;
     }
 
     if ( pHead->sver == 0 && (pHead->len < 0 || pHead->len > size - sizeof(SWalHead))) {
@@ -464,8 +467,10 @@ static int32_t walRestoreWalFile(SWal *pWal, void *pVnode, FWalWrite writeFp, ch
         walFtruncate(pWal, tfd, offset);
         break;
       }
+      if (pHead->sver != 0) contAlreadyRead = true;
     }
 
+    if (!contAlreadyRead) {
       ret = (int32_t)tfRead(tfd, pHead->cont, pHead->len);
       if (ret < 0) {
         wError("vgId:%d, file:%s, failed to read wal body since %s", pWal->vgId, name, strerror(errno));
@@ -482,14 +487,15 @@ static int32_t walRestoreWalFile(SWal *pWal, void *pVnode, FWalWrite writeFp, ch
       // check new wal sum head + body crc
       if ((pHead->sver != 0) && !walValidateChecksum(pHead)) {
         // new format wal corrupted
-      wError("vgId:%d, file:%s, wal whole cksum is messed up, hver:%" PRIu64 " len:%d offset:%" PRId64, pWal->vgId, name,
-             pHead->version, pHead->len, offset);
+        wError("vgId:%d, file:%s, wal whole cksum is messed up, hver:%" PRIu64 " len:%d offset:%" PRId64, pWal->vgId,
+               name, pHead->version, pHead->len, offset);
         code = walSkipCorruptedRecord(pWal, pHead, tfd, &offset);
         if (code != TSDB_CODE_SUCCESS) {
           walFtruncate(pWal, tfd, offset);
           break;
         }
       }
+    }
 
     offset = offset + sizeof(SWalHead) + pHead->len;