gfwleak/tango-maat
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

IP Plugin更新后重置计数器。

Browse Source
This commit is contained in:
zhengchao
2020-08-20 10:37:55 +08:00
parent a44e14f82d
commit 3791c9426e
1 changed files with 20 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/entry/Maat_rule.cpp
View File

@@ -2023,6 +2023,7 @@ void update_compile_rule(struct Maat_table_schema* table,const char* table_line
assert(ret==0); assert(ret==0);
table_rt->origin_rule_num--; table_rt->origin_rule_num--;
Maat_garbage_bagging(scanner->ref_garbage_bin, p_compile, (void (*)(void*))destroy_compile_rule); Maat_garbage_bagging(scanner->ref_garbage_bin, p_compile, (void (*)(void*))destroy_compile_rule);
scanner->to_update_compile_cnt++;
} }
else else
{ {
@@ -2036,6 +2037,7 @@ void update_compile_rule(struct Maat_table_schema* table,const char* table_line
if(ret==0) if(ret==0)
{ {
table_rt->origin_rule_num++; table_rt->origin_rule_num++;
scanner->to_update_compile_cnt++;
} }
else else
{ {
@@ -2048,6 +2050,7 @@ void update_compile_rule(struct Maat_table_schema* table,const char* table_line
table->udpate_err_cnt++; table->udpate_err_cnt++;
} }
} }
return; return;
} }
@@ -2228,13 +2231,14 @@ void do_scanner_update(struct Maat_scanner* scanner, int scan_thread_num, void*
struct ip_matcher* old_ip_matcher=NULL; struct ip_matcher* old_ip_matcher=NULL;
int i=0, ret=0; int i=0, ret=0;
if(scanner->to_update_compile_cnt+scanner->to_update_group_cnt>0)
{
ret=Maat_hierarchy_rebuild(scanner->hier); ret=Maat_hierarchy_rebuild(scanner->hier);
if(ret!=0) if(ret!=0)
{ {
MESA_handle_runtime_log(logger, RLOG_LV_FATAL, maat_module , MESA_handle_runtime_log(logger, RLOG_LV_FATAL, maat_module ,
"Version %d hierarchy rebuild failed.", "Version %d hierarchy rebuild failed.",
scanner->version); scanner->version);
return;
} }
else else
{ {
@@ -2243,12 +2247,13 @@ void do_scanner_update(struct Maat_scanner* scanner, int scan_thread_num, void*
scanner->version, scanner->version,
scanner->dedup_expr_num); scanner->dedup_expr_num);
} }
}
scanner->dedup_expr_num=0; scanner->dedup_expr_num=0;
rulescan_batch_update(scanner->region, rulescan_batch_update(scanner->region,
scanner->region_update_q, scanner->region_update_q,
logger, logger,
scanner); scanner);
for(i=0; (size_t)i<scanner->max_table_num; i++) for(i=0; (size_t)i<scanner->max_table_num; i++)
{ {
table_rt=Maat_table_runtime_get(scanner->table_rt_mgr, i); table_rt=Maat_table_runtime_get(scanner->table_rt_mgr, i);
@@ -2292,6 +2297,7 @@ void do_scanner_update(struct Maat_scanner* scanner, int scan_thread_num, void*
scanner->gie_update_q_size=0; scanner->gie_update_q_size=0;
scanner->to_update_group_cnt=0; scanner->to_update_group_cnt=0;
scanner->to_update_compile_cnt=0; scanner->to_update_compile_cnt=0;
scanner->ip_plugin_update_q_size=0;
return; return;
} }