GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-29 15:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): fail early when groups already subscribed

Browse Source
This commit is contained in:
eeff
2024-06-05 11:52:39 +08:00
parent 5f9a66d794
commit 8fcbe9cac8
1 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/manager.c
+22
View File
@@ -698,6 +698,28 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
(neu_req_subscribe_groups_t *) &header[1];
neu_resp_error_t error = { 0 };
UT_array *subs =
neu_subscribe_manager_get(manager->subscribe_manager, cmd->app);
for (uint16_t i = 0; i < cmd->n_group; ++i) {
neu_req_subscribe_group_info_t *info = &cmd->groups[i];
utarray_foreach(subs, neu_resp_subscribe_info_t *, sub)
{
if (0 == strcmp(info->driver, sub->driver) &&
0 == strcmp(info->group, sub->group)) {
error.error = NEU_ERR_GROUP_ALREADY_SUBSCRIBED;
}
}
}
utarray_free(subs);
if (0 != error.error) {
neu_req_subscribe_groups_fini(cmd);
header->type = NEU_RESP_ERROR;
strcpy(header->receiver, header->sender);
reply(manager, header, &error);
break;
}
for (uint16_t i = 0; i < cmd->n_group; ++i) {
neu_req_subscribe_group_info_t *info = &cmd->groups[i];