diff options
| author | root <[email protected]> | 2024-10-24 07:56:49 +0000 |
|---|---|---|
| committer | root <[email protected]> | 2024-10-24 07:56:49 +0000 |
| commit | da715f21ef5829c9c279b6fe24e89cd223afe643 (patch) | |
| tree | 813377f2563475061f396609cd1dc3acaabb315f /src | |
| parent | 1cd21a43c91bcfb8975991acffb1e3cb1c7841b7 (diff) | |
rename o2o and object2object to object_group
Diffstat (limited to 'src')
| -rw-r--r-- | src/inc_internal/maat_object.h | 26 | ||||
| -rw-r--r-- | src/inc_internal/maat_rule.h | 4 | ||||
| -rw-r--r-- | src/inc_internal/maat_table.h | 4 | ||||
| -rw-r--r-- | src/maat_api.c | 6 | ||||
| -rw-r--r-- | src/maat_config_monitor.c | 6 | ||||
| -rw-r--r-- | src/maat_object.c | 262 | ||||
| -rw-r--r-- | src/maat_rule.c | 10 | ||||
| -rw-r--r-- | src/maat_stat.c | 8 | ||||
| -rw-r--r-- | src/maat_table.c | 36 |
9 files changed, 181 insertions, 181 deletions
diff --git a/src/inc_internal/maat_object.h b/src/inc_internal/maat_object.h index 6d13e46..bef043e 100644 --- a/src/inc_internal/maat_object.h +++ b/src/inc_internal/maat_object.h @@ -23,33 +23,33 @@ extern "C" #include "maat_table.h" struct maat_object; -struct object2object_runtime; +struct object_group_runtime; -/* object2object schema API */ -void *object2object_schema_new(cJSON *json, struct table_manager *tbl_mgr, +/* object_group schema API */ +void *object_group_schema_new(cJSON *json, struct table_manager *tbl_mgr, const char *table_name, struct log_handle *logger); -void object2object_schema_free(void *o2o_schema); +void object_group_schema_free(void *object_group_schema); -/* object2object runtime API */ -void *object2object_runtime_new(void *o2o_schema, size_t max_thread_num, +/* object_group runtime API */ +void *object_group_runtime_new(void *object_group_schema, size_t max_thread_num, struct maat_garbage_bin *garbage_bin, struct log_handle *logger); -void object2object_runtime_free(void *o2o_runtime); +void object_group_runtime_free(void *object_group_runtime); -int object2object_runtime_update(void *o2o_runtime, void *o2o_schema, const char *table_name, +int object_group_runtime_update(void *object_group_runtime, void *object_group_schema, const char *table_name, const char *line, enum maat_operation op); -int object2object_runtime_commit(void *o2o_runtime, const char *table_name, long long maat_rt_version); +int object_group_runtime_commit(void *object_group_runtime, const char *table_name, long long maat_rt_version); -size_t object2object_runtime_get_super_objects(void *o2o_runtime, uuid_t *object_uuids, +size_t object_group_runtime_get_super_objects(void *object_group_runtime, uuid_t *object_uuids, size_t n_object_uuids, uuid_t *super_object_uuids, size_t super_object_uuids_size); -long long object2object_runtime_rule_count(void *o2o_runtime); +long long object_group_runtime_rule_count(void *object_group_runtime); -long long object2object_runtime_exclude_rule_count(void *o2o_runtime); +long long object_group_runtime_exclude_rule_count(void *object_group_runtime); -long long object2object_runtime_update_err_count(void *o2o_runtime); +long long object_group_runtime_update_err_count(void *object_group_runtime); #ifdef __cplusplus } diff --git a/src/inc_internal/maat_rule.h b/src/inc_internal/maat_rule.h index 11e15d8..7b9d0ef 100644 --- a/src/inc_internal/maat_rule.h +++ b/src/inc_internal/maat_rule.h @@ -25,7 +25,7 @@ extern "C" struct rule_schema; struct rule_runtime; struct rule_state; -struct object2object_runtime; +struct object_group_runtime; /* rule schema API */ void *rule_schema_new(cJSON *json, struct table_manager *tbl_mgr, @@ -81,7 +81,7 @@ void rule_compile_state_not_logic_update(struct rule_compile_state *rule_compile size_t rule_compile_state_get_internal_hit_paths(struct rule_compile_state *rule_compile_state, struct rule_runtime *rule_rt, - struct object2object_runtime *o2o_rt, + struct object_group_runtime *object_group_rt, struct maat_hit_path *hit_path_array, size_t array_size); diff --git a/src/inc_internal/maat_table.h b/src/inc_internal/maat_table.h index bb360b2..3f6ec5c 100644 --- a/src/inc_internal/maat_table.h +++ b/src/inc_internal/maat_table.h @@ -36,7 +36,7 @@ enum table_type { TABLE_TYPE_BOOL_PLUGIN, //above are physical table TABLE_TYPE_RULE, - TABLE_TYPE_OBJECT2OBJECT, + TABLE_TYPE_OBJECT_GROUP, TABLE_TYPE_MAX }; @@ -81,7 +81,7 @@ const char *table_manager_get_table_schema_tag(struct table_manager *tbl_mgr, in enum table_type table_manager_get_table_type(struct table_manager *tbl_mgr, int table_id); int table_manager_get_default_rule_table_id(struct table_manager *tbl_mgr); -int table_manager_get_object2object_table_id(struct table_manager *tbl_mgr); +int table_manager_get_object_group_table_id(struct table_manager *tbl_mgr); enum maat_expr_engine table_manager_get_expr_engine(struct table_manager *tbl_mgr); diff --git a/src/maat_api.c b/src/maat_api.c index 3db07af..5819102 100644 --- a/src/maat_api.c +++ b/src/maat_api.c @@ -2033,13 +2033,13 @@ int maat_state_get_hit_paths(struct maat_state *state, struct maat_hit_path *pat return -1; } - int o2o_table_id = table_manager_get_object2object_table_id(maat_inst->tbl_mgr); - void *o2o_runtime = table_manager_get_runtime(maat_inst->tbl_mgr, o2o_table_id); + int object_group_table_id = table_manager_get_object_group_table_id(maat_inst->tbl_mgr); + void *object_group_runtime = table_manager_get_runtime(maat_inst->tbl_mgr, object_group_table_id); size_t hit_path_cnt = rule_compile_state_get_internal_hit_paths(state->rule_compile_state, (struct rule_runtime *)rule_rt, - (struct object2object_runtime *)o2o_runtime, + (struct object_group_runtime *)object_group_runtime, path_array, array_size); return rule_runtime_get_hit_paths((struct rule_runtime *)rule_rt, diff --git a/src/maat_config_monitor.c b/src/maat_config_monitor.c index 6074239..53a42d1 100644 --- a/src/maat_config_monitor.c +++ b/src/maat_config_monitor.c @@ -139,7 +139,7 @@ void config_monitor_traverse(long long current_version, const cJSON *json_root, cJSON *tmp_obj = NULL; cJSON *rule_table = cJSON_GetObjectItem(json_root, "rule_table"); - cJSON *object2object_table = cJSON_GetObjectItem(json_root, "object2object_table"); + cJSON *object_group_table = cJSON_GetObjectItem(json_root, "object_group_table"); cJSON *plugin_table = cJSON_GetObjectItem(json_root, "plugin_table"); tmp_obj = cJSON_GetObjectItem(json_root, "items"); @@ -167,8 +167,8 @@ void config_monitor_traverse(long long current_version, const cJSON *json_root, } } - if (object2object_table) { - config_load_json_content(json_root, object2object_table->valuestring, "object_groups", u_param, update_fn); + if (object_group_table) { + config_load_json_content(json_root, object_group_table->valuestring, "object_groups", u_param, update_fn); } if (rule_table) { config_load_json_content(json_root, rule_table->valuestring, "rules", u_param, update_fn); diff --git a/src/maat_object.c b/src/maat_object.c index 62e6aeb..f57558d 100644 --- a/src/maat_object.c +++ b/src/maat_object.c @@ -22,13 +22,13 @@ #define MODULE_OBJECT module_name_str("maat.object") -struct object2object_item { +struct object_group_item { uuid_t object_uuid; UT_array *incl_sub_object_uuids; UT_array *excl_sub_object_uuids; }; -struct object2object_schema { +struct object_group_schema { int table_id; struct table_manager *ref_tbl_mgr; }; @@ -57,11 +57,11 @@ struct maat_object_topology { struct log_handle *logger; }; -struct object2object_runtime { +struct object_group_runtime { struct maat_object_topology *object_topo; struct maat_object_topology *updating_object_topo; long long rule_num; - long long excl_rule_num; //exclude o2o rule num + long long excl_rule_num; //exclude object_group rule num long long update_err_cnt; int updating_flag; @@ -76,31 +76,31 @@ static inline int compare_object_uuid(const void *a, const void *b) return uuid_compare(*(uuid_t *)a, *(uuid_t *)b); } -void *object2object_schema_new(cJSON *json, struct table_manager *tbl_mgr, +void *object_group_schema_new(cJSON *json, struct table_manager *tbl_mgr, const char *table_name, struct log_handle *logger) { - struct object2object_schema *o2o_schema = ALLOC(struct object2object_schema, 1); + struct object_group_schema *object_group_schema = ALLOC(struct object_group_schema, 1); cJSON *item = cJSON_GetObjectItem(json, "table_id"); if (item != NULL && item->type == cJSON_Number) { - o2o_schema->table_id = item->valueint; + object_group_schema->table_id = item->valueint; } else { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> schema has no table_id column", + "[%s:%d] object_group table:<%s> schema has no table_id column", __FUNCTION__, __LINE__, table_name); goto error; } - o2o_schema->ref_tbl_mgr = tbl_mgr; - return o2o_schema; + object_group_schema->ref_tbl_mgr = tbl_mgr; + return object_group_schema; error: - FREE(o2o_schema); + FREE(object_group_schema); return NULL; } -void object2object_schema_free(void *o2o_schema) +void object_group_schema_free(void *object_group_schema) { - FREE(o2o_schema); + FREE(object_group_schema); } static void object_vertex_free(struct maat_object *object) @@ -231,46 +231,46 @@ maat_object_topology_clone(struct maat_object_topology *object_topo) return object_topo_copy; } -void *object2object_runtime_new(void *o2o_schema, size_t max_thread_num, +void *object_group_runtime_new(void *object_group_schema, size_t max_thread_num, struct maat_garbage_bin *garbage_bin, struct log_handle *logger) { - if (NULL == o2o_schema) { + if (NULL == object_group_schema) { return NULL; } - struct object2object_runtime *o2o_rt = ALLOC(struct object2object_runtime, 1); + struct object_group_runtime *object_group_rt = ALLOC(struct object_group_runtime, 1); - o2o_rt->object_topo = maat_object_topology_new(logger); - o2o_rt->ref_garbage_bin = garbage_bin; - o2o_rt->logger = logger; + object_group_rt->object_topo = maat_object_topology_new(logger); + object_group_rt->ref_garbage_bin = garbage_bin; + object_group_rt->logger = logger; - return o2o_rt; + return object_group_rt; } -void object2object_runtime_free(void *o2o_runtime) +void object_group_runtime_free(void *object_group_runtime) { - if (NULL == o2o_runtime) { + if (NULL == object_group_runtime) { return; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; - if (o2o_rt->object_topo != NULL) { - maat_object_topology_free(o2o_rt->object_topo); - o2o_rt->object_topo = NULL; + if (object_group_rt->object_topo != NULL) { + maat_object_topology_free(object_group_rt->object_topo); + object_group_rt->object_topo = NULL; } - if (o2o_rt->updating_object_topo != NULL) { - maat_object_topology_free(o2o_rt->updating_object_topo); - o2o_rt->updating_object_topo = NULL; + if (object_group_rt->updating_object_topo != NULL) { + maat_object_topology_free(object_group_rt->updating_object_topo); + object_group_rt->updating_object_topo = NULL; } - FREE(o2o_rt); + FREE(object_group_rt); } -static struct object2object_item * -object2object_item_new(const char *line, struct object2object_schema *o2o_schema, +static struct object_group_item * +object_group_item_new(const char *line, struct object_group_schema *object_group_schema, const char *table_name, struct log_handle *logger) { cJSON *tmp_obj = NULL; @@ -278,29 +278,29 @@ object2object_item_new(const char *line, struct object2object_schema *o2o_schema if (json == NULL) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> line:<%s> parse json failed", + "[%s:%d] object_group table:<%s> line:<%s> parse json failed", __FUNCTION__, __LINE__, table_name, line); return NULL; } - struct object2object_item *o2o_item = ALLOC(struct object2object_item, 1); - utarray_new(o2o_item->incl_sub_object_uuids, &ut_object_uuid_icd); - utarray_new(o2o_item->excl_sub_object_uuids, &ut_object_uuid_icd); + struct object_group_item *object_group_item = ALLOC(struct object_group_item, 1); + utarray_new(object_group_item->incl_sub_object_uuids, &ut_object_uuid_icd); + utarray_new(object_group_item->excl_sub_object_uuids, &ut_object_uuid_icd); tmp_obj = cJSON_GetObjectItem(json, "object_uuid"); if (tmp_obj == NULL || tmp_obj->type != cJSON_String) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> has no object_uuid or format is not string in line:%s", + "[%s:%d] object_group table:<%s> has no object_uuid or format is not string in line:%s", __FUNCTION__, __LINE__, table_name, line); goto error; } - uuid_parse(tmp_obj->valuestring, o2o_item->object_uuid); + uuid_parse(tmp_obj->valuestring, object_group_item->object_uuid); tmp_obj = cJSON_GetObjectItem(json, "included_sub_object_uuids"); if (tmp_obj) { if (tmp_obj->type != cJSON_Array) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> included_sub_object_ids format is not array in line:%s", + "[%s:%d] object_group table:<%s> included_sub_object_ids format is not array in line:%s", __FUNCTION__, __LINE__, table_name, line); goto error; } @@ -309,16 +309,16 @@ object2object_item_new(const char *line, struct object2object_schema *o2o_schema cJSON *item = cJSON_GetArrayItem(tmp_obj, i); if (item == NULL || item->type != cJSON_String) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> included_sub_object_ids format error in line:%s", + "[%s:%d] object_group table:<%s> included_sub_object_ids format error in line:%s", __FUNCTION__, __LINE__, table_name, line); goto error; } uuid_t object_uuid; uuid_parse(item->valuestring, object_uuid); - utarray_push_back(o2o_item->incl_sub_object_uuids, &object_uuid); + utarray_push_back(object_group_item->incl_sub_object_uuids, &object_uuid); } - if (utarray_len(o2o_item->incl_sub_object_uuids) > MAX_OBJECT_CNT) { + if (utarray_len(object_group_item->incl_sub_object_uuids) > MAX_OBJECT_CNT) { log_fatal(logger, MODULE_OBJECT, "[%s:%d] o2r table:<%s> included_sub_object_ids exceed maximum:%d in line:%s", __FUNCTION__, __LINE__, table_name, MAX_OBJECT_CNT, line); @@ -330,7 +330,7 @@ object2object_item_new(const char *line, struct object2object_schema *o2o_schema if (tmp_obj) { if (tmp_obj->type != cJSON_Array) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> excluded_sub_object_ids format is not array in line:%s", + "[%s:%d] object_group table:<%s> excluded_sub_object_ids format is not array in line:%s", __FUNCTION__, __LINE__, table_name, line); goto error; } @@ -339,16 +339,16 @@ object2object_item_new(const char *line, struct object2object_schema *o2o_schema cJSON *item = cJSON_GetArrayItem(tmp_obj, i); if (item == NULL || item->type != cJSON_String) { log_fatal(logger, MODULE_OBJECT, - "[%s:%d] o2o table:<%s> excluded_sub_object_ids format error in line:%s", + "[%s:%d] object_group table:<%s> excluded_sub_object_ids format error in line:%s", __FUNCTION__, __LINE__, table_name, line); goto error; } uuid_t object_uuid; uuid_parse(item->valuestring, object_uuid); - utarray_push_back(o2o_item->excl_sub_object_uuids, &object_uuid); + utarray_push_back(object_group_item->excl_sub_object_uuids, &object_uuid); } - if (utarray_len(o2o_item->excl_sub_object_uuids) > MAX_OBJECT_CNT) { + if (utarray_len(object_group_item->excl_sub_object_uuids) > MAX_OBJECT_CNT) { log_fatal(logger, MODULE_OBJECT, "[%s:%d] o2r table:<%s> excluded_sub_object_ids exceed maximum:%d in line:%s", __FUNCTION__, __LINE__, table_name, MAX_OBJECT_CNT, line); @@ -358,32 +358,32 @@ object2object_item_new(const char *line, struct object2object_schema *o2o_schema cJSON_Delete(json); - return o2o_item; + return object_group_item; error: if (json) { cJSON_Delete(json); } - FREE(o2o_item); + FREE(object_group_item); return NULL; } -static void object2object_item_free(struct object2object_item *o2o_item) +static void object_group_item_free(struct object_group_item *object_group_item) { - if (NULL == o2o_item) { + if (NULL == object_group_item) { return; } - if (o2o_item->incl_sub_object_uuids != NULL) { - utarray_free(o2o_item->incl_sub_object_uuids); - o2o_item->incl_sub_object_uuids = NULL; + if (object_group_item->incl_sub_object_uuids != NULL) { + utarray_free(object_group_item->incl_sub_object_uuids); + object_group_item->incl_sub_object_uuids = NULL; } - if (o2o_item->excl_sub_object_uuids != NULL) { - utarray_free(o2o_item->excl_sub_object_uuids); - o2o_item->excl_sub_object_uuids = NULL; + if (object_group_item->excl_sub_object_uuids != NULL) { + utarray_free(object_group_item->excl_sub_object_uuids); + object_group_item->excl_sub_object_uuids = NULL; } - FREE(o2o_item); + FREE(object_group_item); } static size_t print_igraph_vector(igraph_vector_t *v, char *buff, size_t sz) { @@ -725,29 +725,29 @@ static int object_topology_build_super_objects(struct maat_object_topology *obje return 0; } -int object2object_runtime_update(void *o2o_runtime, void *o2o_schema, +int object_group_runtime_update(void *object_group_runtime, void *object_group_schema, const char *table_name, const char *line, enum maat_operation op) { - if (NULL == o2o_runtime || NULL == o2o_schema || + if (NULL == object_group_runtime || NULL == object_group_schema || NULL == line) { return -1; } - struct object2object_schema *schema = (struct object2object_schema *)o2o_schema; - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; + struct object_group_schema *schema = (struct object_group_schema *)object_group_schema; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; - struct object2object_item *o2o_item = object2object_item_new(line, schema, table_name, - o2o_rt->logger); - if (NULL == o2o_item) { - o2o_rt->update_err_cnt++; + struct object_group_item *object_group_item = object_group_item_new(line, schema, table_name, + object_group_rt->logger); + if (NULL == object_group_item) { + object_group_rt->update_err_cnt++; return -1; } - if (0 == o2o_rt->updating_flag) { - assert(o2o_rt->updating_object_topo == NULL); - o2o_rt->updating_object_topo = maat_object_topology_clone(o2o_rt->object_topo); - o2o_rt->updating_flag = 1; + if (0 == object_group_rt->updating_flag) { + assert(object_group_rt->updating_object_topo == NULL); + object_group_rt->updating_object_topo = maat_object_topology_clone(object_group_rt->object_topo); + object_group_rt->updating_flag = 1; } int ret = 0; @@ -756,62 +756,62 @@ int object2object_runtime_update(void *o2o_runtime, void *o2o_schema, uuid_t *sub_object_uuid = NULL; if (MAAT_OP_DEL == op) { //delete - for (i = 0; i < utarray_len(o2o_item->incl_sub_object_uuids); i++) { - sub_object_uuid = (uuid_t *)utarray_eltptr(o2o_item->incl_sub_object_uuids, i); - ret = object_topology_del_object_from_object(o2o_rt->updating_object_topo, - &o2o_item->object_uuid, sub_object_uuid, 0); + for (i = 0; i < utarray_len(object_group_item->incl_sub_object_uuids); i++) { + sub_object_uuid = (uuid_t *)utarray_eltptr(object_group_item->incl_sub_object_uuids, i); + ret = object_topology_del_object_from_object(object_group_rt->updating_object_topo, + &object_group_item->object_uuid, sub_object_uuid, 0); if (ret != 0) { err_flag = 1; } } - for (i = 0; i < utarray_len(o2o_item->excl_sub_object_uuids); i++) { - sub_object_uuid = (uuid_t *)utarray_eltptr(o2o_item->excl_sub_object_uuids, i); - ret = object_topology_del_object_from_object(o2o_rt->updating_object_topo, - &o2o_item->object_uuid, sub_object_uuid, 1); + for (i = 0; i < utarray_len(object_group_item->excl_sub_object_uuids); i++) { + sub_object_uuid = (uuid_t *)utarray_eltptr(object_group_item->excl_sub_object_uuids, i); + ret = object_topology_del_object_from_object(object_group_rt->updating_object_topo, + &object_group_item->object_uuid, sub_object_uuid, 1); if (ret != 0) { err_flag = 1; } } if (1 == err_flag) { - o2o_rt->update_err_cnt++; + object_group_rt->update_err_cnt++; } else { - if (utarray_len(o2o_item->excl_sub_object_uuids) > 0) { - o2o_rt->excl_rule_num--; + if (utarray_len(object_group_item->excl_sub_object_uuids) > 0) { + object_group_rt->excl_rule_num--; } - o2o_rt->rule_num--; + object_group_rt->rule_num--; } } else { //add - for (i = 0; i < utarray_len(o2o_item->incl_sub_object_uuids); i++) { - sub_object_uuid = (uuid_t *)utarray_eltptr(o2o_item->incl_sub_object_uuids, i); - ret = object_topology_add_object_to_object(o2o_rt->updating_object_topo, - &o2o_item->object_uuid, sub_object_uuid, 0); + for (i = 0; i < utarray_len(object_group_item->incl_sub_object_uuids); i++) { + sub_object_uuid = (uuid_t *)utarray_eltptr(object_group_item->incl_sub_object_uuids, i); + ret = object_topology_add_object_to_object(object_group_rt->updating_object_topo, + &object_group_item->object_uuid, sub_object_uuid, 0); if (ret != 0) { err_flag = 1; } } - for (i = 0; i < utarray_len(o2o_item->excl_sub_object_uuids); i++) { - sub_object_uuid = (uuid_t *)utarray_eltptr(o2o_item->excl_sub_object_uuids, i); - ret = object_topology_add_object_to_object(o2o_rt->updating_object_topo, - &o2o_item->object_uuid, sub_object_uuid, 1); + for (i = 0; i < utarray_len(object_group_item->excl_sub_object_uuids); i++) { + sub_object_uuid = (uuid_t *)utarray_eltptr(object_group_item->excl_sub_object_uuids, i); + ret = object_topology_add_object_to_object(object_group_rt->updating_object_topo, + &object_group_item->object_uuid, sub_object_uuid, 1); if (ret != 0) { err_flag = 1; } } if (1 == err_flag) { - o2o_rt->update_err_cnt++; + object_group_rt->update_err_cnt++; } else { - if (utarray_len(o2o_item->excl_sub_object_uuids) > 0) { - o2o_rt->excl_rule_num++; + if (utarray_len(object_group_item->excl_sub_object_uuids) > 0) { + object_group_rt->excl_rule_num++; } - o2o_rt->rule_num++; + object_group_rt->rule_num++; } } - object2object_item_free(o2o_item); + object_group_item_free(object_group_item); return ret; } @@ -822,43 +822,43 @@ static void garbage_maat_object_topology_free(void *data, void *arg) maat_object_topology_free(object_topo); } -int object2object_runtime_commit(void *o2o_runtime, const char *table_name, +int object_group_runtime_commit(void *object_group_runtime, const char *table_name, long long maat_rt_version) { - if (NULL == o2o_runtime) { + if (NULL == object_group_runtime) { return -1; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; - if (0 == o2o_rt->updating_flag) { + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; + if (0 == object_group_rt->updating_flag) { return 0; } struct timespec start, end; clock_gettime(CLOCK_MONOTONIC, &start); - int ret = object_topology_build_super_objects(o2o_rt->updating_object_topo); + int ret = object_topology_build_super_objects(object_group_rt->updating_object_topo); clock_gettime(CLOCK_MONOTONIC, &end); long long time_elapse_ms = (end.tv_sec - start.tv_sec) * 1000 + (end.tv_nsec - start.tv_nsec) / 1000000; if (ret < 0) { - log_fatal(o2o_rt->logger, MODULE_OBJECT, - "[%s:%d] table[%s] object2object runtime commit failed", + log_fatal(object_group_rt->logger, MODULE_OBJECT, + "[%s:%d] table[%s] object_group runtime commit failed", __FUNCTION__, __LINE__, table_name); return -1; } - struct maat_object_topology *old_object_topo = o2o_rt->object_topo; - o2o_rt->object_topo = o2o_rt->updating_object_topo; - o2o_rt->updating_object_topo = NULL; - o2o_rt->updating_flag = 0; + struct maat_object_topology *old_object_topo = object_group_rt->object_topo; + object_group_rt->object_topo = object_group_rt->updating_object_topo; + object_group_rt->updating_object_topo = NULL; + object_group_rt->updating_flag = 0; - maat_garbage_bagging(o2o_rt->ref_garbage_bin, old_object_topo, NULL, + maat_garbage_bagging(object_group_rt->ref_garbage_bin, old_object_topo, NULL, garbage_maat_object_topology_free); - log_info(o2o_rt->logger, MODULE_OBJECT, - "table[%s] commit %zu o2o rules and rebuild super_objects completed," - " version:%lld, consume:%lldms", table_name, o2o_rt->rule_num, + log_info(object_group_rt->logger, MODULE_OBJECT, + "table[%s] commit %zu object_group rules and rebuild super_objects completed," + " version:%lld, consume:%lldms", table_name, object_group_rt->rule_num, maat_rt_version, time_elapse_ms); return 0; @@ -876,7 +876,7 @@ static void get_candidate_super_object_ids(struct maat_object_topology *object_t p = (uuid_t *)utarray_next(hit_object_uuids, p)) { struct maat_object *object = object_topology_find_object(object_topo, p); if (NULL == object) { - //object_id not in object2object table + //object_id not in object_group table continue; } @@ -1170,61 +1170,61 @@ static size_t object_topology_get_super_objects(struct maat_object_topology *obj return idx; } -size_t object2object_runtime_get_super_objects(void *o2o_runtime, uuid_t *object_uuids, +size_t object_group_runtime_get_super_objects(void *object_group_runtime, uuid_t *object_uuids, size_t n_object_uuids, uuid_t *super_object_uuids, size_t super_object_uuids_size) { - if (NULL == o2o_runtime || NULL == object_uuids || 0 == n_object_uuids) { + if (NULL == object_group_runtime || NULL == object_uuids || 0 == n_object_uuids) { return 0; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; - uuid_t o2o_object_uuids[n_object_uuids]; - size_t o2o_object_uuids_cnt = 0; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; + uuid_t object_group_object_uuids[n_object_uuids]; + size_t object_group_object_uuids_cnt = 0; for (size_t i = 0; i < n_object_uuids; i++) { - struct maat_object *object = object_topology_find_object(o2o_rt->object_topo, &object_uuids[i]); + struct maat_object *object = object_topology_find_object(object_group_rt->object_topo, &object_uuids[i]); if (NULL == object) { continue; } - uuid_copy(o2o_object_uuids[o2o_object_uuids_cnt++], object_uuids[i]); + uuid_copy(object_group_object_uuids[object_group_object_uuids_cnt++], object_uuids[i]); } - if (0 == o2o_object_uuids_cnt) { + if (0 == object_group_object_uuids_cnt) { return 0; } - return object_topology_get_super_objects(o2o_rt->object_topo, o2o_object_uuids, o2o_object_uuids_cnt, + return object_topology_get_super_objects(object_group_rt->object_topo, object_group_object_uuids, object_group_object_uuids_cnt, super_object_uuids, super_object_uuids_size); } -long long object2object_runtime_rule_count(void *o2o_runtime) +long long object_group_runtime_rule_count(void *object_group_runtime) { - if (NULL == o2o_runtime) { + if (NULL == object_group_runtime) { return 0; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; - return o2o_rt->rule_num; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; + return object_group_rt->rule_num; } -long long object2object_runtime_exclude_rule_count(void *o2o_runtime) +long long object_group_runtime_exclude_rule_count(void *object_group_runtime) { - if (NULL == o2o_runtime) { + if (NULL == object_group_runtime) { return 0; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; - return o2o_rt->excl_rule_num; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; + return object_group_rt->excl_rule_num; } -long long object2object_runtime_update_err_count(void *o2o_runtime) +long long object_group_runtime_update_err_count(void *object_group_runtime) { - if (NULL == o2o_runtime) { + if (NULL == object_group_runtime) { return 0; } - struct object2object_runtime *o2o_rt = (struct object2object_runtime *)o2o_runtime; - return o2o_rt->update_err_cnt; + struct object_group_runtime *object_group_rt = (struct object_group_runtime *)object_group_runtime; + return object_group_rt->update_err_cnt; }
\ No newline at end of file diff --git a/src/maat_rule.c b/src/maat_rule.c index e23bc72..dd7acbd 100644 --- a/src/maat_rule.c +++ b/src/maat_rule.c @@ -1767,11 +1767,11 @@ int rule_compile_state_update(struct rule_compile_state *rule_compile_state, str utarray_push_back(rule_compile_state->last_hit_objects, &hit_object); } - int o2o_table_id = table_manager_get_object2object_table_id(maat_inst->tbl_mgr); - void *o2o_rt = table_manager_get_runtime(maat_inst->tbl_mgr, o2o_table_id); + int object_group_table_id = table_manager_get_object_group_table_id(maat_inst->tbl_mgr); + void *object_group_rt = table_manager_get_runtime(maat_inst->tbl_mgr, object_group_table_id); uuid_t super_object_uuids[MAX_HIT_OBJECT_NUM]; - size_t super_object_cnt = object2object_runtime_get_super_objects(o2o_rt, hit_object_uuids, + size_t super_object_cnt = object_group_runtime_get_super_objects(object_group_rt, hit_object_uuids, hit_cnt, super_object_uuids, MAX_HIT_OBJECT_NUM); for (i = 0; i < super_object_cnt; i++) { @@ -1944,7 +1944,7 @@ size_t rule_compile_state_get_direct_hit_object_cnt(struct rule_compile_state *r size_t rule_compile_state_get_internal_hit_paths(struct rule_compile_state *rule_compile_state, struct rule_runtime *rule_rt, - struct object2object_runtime *o2o_rt, + struct object_group_runtime *object_group_rt, struct maat_hit_path *hit_path_array, size_t array_size) { @@ -1962,7 +1962,7 @@ size_t rule_compile_state_get_internal_hit_paths(struct rule_compile_state *rule utarray_new(valid_super_object_uuids, &ut_rule_object_uuid_icd); size_t super_object_cnt = - object2object_runtime_get_super_objects(o2o_rt, &(internal_path->object_uuid), 1, + object_group_runtime_get_super_objects(object_group_rt, &(internal_path->object_uuid), 1, super_object_uuids, MAX_HIT_OBJECT_NUM); for (size_t idx = 0; idx < super_object_cnt; idx++) { utarray_push_back(valid_super_object_uuids, &super_object_uuids[idx]); diff --git a/src/maat_stat.c b/src/maat_stat.c index 29935f3..32ab9f5 100644 --- a/src/maat_stat.c +++ b/src/maat_stat.c @@ -244,7 +244,7 @@ static void fs_table_row_refresh(struct maat_stat *stat, int perf_on) long long total_rule_num = 0, total_scan_bytes = 0, total_update_err = 0; long long total_scan_times = 0, total_hit_times = 0, total_scan_cpu_time = 0; long long total_regv6_num = 0, total_hit_item_num = 0, total_hit_pattern_num = 0; - long long o2r_not_condition_num = 0, o2o_excl_rule_num = 0; + long long o2r_not_condition_num = 0, object_group_excl_rule_num = 0; struct field cell_tag = { .key = "TBL", .type = FIELD_VALUE_CSTRING @@ -272,8 +272,8 @@ static void fs_table_row_refresh(struct maat_stat *stat, int perf_on) plugin_cache_num += plugin_runtime_cached_row_count(runtime); plugin_rule_num += plugin_runtime_rule_count(runtime); break; - case TABLE_TYPE_OBJECT2OBJECT: - o2o_excl_rule_num += object2object_runtime_exclude_rule_count(runtime); + case TABLE_TYPE_OBJECT_GROUP: + object_group_excl_rule_num += object_group_runtime_exclude_rule_count(runtime); break; case TABLE_TYPE_EXPR: regex_rule_num = expr_runtime_regex_rule_count(runtime); @@ -414,7 +414,7 @@ static void fs_table_row_refresh(struct maat_stat *stat, int perf_on) fieldstat_easy_counter_set(stat->fs_handle, 0, stat->g_metric_id[STATUS_OBJECT_REF_EXCL_NUM], - NULL, 0, o2o_excl_rule_num); + NULL, 0, object_group_excl_rule_num); } diff --git a/src/maat_table.c b/src/maat_table.c index 79e152c..54377ee 100644 --- a/src/maat_table.c +++ b/src/maat_table.c @@ -57,7 +57,7 @@ struct table_manager { enum expr_engine_type engine_type; int default_rule_table_id; - int o2o_table_id; + int object_group_table_id; struct maat_kv_store *tbl_name2id_map; struct maat_kv_store *conj_tbl_name2id_map; @@ -233,15 +233,15 @@ struct table_operations table_ops[TABLE_TYPE_MAX] = { .update_err_count = rule_runtime_update_err_count }, { - .type = TABLE_TYPE_OBJECT2OBJECT, - .new_schema = object2object_schema_new, - .free_schema = object2object_schema_free, - .new_runtime = object2object_runtime_new, - .free_runtime = object2object_runtime_free, - .update_runtime = object2object_runtime_update, - .commit_runtime = object2object_runtime_commit, - .rule_count = object2object_runtime_rule_count, - .update_err_count = object2object_runtime_update_err_count + .type = TABLE_TYPE_OBJECT_GROUP, + .new_schema = object_group_schema_new, + .free_schema = object_group_schema_free, + .new_runtime = object_group_runtime_new, + .free_runtime = object_group_runtime_free, + .update_runtime = object_group_runtime_update, + .commit_runtime = object_group_runtime_commit, + .rule_count = object_group_runtime_rule_count, + .update_err_count = object_group_runtime_update_err_count } }; @@ -433,7 +433,7 @@ static void maat_table_schema_free(void *schema, enum table_type table_type) static void register_reserved_word(struct maat_kv_store *reserved_word_map) { maat_kv_register(reserved_word_map, "rule", TABLE_TYPE_RULE); - maat_kv_register(reserved_word_map, "object2object", TABLE_TYPE_OBJECT2OBJECT); + maat_kv_register(reserved_word_map, "object_group", TABLE_TYPE_OBJECT_GROUP); maat_kv_register(reserved_word_map, "flag", TABLE_TYPE_FLAG); maat_kv_register(reserved_word_map, "expr", TABLE_TYPE_EXPR); maat_kv_register(reserved_word_map, "interval", TABLE_TYPE_INTERVAL); @@ -784,7 +784,7 @@ table_manager_create(const char *table_info_path, const char *accept_tags, } int default_rule_table_id = -1; - int o2o_table_id = -1; + int object_group_table_id = -1; struct maat_kv_store *reserved_word_map = maat_kv_store_new(); register_reserved_word(reserved_word_map); @@ -821,8 +821,8 @@ table_manager_create(const char *table_info_path, const char *accept_tags, } } - if (maat_tbl->table_type == TABLE_TYPE_OBJECT2OBJECT) { - o2o_table_id = maat_tbl->table_id; + if (maat_tbl->table_type == TABLE_TYPE_OBJECT_GROUP) { + object_group_table_id = maat_tbl->table_id; } tbl_mgr->tbl[maat_tbl->table_id] = maat_tbl; @@ -835,10 +835,10 @@ table_manager_create(const char *table_info_path, const char *accept_tags, } tbl_mgr->default_rule_table_id = default_rule_table_id; - tbl_mgr->o2o_table_id = o2o_table_id; + tbl_mgr->object_group_table_id = object_group_table_id; log_info(logger, MODULE_TABLE, "default rule table id: %d", default_rule_table_id); - log_info(logger, MODULE_TABLE, "object2object table id: %d", o2o_table_id); + log_info(logger, MODULE_TABLE, "object_group table id: %d", object_group_table_id); next: FREE(json_buff); maat_kv_store_free(reserved_word_map); @@ -1055,13 +1055,13 @@ int table_manager_get_default_rule_table_id(struct table_manager *tbl_mgr) return tbl_mgr->default_rule_table_id; } -int table_manager_get_object2object_table_id(struct table_manager *tbl_mgr) +int table_manager_get_object_group_table_id(struct table_manager *tbl_mgr) { if (NULL == tbl_mgr) { return -1; } - return tbl_mgr->o2o_table_id; + return tbl_mgr->object_group_table_id; } void *table_manager_get_schema(struct table_manager *tbl_mgr, int table_id) |
