comparison: main/task_mqtt.c
main/task_mqtt.c
- changeset 37
- 358bbd5b608e
- parent 28
- 6d825e2962e4
- child 44
- e52d11b8f252
equal
deleted
inserted
replaced
| 36:e2a43e7c4035 | 37:358bbd5b608e |
|---|---|
| 271 static esp_err_t mqtt_event_handler_cb(esp_mqtt_event_handle_t event) | 271 static esp_err_t mqtt_event_handler_cb(esp_mqtt_event_handle_t event) |
| 272 { | 272 { |
| 273 switch (event->event_id) { | 273 switch (event->event_id) { |
| 274 | 274 |
| 275 case MQTT_EVENT_CONNECTED: | 275 case MQTT_EVENT_CONNECTED: |
| 276 ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED"); | 276 ESP_LOGD(TAG, "MQTT_EVENT_CONNECTED"); |
| 277 xEventGroupSetBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); | 277 xEventGroupSetBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); |
| 278 break; | 278 break; |
| 279 | 279 |
| 280 case MQTT_EVENT_DISCONNECTED: | 280 case MQTT_EVENT_DISCONNECTED: |
| 281 ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED"); | 281 ESP_LOGD(TAG, "MQTT_EVENT_DISCONNECTED"); |
| 282 xEventGroupClearBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); | 282 xEventGroupClearBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); |
| 283 break; | 283 break; |
| 284 | 284 |
| 285 case MQTT_EVENT_SUBSCRIBED: | 285 case MQTT_EVENT_SUBSCRIBED: |
| 286 ESP_LOGI(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id); | 286 ESP_LOGD(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id); |
| 287 break; | 287 break; |
| 288 | 288 |
| 289 case MQTT_EVENT_UNSUBSCRIBED: | 289 case MQTT_EVENT_UNSUBSCRIBED: |
| 290 ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id); | 290 ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id); |
| 291 break; | 291 break; |
| 292 | 292 |
| 293 case MQTT_EVENT_PUBLISHED: | 293 case MQTT_EVENT_PUBLISHED: |
| 294 ESP_LOGI(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id); | 294 ESP_LOGD(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id); |
| 295 if (xSemaphoreTake(xSemaphorePcounter, 10) == pdTRUE) { | 295 if (xSemaphoreTake(xSemaphorePcounter, 10) == pdTRUE) { |
| 296 if (count_pub) { | 296 if (count_pub) { |
| 297 count_pub--; | 297 count_pub--; |
| 298 } | 298 } |
| 299 xSemaphoreGive(xSemaphorePcounter); | 299 xSemaphoreGive(xSemaphorePcounter); |
| 346 /* | 346 /* |
| 347 * Initialize Sequence counter from NVS | 347 * Initialize Sequence counter from NVS |
| 348 */ | 348 */ |
| 349 err = nvs_open("storage", NVS_READWRITE, &seq_handle); | 349 err = nvs_open("storage", NVS_READWRITE, &seq_handle); |
| 350 if (err != ESP_OK) { | 350 if (err != ESP_OK) { |
| 351 ESP_LOGI(TAG, "Error (%s) opening NVS handle", esp_err_to_name(err)); | 351 ESP_LOGE(TAG, "Error (%s) opening NVS handle", esp_err_to_name(err)); |
| 352 } else { | 352 } else { |
| 353 err = nvs_get_u64(seq_handle, "Sequence_cnt", &Sequence); | 353 err = nvs_get_u64(seq_handle, "Sequence_cnt", &Sequence); |
| 354 switch (err) { | 354 switch (err) { |
| 355 case ESP_OK: | 355 case ESP_OK: |
| 356 ESP_LOGI(TAG, "Sequence counter from NVS = %lld", Sequence); | 356 ESP_LOGI(TAG, "Sequence counter from NVS = %lld", Sequence); |
| 359 case ESP_ERR_NVS_NOT_FOUND: | 359 case ESP_ERR_NVS_NOT_FOUND: |
| 360 ESP_LOGI(TAG, "Sequence counter not found"); | 360 ESP_LOGI(TAG, "Sequence counter not found"); |
| 361 break; | 361 break; |
| 362 | 362 |
| 363 default: | 363 default: |
| 364 ESP_LOGI(TAG, "Error (%s) init Sequence", esp_err_to_name(err)); | 364 ESP_LOGE(TAG, "Error (%s) init Sequence", esp_err_to_name(err)); |
| 365 break; | 365 break; |
| 366 } | 366 } |
| 367 } | 367 } |
| 368 | 368 |
| 369 /* event handler and event group for the wifi driver */ | 369 /* event handler and event group for the wifi driver */ |
