d0kuhn/mosquitto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'fix_msg_modification_leak' of https://github.com/abiliojr/mosquitto into abiliojr-fix_msg_modification_leak

Browse Source
This commit is contained in:
Roger A. Light 2022-05-11 15:53:48 +01:00
commit 53a9e81480
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/plugin.c
View File

@ -157,23 +157,29 @@ int plugin__handle_message(struct mosquitto *context, struct mosquitto_msg_store
DL_FOREACH(opts->plugin_callbacks.message, cb_base){ DL_FOREACH(opts->plugin_callbacks.message, cb_base){
rc = cb_base->cb(MOSQ_EVT_MESSAGE, &event_data, cb_base->userdata); rc = cb_base->cb(MOSQ_EVT_MESSAGE, &event_data, cb_base->userdata);
if(stored->topic != event_data.topic){
mosquitto__free(stored->topic);
stored->topic = event_data.topic;
}
if(stored->payload != event_data.payload){
mosquitto__free(stored->payload);
stored->payload = event_data.payload;
stored->payloadlen = event_data.payloadlen;
}
if(stored->properties != event_data.properties){
mosquitto_property_free_all(stored->properties);
stored->properties = event_data.properties;
}
if(rc != MOSQ_ERR_SUCCESS){ if(rc != MOSQ_ERR_SUCCESS){
break; break;
} }
} }
if(stored->topic != event_data.topic){
mosquitto__free(stored->topic);
stored->topic = event_data.topic;
}
if(stored->payload != event_data.payload){
mosquitto__free(stored->payload);
stored->payload = event_data.payload;
stored->payloadlen = event_data.payloadlen;
}
stored->retain = event_data.retain; stored->retain = event_data.retain;
stored->properties = event_data.properties;
return rc; return rc;
} }