From ffc1740a00d02d941b941981b45f4f003b2b5629 Mon Sep 17 00:00:00 2001
From: liuwentan <liuwentan@geedgenetworks.com>
Date: Thu, 13 Apr 2023 18:53:36 +0800
Subject: [PATCH] fix Full config update bug
 https://jira.geedge.net/browse/TSG-14591

---
 src/inc_internal/maat_rule.h  | 2 +-
 src/maat_api.c                | 2 +-
 src/maat_compile.c            | 4 ++--
 src/maat_rule.c               | 7 +------
 src/maat_table.c              | 8 +++++++-
 test/maat_framework_gtest.cpp | 3 +--
 6 files changed, 13 insertions(+), 13 deletions(-)

diff --git a/src/inc_internal/maat_rule.h b/src/inc_internal/maat_rule.h
index b56226f..11871a4 100644
--- a/src/inc_internal/maat_rule.h
+++ b/src/inc_internal/maat_rule.h
@@ -97,7 +97,7 @@ struct maat_runtime {
     struct table_manager *ref_tbl_mgr; //share with maat instance
     size_t max_table_num;
     
-    uint32_t rule_num;
+    long long rule_num;
     struct maat_kv_store *sequence_map;
 
     struct maat_garbage_bin *ref_garbage_bin;
diff --git a/src/maat_api.c b/src/maat_api.c
index 696b1c2..e65e4d5 100644
--- a/src/maat_api.c
+++ b/src/maat_api.c
@@ -1507,7 +1507,7 @@ int maat_stream_scan(struct maat_stream *maat_stream, const char *data, int data
 
     void *expr_rt = table_manager_get_runtime(maat_instance->tbl_mgr, maat_stream->physical_table_id);
     assert(expr_rt != NULL);
-
+    
     long long cur_expr_rt_version = expr_runtime_get_version(expr_rt);
     if (maat_stream->expr_rt_version != cur_expr_rt_version) {
         return MAAT_SCAN_OK;
diff --git a/src/maat_compile.c b/src/maat_compile.c
index 33e4a17..b495999 100644
--- a/src/maat_compile.c
+++ b/src/maat_compile.c
@@ -31,10 +31,10 @@ struct compile_schema {
     int compile_id_column;
     int rule_tag_column;
     int declared_clause_num_column;
-	struct ex_data_schema ex_schema;
-    int set_flag;
     int table_id; //ugly
     char table_name[NAME_MAX];
+    int set_flag;
+    struct ex_data_schema ex_schema;
     struct table_manager *ref_tbl_mgr;
     struct log_handle *logger;
 
diff --git a/src/maat_rule.c b/src/maat_rule.c
index 21df127..e89ff39 100644
--- a/src/maat_rule.c
+++ b/src/maat_rule.c
@@ -292,12 +292,7 @@ void maat_runtime_destroy(struct maat_runtime *maat_rt)
     if (NULL == maat_rt) {
         return;
     }
-
-    if (maat_rt->ref_tbl_mgr != NULL) {
-        table_manager_runtime_destroy(maat_rt->ref_tbl_mgr);
-        maat_rt->ref_tbl_mgr = NULL;
-    }
-
+    
     if (maat_rt->sequence_map != NULL) {
         maat_kv_store_free(maat_rt->sequence_map);
         maat_rt->sequence_map = NULL;
diff --git a/src/maat_table.c b/src/maat_table.c
index be2ce07..b2c2f5d 100644
--- a/src/maat_table.c
+++ b/src/maat_table.c
@@ -441,6 +441,11 @@ void maat_table_free(struct maat_table *maat_tbl)
         maat_tbl->runtime = NULL;
     }
 
+    if (maat_tbl->updating_runtime != NULL) {
+        maat_table_runtime_free(maat_tbl->updating_runtime, maat_tbl->table_type);
+        maat_tbl->updating_runtime = NULL;
+    }
+    
     FREE(maat_tbl);
 }
 
@@ -877,6 +882,7 @@ void table_commit_updating_runtime(struct table_manager *tbl_mgr, int table_id,
 
     void *runtime = table_manager_get_runtime(tbl_mgr, table_id);
     tbl_mgr->tbl[table_id]->runtime = updating_rt;
+    
     if (runtime != NULL) {
         enum table_type *arg = ALLOC(enum table_type, 1);
         *arg = table_type;
@@ -902,7 +908,7 @@ void table_commit_runtime(struct table_manager *tbl_mgr, int table_id,
                   __FUNCTION__, __LINE__, table_id);
         return;
     }
-
+   
     struct maat_table *ptable = tbl_mgr->tbl[table_id];
     if (table_ops[table_type].commit_runtime != NULL) {
         table_ops[table_type].commit_runtime(runtime, ptable->table_name, maat_rt_version);
diff --git a/test/maat_framework_gtest.cpp b/test/maat_framework_gtest.cpp
index 3755f6b..b134474 100644
--- a/test/maat_framework_gtest.cpp
+++ b/test/maat_framework_gtest.cpp
@@ -337,7 +337,6 @@ static void random_keyword_generate(char *keyword_buf, size_t sz)
 	return;
 }
 
-#if 1
 class MaatFlagScan : public testing::Test
 {
 protected:
@@ -5555,7 +5554,7 @@ TEST_F(MaatRollbackTest, FullConfigRollback) {
     maat_state_free(state);
     state = NULL;
 }
-#endif
+
 int main(int argc, char ** argv)
 {
 	int ret=0;