From dba4c569462f494e2cfe491c6c5f98c2e40eaaa0 Mon Sep 17 00:00:00 2001 From: HuangXin Date: Mon, 26 Nov 2018 16:44:34 +0800 Subject: [PATCH] Fix megre code some error --- mqtt/esp_mqtt_AliNetease.c | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/mqtt/esp_mqtt_AliNetease.c b/mqtt/esp_mqtt_AliNetease.c index 6349b20..a6d14e2 100644 --- a/mqtt/esp_mqtt_AliNetease.c +++ b/mqtt/esp_mqtt_AliNetease.c @@ -993,7 +993,6 @@ void mqtt_client_thread(void* pvParameters) mqtt_client_set_last_msec(ne_os_ticks_ms(xTaskGetTickCount())); do { /* Generate topic message */ - cnt++; rc = mqtt_client_handle_message(pclient); if (rc < 0) { @@ -1005,22 +1004,17 @@ void mqtt_client_thread(void* pvParameters) MSG_ctrl_cmd_process(pclient); /* handle the MQTT packet received from TCP or SSL connection */ - if(cnt++ % 100 == 0) { MQTT_LOG_EX(LOG_Info, "MQTT Yield: FreeSize=%x, MinFreeSize=%x, CNT=%d\r\n", (int)system_get_free_heap_size(), (int)xPortGetMinimumEverFreeHeapSize(), cnt); } rc = IOT_MQTT_Yield(pclient, 200); - - MQTT_LOG_EX(LOG_Info, "MQTT Yield: FreeSize=%x, MinFreeSize=%x, CNT=%x\r\n", (int)system_get_free_heap_size(), (int)xPortGetMinimumEverFreeHeapSize(), cnt); - rc = IOT_MQTT_Yield(pclient, 200); - if (rc < 0) { MQTT_LOG_EX(LOG_Error, "Yield failed\r\n"); break; } - + #if 0 //test code for simulate MQTT publish if ((cnt&0xf) == 0) { mqtt_client_test_publish(pclient, cnt);