hacklab/G8TidinessButtons
5
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Attempt to fix blocking mqtt reconnect

Browse Source
This commit is contained in:
cazagen 2019-01-25 14:33:24 +00:00
parent fd787a05b2
commit 6474447e53
Signed by: cazagen
GPG Key ID: C326FEEE25FF7915
1 changed files with 35 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
buttons.cpp
View File

@ -17,11 +17,13 @@ int input3_value = 0;
int input4_value = 0; int input4_value = 0;
int led_timeout = 1000; int led_timeout = 1000;
long led_time = 0; long led_time = 0;
long last_wifi_check_time = 0; long last_wifi_check_time = 0;
long lastReconnectAttempt = 0;
long reconnectAttempts = 0;
long debouncing_time = 1000; long debouncing_time = 1000;
volatile unsigned long last_micros; volatile unsigned long last_micros;
@ -94,25 +96,21 @@ void setup_wifi() {
Serial.println(WiFi.localIP()); Serial.println(WiFi.localIP());
} }
void reconnect() { boolean reconnect() {
// Loop until we're reconnected reconnectAttempts++;
while (!client.connected()) { #
Serial.print("Attempting MQTT connection..."); String clientID = "ESP8266Client-";
// Create a random client ID clientID += String(random(0xffff), HEX);
String clientId = "ESP8266Client-";
clientId += String(random(0xffff), HEX); if (client.connect(clientID.c_str())) {
// Attempt to connect Serial.println("MQTT Connected");
if (client.connect(clientId.c_str())) { } else {
Serial.println("connected"); Serial.print("failed, rc = ");
// Once connected, publish an announcement... Serial.print(client.state());
} else { Serial.println("Trying again");
Serial.print("failed, rc= ");
Serial.print(client.state());
Serial.println(" try again in 1 second");
// Wait 1 seconds before retrying
delay(1000);
}
} }
return client.connected();
} }
void setup() { void setup() {
@ -191,10 +189,6 @@ void Interrupt4() {
void loop() { void loop() {
long now = millis(); long now = millis();
if (!client.connected()) {
reconnect(); // mqtt
}
if (now - last_wifi_check_time > WIFI_TIMEOUT) { if (now - last_wifi_check_time > WIFI_TIMEOUT) {
Serial.print("Checking WiFi... "); Serial.print("Checking WiFi... ");
if (WiFi.status() != WL_CONNECTED) { if (WiFi.status() != WL_CONNECTED) {
@ -206,10 +200,27 @@ void loop() {
last_wifi_check_time = now; last_wifi_check_time = now;
} }
if (!client.connected()) {
if (now - lastReconnectAttempt > 5000) {
lastReconnectAttempt = now;
// Attempt to reconnect
Serial.println("Attempting MQTT reconnect");
if (reconnect()) {
reconnectAttempts = 0;
lastReconnectAttempt = 0;
}
if (reconnectAttempts > 5) {
Serial.println("mqtt failed too many times, restarting wifi");
setup_wifi();
}
}
} else {
client.loop();
}
if (now - led_time > led_timeout) { if (now - led_time > led_timeout) {
digitalWrite(LED_PIN, 0); digitalWrite(LED_PIN, 0);
} }
client.loop(); // mqtt client
ArduinoOTA.handle(); ArduinoOTA.handle();
} }