GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2069 from eeff/2.6-encrypt_pass

Browse Source 
v2.6 encrypt pass: fail early when groups already subscribed
This commit is contained in:
fengzeroz
2024-06-05 15:41:47 +08:00
committed by GitHub
parent 620e47e6c6 8fcbe9cac8
commit 1f92ce5e9b
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];