From f7503a2ea9f49b35de727db9e03249b2a1b0eeb5 Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Thu, 24 Oct 2024 17:19:26 +0800
Subject: [PATCH] fix: new merge code

---
 include/os/osString.h                      |  1 -
 source/client/src/clientRawBlockWrite.c    |  2 +-
 source/client/src/clientSml.c              |  6 ++---
 source/libs/executor/src/sysscanoperator.c |  1 +
 source/os/src/osMemory.c                   | 31 ----------------------
 source/os/src/osString.c                   |  4 +--
 6 files changed, 7 insertions(+), 38 deletions(-)

diff --git a/include/os/osString.h b/include/os/osString.h
index 43d995cf0d..885b1ce93b 100644
--- a/include/os/osString.h
+++ b/include/os/osString.h
@@ -112,7 +112,6 @@ double   taosStr2Double(const char *str, char **pEnd);
 float    taosStr2Float(const char *str, char **pEnd);
 int32_t  taosHex2Ascii(const char *z, uint32_t n, void **data, uint32_t *size);
 int32_t  taosAscii2Hex(const char *z, uint32_t n, void **data, uint32_t *size);
-char    *taosStrndup(const char *s, int n);
 //int32_t  taosBin2Ascii(const char *z, uint32_t n, void** data, uint32_t* size);
 bool isHex(const char* z, uint32_t n);
 bool isValidateHex(const char* z, uint32_t n);
diff --git a/source/client/src/clientRawBlockWrite.c b/source/client/src/clientRawBlockWrite.c
index acba8117c6..0f3148b160 100644
--- a/source/client/src/clientRawBlockWrite.c
+++ b/source/client/src/clientRawBlockWrite.c
@@ -1288,7 +1288,7 @@ end:
   destroyRequest(pRequest);
   tDecoderClear(&coder);
   qDestroyQuery(pQuery);
-  taosArrayDestroyP(pTagList, taosMemoryFree);
+  taosArrayDestroyP(pTagList, NULL);
   return code;
 }
 
diff --git a/source/client/src/clientSml.c b/source/client/src/clientSml.c
index 80f583bbee..d64f390e41 100644
--- a/source/client/src/clientSml.c
+++ b/source/client/src/clientSml.c
@@ -479,7 +479,7 @@ int32_t smlParseEndLine(SSmlHandle *info, SSmlLineInfo *elements, SSmlKv *kvTs)
     }
 
     clearColValArraySml(info->currTableDataCtx->pValues);
-    taosArrayClearP(info->escapedStringList, taosMemoryFree);
+    taosArrayClearP(info->escapedStringList, NULL);
     if (unlikely(ret != TSDB_CODE_SUCCESS)) {
       smlBuildInvalidDataMsg(&info->msgBuf, "smlBuildCol error", NULL);
       return ret;
@@ -1609,7 +1609,7 @@ void smlDestroyInfo(SSmlHandle *info) {
   taosArrayDestroy(info->valueJsonArray);
 
   taosArrayDestroyEx(info->preLineTagKV, freeSSmlKv);
-  taosArrayDestroyP(info->escapedStringList, taosMemoryFree);
+  taosArrayDestroyP(info->escapedStringList, NULL);
 
   if (!info->dataFormat) {
     for (int i = 0; i < info->lineNum; i++) {
@@ -1952,7 +1952,7 @@ int32_t smlClearForRerun(SSmlHandle *info) {
     }
   }
 
-  taosArrayClearP(info->escapedStringList, taosMemoryFree);
+  taosArrayClearP(info->escapedStringList, NULL);
   (void)memset(&info->preLine, 0, sizeof(SSmlLineInfo));
   info->currSTableMeta = NULL;
   info->currTableDataCtx = NULL;
diff --git a/source/libs/executor/src/sysscanoperator.c b/source/libs/executor/src/sysscanoperator.c
index 6a3ea2ba57..b6e4018e46 100644
--- a/source/libs/executor/src/sysscanoperator.c
+++ b/source/libs/executor/src/sysscanoperator.c
@@ -2177,6 +2177,7 @@ static SSDataBlock* sysTableScanFromMNode(SOperatorInfo* pOperator, SSysTableSca
     pMsgSendInfo->fp = loadSysTableCallback;
     pMsgSendInfo->requestId = pTaskInfo->id.queryId;
 
+    void* poolHandle = NULL;
     taosSaveDisableMemoryPoolUsage(poolHandle);
     code = asyncSendMsgToServer(pInfo->readHandle.pMsgCb->clientRpc, &pInfo->epSet, NULL, pMsgSendInfo);
     taosRestoreEnableMemoryPoolUsage(poolHandle);
diff --git a/source/os/src/osMemory.c b/source/os/src/osMemory.c
index 96a35095ed..6f71c87bba 100644
--- a/source/os/src/osMemory.c
+++ b/source/os/src/osMemory.c
@@ -390,37 +390,6 @@ char *taosStrdupi(const char *ptr) {
 #endif
 }
 
-char *taosStrndupi(const char *ptr, int64_t size) {
-#ifdef USE_TD_MEMORY
-  if (ptr == NULL) return NULL;
-
-  TdMemoryInfoPtr pTdMemoryInfo = (TdMemoryInfoPtr)((char *)ptr - sizeof(TdMemoryInfo));
-  ASSERT(pTdMemoryInfo->symbol == TD_MEMORY_SYMBOL);
-  if (pTdMemoryInfo->symbol != TD_MEMORY_SYMBOL) {
-    return NULL;
-  }
-  void *tmp = tstrdup(pTdMemoryInfo);
-  if (tmp == NULL) return NULL;
-
-  memcpy(tmp, pTdMemoryInfo, sizeof(TdMemoryInfo));
-  taosBackTrace(((TdMemoryInfoPtr)tmp)->stackTrace, TD_MEMORY_STACK_TRACE_DEPTH);
-
-  return (char *)tmp + sizeof(TdMemoryInfo);
-#else
-#ifdef BUILD_WITH_RAND_ERR
-  if (tsEnableRandErr) {
-    uint32_t r = taosRand() % 10001;
-    if ((r + 1) <= tsRandErrChance) {
-      terrno = TSDB_CODE_OUT_OF_MEMORY;
-      return NULL;
-    }
-  }
-#endif
-
-  return tstrndup(ptr, size);  
-#endif
-}
-
 
 void taosMemFree(void *ptr) {
   if (NULL == ptr) return;
diff --git a/source/os/src/osString.c b/source/os/src/osString.c
index 71f6b46f79..052b951728 100644
--- a/source/os/src/osString.c
+++ b/source/os/src/osString.c
@@ -63,7 +63,7 @@ char *strsep(char **stringp, const char *delim) {
   /* NOTREACHED */
 }
 /* Duplicate a string, up to at most size characters */
-char *taosStrndup(const char *s, int size) {
+char *taosStrndupi(const char *s, int64_t size) {
   if (s == NULL) return NULL;
   size_t l;
   char  *s2;
@@ -88,7 +88,7 @@ char *stpncpy(char *dest, const char *src, int n) {
   return memset(dest, '\0', n - size);
 }
 #else
-char *taosStrndup(const char *s, int size) {
+char *taosStrndupi(const char *s, int64_t size) {
   if (s == NULL) {
     return NULL;
   }