From c7602a4c1a11b45c8f8f0124900c1e83a3652f4e Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Thu, 11 May 2023 01:19:40 +0000
Subject: [PATCH] refactor code

---
 source/libs/stream/src/streamBackendRocksdb.c |  1 -
 source/libs/stream/test/CMakeLists.txt        |  2 +-
 source/libs/stream/test/tstreamUpdateTest.cpp | 30 +++++++++++++++----
 3 files changed, 26 insertions(+), 7 deletions(-)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 70aeed3cdd..e1c030b5c5 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -695,7 +695,6 @@ int32_t streamStateOpenBackendCf(void* backend, char* name, SHashObj* ids) {
       memcpy(cfNames[0], "default", strlen("default"));
       continue;
     }
-    qDebug("cf name %s", idstr);
 
     GEN_COLUMN_FAMILY_NAME(cfNames[i], idstr, ginitDict[(i - 1) % (cfLen)].key);
     if (i % cfLen == 0) {
diff --git a/source/libs/stream/test/CMakeLists.txt b/source/libs/stream/test/CMakeLists.txt
index 5a97ba45f6..a0c1717690 100644
--- a/source/libs/stream/test/CMakeLists.txt
+++ b/source/libs/stream/test/CMakeLists.txt
@@ -10,7 +10,7 @@ ADD_EXECUTABLE(streamUpdateTest "tstreamUpdateTest.cpp")
 
 TARGET_LINK_LIBRARIES(
   streamUpdateTest
-  PUBLIC os util common gtest stream
+  PUBLIC os util common gtest gtest_main stream
 )
 
 TARGET_INCLUDE_DIRECTORIES(
diff --git a/source/libs/stream/test/tstreamUpdateTest.cpp b/source/libs/stream/test/tstreamUpdateTest.cpp
index c698187874..d34e70b734 100644
--- a/source/libs/stream/test/tstreamUpdateTest.cpp
+++ b/source/libs/stream/test/tstreamUpdateTest.cpp
@@ -6,6 +6,25 @@
 using namespace std;
 #define MAX_NUM_SCALABLE_BF 100000
 
+class StreamStateEnv : public ::testing::Test {
+ protected:
+  virtual void SetUp() {
+    // initLog();
+    //  taosRemoveDir(path);
+    //  SIndexOpts opts;
+    //  opts.cacheSize = 1024 * 1024 * 4;
+    //  int ret = indexOpen(&opts, path, &index);
+    //  assert(ret == 0);
+  }
+  virtual void TearDown() {
+    // indexClose(index);
+  }
+
+  const char *path = TD_TMP_DIR_PATH "stream";
+  // SIndexOpts* opts;
+  // SIndex*     index;
+};
+
 bool equalSBF(SScalableBf *left, SScalableBf *right) {
   if (left->growth != right->growth) return false;
   if (left->numBits != right->numBits) return false;
@@ -191,8 +210,9 @@ TEST(TD_STREAM_UPDATE_TEST, update) {
   // updateInfoDestroy(pSU6);
   // updateInfoDestroy(pSU7);
 }
-
-int main(int argc, char *argv[]) {
-  testing::InitGoogleTest(&argc, argv);
-  return RUN_ALL_TESTS();
-}
\ No newline at end of file
+// TEST()
+TEST_F(StreamStateEnv, test1) {}
+// int main(int argc, char *argv[]) {
+//   testing::InitGoogleTest(&argc, argv);
+//   return RUN_ALL_TESTS();
+// }
\ No newline at end of file
-- 
GitLab