GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-22 01:05:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor add tag to table

Browse Source
This commit is contained in:
fengzero
2022-03-16 05:40:07 +00:00
parent 14a96d6e09
commit 901ff6df16
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/base/neu_datatag_table.c
+14 -14
View File
@@ -118,28 +118,28 @@ int neu_datatag_tbl_update(neu_datatag_table_t *tag_tbl, datatag_id_t tag_id,
datatag_id_t neu_datatag_tbl_add(neu_datatag_table_t *tag_tbl,
neu_datatag_t * datatag)
{
datatag_id_t id = 0;
int ret = -1;
datatag_id_t id = 0;
pthread_mutex_lock(&tag_tbl->mtx);
if (NULL == neu_hash_table_get(&tag_tbl->tag_name_table, datatag->name)) {
if (datatag->id > 0) {
if (neu_id_set(&tag_tbl->datatag_table, datatag->id, datatag) !=
0) {
log_error("Failed to set tag_id");
pthread_mutex_unlock(&tag_tbl->mtx);
return id;
}
} else if (neu_id_alloc(&tag_tbl->datatag_table, &datatag->id,
datatag) != 0) {
log_error("Failed to alloc tag_id");
pthread_mutex_unlock(&tag_tbl->mtx);
return id;
ret = neu_id_set(&tag_tbl->datatag_table, datatag->id, datatag);
} else {
ret = neu_id_alloc(&tag_tbl->datatag_table, &datatag->id, datatag);
}
id = datatag->id;
neu_hash_table_set(&tag_tbl->tag_name_table, datatag->name, datatag);
}
if (ret != 0) {
pthread_mutex_unlock(&tag_tbl->mtx);
return 0;
}
neu_hash_table_set(&tag_tbl->tag_name_table, datatag->name, datatag);
id = datatag->id;
pthread_mutex_unlock(&tag_tbl->mtx);
return id;
}