mirror of
https://github.com/emqx/neuron.git
synced 2026-10-29 07:06:32 +08:00
Refactor: variable renamning
Rename neu_datatag_table to datatag_table
This commit is contained in:
@@ -25,7 +25,7 @@
|
||||
|
||||
struct neu_datatag_table {
|
||||
pthread_mutex_t mtx;
|
||||
neu_id_map neu_datatag_table;
|
||||
neu_id_map datatag_table;
|
||||
};
|
||||
|
||||
neu_datatag_table_t *neu_datatag_tbl_create(void)
|
||||
@@ -42,14 +42,14 @@ neu_datatag_table_t *neu_datatag_tbl_create(void)
|
||||
return NULL;
|
||||
}
|
||||
|
||||
neu_id_map_init(&tag_tbl->neu_datatag_table, 0, 0);
|
||||
neu_id_map_init(&tag_tbl->datatag_table, 0, 0);
|
||||
return tag_tbl;
|
||||
}
|
||||
|
||||
void neu_datatag_tbl_destroy(neu_datatag_table_t *tag_tbl)
|
||||
{
|
||||
// TODO: free all datatag in datatag table
|
||||
neu_id_map_fini(&tag_tbl->neu_datatag_table);
|
||||
neu_id_map_fini(&tag_tbl->datatag_table);
|
||||
pthread_mutex_destroy(&tag_tbl->mtx);
|
||||
NEU_FREE_STRUCT(tag_tbl);
|
||||
return;
|
||||
@@ -61,7 +61,7 @@ neu_datatag_t *neu_datatag_tbl_get(neu_datatag_table_t *tag_tbl,
|
||||
neu_datatag_t *datatag;
|
||||
|
||||
pthread_mutex_lock(&tag_tbl->mtx);
|
||||
datatag = neu_id_get(&tag_tbl->neu_datatag_table, tag_id);
|
||||
datatag = neu_id_get(&tag_tbl->datatag_table, tag_id);
|
||||
pthread_mutex_unlock(&tag_tbl->mtx);
|
||||
return datatag;
|
||||
}
|
||||
@@ -72,7 +72,7 @@ int neu_datatag_tbl_update(neu_datatag_table_t *tag_tbl, datatag_id_t tag_id,
|
||||
int rv;
|
||||
|
||||
pthread_mutex_lock(&tag_tbl->mtx);
|
||||
rv = neu_id_set(&tag_tbl->neu_datatag_table, tag_id, datatag);
|
||||
rv = neu_id_set(&tag_tbl->datatag_table, tag_id, datatag);
|
||||
pthread_mutex_unlock(&tag_tbl->mtx);
|
||||
return rv;
|
||||
}
|
||||
@@ -83,7 +83,7 @@ datatag_id_t neu_datatag_tbl_add(neu_datatag_table_t *tag_tbl,
|
||||
datatag_id_t id = 0;
|
||||
|
||||
pthread_mutex_lock(&tag_tbl->mtx);
|
||||
if (neu_id_alloc(&tag_tbl->neu_datatag_table, &datatag->id, datatag) == 0) {
|
||||
if (neu_id_alloc(&tag_tbl->datatag_table, &datatag->id, datatag) == 0) {
|
||||
id = datatag->id;
|
||||
}
|
||||
pthread_mutex_unlock(&tag_tbl->mtx);
|
||||
@@ -95,7 +95,7 @@ int neu_datatag_tbl_remove(neu_datatag_table_t *tag_tbl, datatag_id_t tag_id)
|
||||
int rv;
|
||||
|
||||
pthread_mutex_lock(&tag_tbl->mtx);
|
||||
rv = neu_id_remove(&tag_tbl->neu_datatag_table, tag_id);
|
||||
rv = neu_id_remove(&tag_tbl->datatag_table, tag_id);
|
||||
pthread_mutex_unlock(&tag_tbl->mtx);
|
||||
return rv;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user