From bc693f374cbfe4b7ab276457f2c345b8146d2371 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Fri, 23 Dec 2022 22:42:32 +0800
Subject: [PATCH] opt index write

---
 source/libs/index/inc/indexFstFile.h | 3 ++-
 source/libs/index/src/indexFstFile.c | 6 ++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/source/libs/index/inc/indexFstFile.h b/source/libs/index/inc/indexFstFile.h
index 91c2aa6d39..d15141f79a 100644
--- a/source/libs/index/inc/indexFstFile.h
+++ b/source/libs/index/inc/indexFstFile.h
@@ -45,8 +45,9 @@ typedef struct IFileCtx {
       char      buf[256];
       int64_t   size;
 
-      char    wBuf[4096];
+      char*   wBuf;
       int32_t wBufOffset;
+      int32_t wBufCap;
 
 #ifdef USE_MMAP
       char* ptr;
diff --git a/source/libs/index/src/indexFstFile.c b/source/libs/index/src/indexFstFile.c
index 54e30ce0f4..4620af8694 100644
--- a/source/libs/index/src/indexFstFile.c
+++ b/source/libs/index/src/indexFstFile.c
@@ -40,7 +40,7 @@ static FORCE_INLINE void idxGenLRUKey(char* buf, const char* path, int32_t block
 static FORCE_INLINE int idxFileCtxDoWrite(IFileCtx* ctx, uint8_t* buf, int len) {
   int tlen = len;
   if (ctx->type == TFILE) {
-    int32_t cap = sizeof(ctx->file.wBuf);
+    int32_t cap = ctx->file.wBufCap;
     if (len + ctx->file.wBufOffset >= cap) {
       int32_t nw = cap - ctx->file.wBufOffset;
       memcpy(ctx->file.wBuf + ctx->file.wBufOffset, buf, nw);
@@ -193,8 +193,9 @@ IFileCtx* idxFileCtxCreate(WriterType type, const char* path, bool readOnly, int
       taosFtruncateFile(ctx->file.pFile, 0);
       taosStatFile(path, &ctx->file.size, NULL);
 
-      memset(ctx->file.wBuf, 0, sizeof(ctx->file.wBuf));
       ctx->file.wBufOffset = 0;
+      ctx->file.wBufCap = kBlockSize * 4;
+      ctx->file.wBuf = taosMemoryCalloc(1, ctx->file.wBufCap);
     } else {
       ctx->file.pFile = taosOpenFile(path, TD_FILE_READ);
       taosFStatFile(ctx->file.pFile, &ctx->file.size, NULL);
@@ -239,6 +240,7 @@ void idxFileCtxDestroy(IFileCtx* ctx, bool remove) {
       ctx->file.wBufOffset = 0;
     }
     ctx->flush(ctx);
+    taosMemoryFreeClear(ctx->file.wBuf);
     taosCloseFile(&ctx->file.pFile);
     if (ctx->file.readOnly) {
 #ifdef USE_MMAP