summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorroot <[email protected]>2024-10-24 07:56:49 +0000
committerroot <[email protected]>2024-10-24 07:56:49 +0000
commitda715f21ef5829c9c279b6fe24e89cd223afe643 (patch)
tree813377f2563475061f396609cd1dc3acaabb315f /src
parent1cd21a43c91bcfb8975991acffb1e3cb1c7841b7 (diff)
rename o2o and object2object to object_group
Diffstat (limited to 'src')
-rw-r--r--src/inc_internal/maat_object.h26
-rw-r--r--src/inc_internal/maat_rule.h4
-rw-r--r--src/inc_internal/maat_table.h4
-rw-r--r--src/maat_api.c6
-rw-r--r--src/maat_config_monitor.c6
-rw-r--r--src/maat_object.c262
-rw-r--r--src/maat_rule.c10
-rw-r--r--src/maat_stat.c8
-rw-r--r--src/maat_table.c36
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)