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

fix(mqtt): topic is subscribed repeatedly

Browse Source
This commit is contained in:
gc87
2022-06-30 09:59:30 +08:00
parent 31dbfb1137
commit 8231e2ffd0
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/mqtt_c_client.c
+9
View File
@@ -803,6 +803,15 @@ neu_err_code_e mqtt_c_client_subscribe(mqtt_c_client_t *client,
assert(NULL != client);
assert(NULL != topic && 0 < strlen(topic));
for (struct subscribe_tuple **p =
(struct subscribe_tuple **) utarray_front(client->array);
NULL != p;
p = (struct subscribe_tuple **) utarray_next(client->array, p)) {
if (0 == strcmp((*p)->topic, topic)) {
return NEU_ERR_SUCCESS;
}
}
struct subscribe_tuple *tuple =
client_subscribe_create(client, topic, qos, handle);
if (NULL == tuple) {