|
|
@ -525,7 +525,7 @@ int mqtt3_handle_connect(struct mosquitto_db *db, struct mosquitto *context)
|
|
|
|
msg_prev = NULL;
|
|
|
|
msg_prev = NULL;
|
|
|
|
while(msg_tail){
|
|
|
|
while(msg_tail){
|
|
|
|
if(msg_tail->direction == mosq_md_out){
|
|
|
|
if(msg_tail->direction == mosq_md_out){
|
|
|
|
if(mosquitto_acl_check(db, context, msg_tail->store->topic, MOSQ_ACL_READ) == MOSQ_ERR_ACL_DENIED){
|
|
|
|
if(mosquitto_acl_check(db, context, msg_tail->store->topic, MOSQ_ACL_READ) != MOSQ_ERR_SUCCESS){
|
|
|
|
mosquitto__db_msg_store_deref(db, &msg_tail->store);
|
|
|
|
mosquitto__db_msg_store_deref(db, &msg_tail->store);
|
|
|
|
if(msg_prev){
|
|
|
|
if(msg_prev){
|
|
|
|
msg_prev->next = msg_tail->next;
|
|
|
|
msg_prev->next = msg_tail->next;
|
|
|
|