mirror
/
esp_mqtt
kopia lustrzana https://github.com/martin-ger/esp_mqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

do not activate closed connections

pull/16/head
Martin Ger 2017-11-08 21:50:04 +01:00
rodzic 9250e3b533
commit bc5bfbd2d4
5 zmienionych plików z 3 dodań i 3 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

BIN
firmware/0x00000.bin
Wyświetl plik

Plik binarny nie jest wyświetlany.

BIN
firmware/0x10000.bin
Wyświetl plik

Plik binarny nie jest wyświetlany.

BIN
firmware/libmqtt.a
Wyświetl plik

Plik binarny nie jest wyświetlany.

4
firmware/sha1sums
Wyświetl plik

@ -1,2 +1,2 @@
a726db57bd8cb2567ee8411ebd7d729370222a8b 0x00000.bin
0415e1b1018874ba371502501df2b25cf34eb5fb 0x10000.bin
4bc31b324e50df7c9a27dd1fd25989b91683b5ce 0x00000.bin
d8421d85140ee997f675adeecc1b6ff52499e498 0x10000.bin

2
mqtt/mqtt_server.c
Wyświetl plik

@ -114,7 +114,7 @@ bool ICACHE_FLASH_ATTR activate_next_client() {
MQTT_ClientCon *clientcon = clientcon_list;
for (clientcon = clientcon_list; clientcon != NULL; clientcon = clientcon->next) {
if (!QUEUE_IsEmpty(&clientcon->msgQueue)) {
if ((!QUEUE_IsEmpty(&clientcon->msgQueue)) && clientcon->pCon->state != ESPCONN_CLOSE) {
MQTT_INFO("MQTT: Next message to client: %s\r\n", clientcon->connect_info.client_id);
system_os_post(MQTT_SERVER_TASK_PRIO, 0, (os_param_t) clientcon);
return true;