make wal cleanup called once for each init

242e8246 · Liu Jicong · dc245929 · 242e8246
隐藏空白更改
内联并排

Showing with 4 addition and 1 deletion

source/libs/wal/src/walMgmt.c source/libs/wal/src/walMgmt.c +4 -1

未找到文件。
--- a/source/libs/wal/src/walMgmt.c
+++ b/source/libs/wal/src/walMgmt.c
@@ -68,9 +68,12 @@ int32_t walInit() {
 }
 void walCleanUp() {
+  int old = atomic_val_compare_exchange_8(&tsWal.inited, 1, 0);
+  if(old == 0) {
+    return;
+  }
  walStopThread();
  taosCloseRef(tsWal.refSetId);
-  atomic_store_8(&tsWal.inited, 0);
  wInfo("wal module is cleaned up");
 }