From a8831af5136a26dbe64d1d4699bcf6373de9922c Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Thu, 12 May 2022 22:33:39 +0800
Subject: [PATCH] fix(wal): int overflow

---
 source/libs/wal/src/walRead.c | 6 +++---
 source/libs/wal/src/walSeek.c | 8 ++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/source/libs/wal/src/walRead.c b/source/libs/wal/src/walRead.c
index a0c65c8ed6..49fd5943b6 100644
--- a/source/libs/wal/src/walRead.c
+++ b/source/libs/wal/src/walRead.c
@@ -54,7 +54,7 @@ int32_t walRegisterRead(SWalReadHandle *pRead, int64_t ver) {
   return 0;
 }
 
-static int32_t walReadSeekFilePos(SWalReadHandle *pRead, int64_t fileFirstVer, int64_t ver) {
+static int64_t walReadSeekFilePos(SWalReadHandle *pRead, int64_t fileFirstVer, int64_t ver) {
   int64_t ret = 0;
 
   TdFilePtr pIdxTFile = pRead->pReadIdxTFile;
@@ -156,7 +156,7 @@ static int32_t walReadSeekVer(SWalReadHandle *pRead, int64_t ver) {
 void walSetReaderCapacity(SWalReadHandle *pRead, int32_t capacity) { pRead->capacity = capacity; }
 
 int32_t walFetchHead(SWalReadHandle *pRead, int64_t ver, SWalHead *pHead) {
-  int32_t code;
+  int64_t code;
 
   // TODO: valid ver
   if (ver > pRead->pWal->vers.commitVer) {
@@ -257,7 +257,7 @@ int32_t walReadWithHandle_s(SWalReadHandle *pRead, int64_t ver, SWalReadHead **p
 }
 
 int32_t walReadWithHandle(SWalReadHandle *pRead, int64_t ver) {
-  int code;
+  int64_t code;
   // TODO: check wal life
   if (pRead->curVersion != ver) {
     if (walReadSeekVer(pRead, ver) < 0) {
diff --git a/source/libs/wal/src/walSeek.c b/source/libs/wal/src/walSeek.c
index a6f238af6b..b99206fe98 100644
--- a/source/libs/wal/src/walSeek.c
+++ b/source/libs/wal/src/walSeek.c
@@ -19,8 +19,8 @@
 #include "tref.h"
 #include "walInt.h"
 
-static int walSeekWritePos(SWal* pWal, int64_t ver) {
-  int code = 0;
+static int64_t walSeekWritePos(SWal* pWal, int64_t ver) {
+  int64_t code = 0;
 
   TdFilePtr pIdxTFile = pWal->pWriteIdxTFile;
   TdFilePtr pLogTFile = pWal->pWriteLogTFile;
@@ -45,7 +45,7 @@ static int walSeekWritePos(SWal* pWal, int64_t ver) {
     terrno = TAOS_SYSTEM_ERROR(errno);
     return -1;
   }
-  return code;
+  return 0;
 }
 
 int walSetWrite(SWal* pWal) {
@@ -124,7 +124,7 @@ int walChangeWrite(SWal* pWal, int64_t ver) {
 }
 
 int walSeekWriteVer(SWal* pWal, int64_t ver) {
-  int code;
+  int64_t code;
   if (ver == pWal->vers.lastVer) {
     return 0;
   }