Minor tweaks to PR.

src/database.c

@@ -896,7 +896,6 @@ int db__message_reconnect_reset(struct mosquitto *context)
 int db__message_remove_incoming(struct mosquitto* context, uint16_t mid)
 {
 	struct mosquitto_client_msg *tail, *tmp;
-	bool deleted = false;
 
 	if(!context) return MOSQ_ERR_INVAL;
 
@@ -906,17 +905,13 @@ int db__message_remove_incoming(struct mosquitto* context, uint16_t mid)
 				return MOSQ_ERR_PROTOCOL;
 			}
 			db__message_remove(&context->msgs_in, tail);
-			deleted = true;
+			return MOSQ_ERR_SUCCESS;
 		}
 	}
 
-	if (deleted) {
-		return MOSQ_ERR_SUCCESS;
-	}
-	else {
 	return MOSQ_ERR_NOT_FOUND;
 }
-}
+
 
 int db__message_release_incoming(struct mosquitto *context, uint16_t mid)
 {

src/handle_publish.c

@@ -286,7 +286,12 @@ int handle__publish(struct mosquitto *context)
 		db__message_store_find(context, msg->source_mid, &stored);
 	}
 
-	if (stored && msg->source_mid != 0 && (stored->qos != msg->qos || stored->payloadlen != msg->payloadlen || strcmp(stored->topic, msg->topic) || memcmp(stored->payload, msg->payload, msg->payloadlen) )){
+	if(stored && msg->source_mid != 0 &&
+			(stored->qos != msg->qos
+			 || stored->payloadlen != msg->payloadlen
+			 || strcmp(stored->topic, msg->topic)
+			 || memcmp(stored->payload, msg->payload, msg->payloadlen) )){
+
 		log__printf(NULL, MOSQ_LOG_WARNING, "Reused message ID %u from %s detected. Clearing from storage.", msg->source_mid, context->id);
 		db__message_remove_incoming(context, msg->source_mid);
 		stored = NULL;