opt index write

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;

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