(iotdb) branch master updated: Feature/cppclient asan (#16293)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new ea195168a95 Feature/cppclient asan (#16293)
ea195168a95 is described below

commit ea195168a958edd8e6ae17437119c06aa724d423
Author: Hongzhi Gao <761417...@qq.com>
AuthorDate: Thu Aug 28 18:27:38 2025 +0800

    Feature/cppclient asan (#16293)
    
    * implement client-cpp memory check(asan)
    
    * fix ubuntu compilation
    
    * fix compilation error
    
    * fix memory leak
    
    * fix conpilation error on moacos
---
 iotdb-client/client-cpp/src/main/CMakeLists.txt    |  5 +++++
 iotdb-client/client-cpp/src/test/CMakeLists.txt    |  5 +++++
 iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 16 ++++++++--------
 3 files changed, 18 insertions(+), 8 deletions(-)

diff --git a/iotdb-client/client-cpp/src/main/CMakeLists.txt 
b/iotdb-client/client-cpp/src/main/CMakeLists.txt
index c6924060ba9..5cf503c4efc 100644
--- a/iotdb-client/client-cpp/src/main/CMakeLists.txt
+++ b/iotdb-client/client-cpp/src/main/CMakeLists.txt
@@ -41,6 +41,11 @@ ELSE()
     SET(THRIFT_STATIC_LIB "${CMAKE_SOURCE_DIR}/../../thrift/lib/libthrift.a")
 ENDIF()
 
+IF(CMAKE_CXX_COMPILER_ID MATCHES "GNU|Clang" AND NOT MSVC)
+    add_compile_options(-fsanitize=address -fno-omit-frame-pointer)
+    add_link_options(-fsanitize=address)
+ENDIF()
+
 # Add the generated source files to the sources for the library.
 AUX_SOURCE_DIRECTORY(./generated-sources-cpp SESSION_SRCS)
 IF(MSVC)
diff --git a/iotdb-client/client-cpp/src/test/CMakeLists.txt 
b/iotdb-client/client-cpp/src/test/CMakeLists.txt
index 186c08b634d..61fade6bf5c 100644
--- a/iotdb-client/client-cpp/src/test/CMakeLists.txt
+++ b/iotdb-client/client-cpp/src/test/CMakeLists.txt
@@ -47,6 +47,11 @@ ELSE()
     SET(THRIFT_STATIC_LIB "${CMAKE_SOURCE_DIR}/../../thrift/lib/libthrift.a")
 ENDIF()
 
+IF(CMAKE_CXX_COMPILER_ID MATCHES "GNU|Clang" AND NOT MSVC)
+    add_compile_options(-fsanitize=address -fno-omit-frame-pointer)
+    add_link_options(-fsanitize=address)
+ENDIF()
+
 ADD_EXECUTABLE(${TARGET_NAME} main.cpp cpp/sessionIT.cpp)
 ADD_EXECUTABLE(${TARGET_NAME_RELATIONAL} main_Relational.cpp 
cpp/sessionRelationalIT.cpp)
 
diff --git a/iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp 
b/iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp
index 18ccb2a8393..d08e0c3fbb0 100644
--- a/iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp
+++ b/iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp
@@ -141,7 +141,8 @@ TEST_CASE("Test insertRecord by string", 
"[testInsertRecord]") {
     while (sessionDataSet->hasNext()) {
         long index = 1;
         count++;
-        for (const Field &f: sessionDataSet->next()->fields) {
+        auto fields = sessionDataSet->next()->fields;
+        for (const Field &f: fields) {
             REQUIRE(f.longV.value() == index);
             index++;
         }
@@ -186,7 +187,8 @@ TEST_CASE("Test insertRecords ", "[testInsertRecords]") {
     while (sessionDataSet->hasNext()) {
         long index = 1;
         count++;
-        for (const Field &f: sessionDataSet->next()->fields) {
+        auto fields = sessionDataSet->next()->fields;
+        for (const Field &f: fields) {
             REQUIRE(f.longV.value() == index);
             index++;
         }
@@ -386,7 +388,8 @@ TEST_CASE("Test insertTablet ", "[testInsertTablet]") {
     while (sessionDataSet->hasNext()) {
         long index = 0;
         count++;
-        for (const Field& f: sessionDataSet->next()->fields) {
+        auto fields = sessionDataSet->next()->fields;
+        for (const Field &f: fields) {
             REQUIRE(f.longV.value() == index);
             index++;
         }
@@ -436,7 +439,8 @@ TEST_CASE("Test insertTablets ", "[testInsertTablets]") {
     while (sessionDataSet->hasNext()) {
         long index = 0;
         count++;
-        for (const Field& f: sessionDataSet->next()->fields) {
+        auto fields = sessionDataSet->next()->fields;
+        for (const Field &f: fields) {
             REQUIRE(f.longV.value() == index);
             index++;
         }
@@ -614,10 +618,6 @@ TEST_CASE("Test executeRawDataQuery ", 
"[executeRawDataQuery]") {
     sessionDataSet->setFetchSize(10);
     vector<string> columns = sessionDataSet->getColumnNames();
     columns = sessionDataSet->getColumnNames();
-    for (const string &column : columns) {
-        cout << column << " " ;
-    }
-    cout << endl;
     REQUIRE(columns[0] == "Time");
     REQUIRE(columns[1] == paths[0]);
     REQUIRE(columns[2] == paths[1]);