Free message if request queue is full

SmingHub · Jul 4, 2019 · 5c8d04b · 5c8d04b
1 parent 26f8f02
commit 5c8d04b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/Sming/Core/Network/MqttClient.cpp b/Sming/Core/Network/MqttClient.cpp
@@ -225,6 +225,11 @@ bool MqttClient::connect(const Url& url, const String& clientName, uint32_t sslO
 		}
 	}
 
+	if(requestQueue.full()) {
+		debug_e("MQTT request queue full!");
+		return false;
+	}
+
 	mqtt_message_t* message = (mqtt_message_t*)malloc(sizeof(mqtt_message_t));
 	memcpy(message, &connectMessage, sizeof(mqtt_message_t));
 	requestQueue.enqueue(message);