@@ -999,7 +999,7 @@ static esp_err_t esp_mqtt_dispatch_event(esp_mqtt_client_handle_t client)
999999 client -> event .protocol_ver = client -> mqtt_state .connection .information .protocol_ver ;
10001000 esp_err_t ret = ESP_FAIL ;
10011001
1002- #ifdef MQTT_SUPPORTED_FEATURE_EVENT_LOOP
1002+ #ifdef MQTT_SUPPORTED_FEATURE_EVENT_LOOP
10031003 esp_event_post_to (client -> config -> event_loop_handle , MQTT_EVENTS , client -> event .event_id , & client -> event , sizeof (client -> event ), portMAX_DELAY );
10041004 ret = esp_event_loop_run (client -> config -> event_loop_handle , 0 );
10051005#else
@@ -1037,7 +1037,7 @@ static esp_err_t deliver_publish(esp_mqtt_client_handle_t client)
10371037 ESP_LOGE (TAG , "%s: mqtt_get_publish_topic() failed" , __func__ );
10381038 return ESP_FAIL ;
10391039 }
1040- ESP_LOGD (TAG , "%s: msg_topic_len=%" PRIu32 , __func__ , msg_topic_len );
1040+ ESP_LOGD (TAG , "%s: msg_topic_len=%" NEWLIB_NANO_COMPAT_FORMAT , __func__ , NEWLIB_NANO_COMPAT_CAST ( msg_topic_len ) );
10411041
10421042 // get payload
10431043 msg_data = mqtt_get_publish_data (msg_buf , & msg_data_len );
@@ -1059,8 +1059,9 @@ static esp_err_t deliver_publish(esp_mqtt_client_handle_t client)
10591059 client -> event .dup = mqtt_get_dup (msg_buf );
10601060 client -> event .total_data_len = msg_data_len + msg_total_len - msg_read_len ;
10611061post_data_event :
1062- ESP_LOGD (TAG , "Get data len= %" PRIu32 ", topic len=%" PRIu32 ", total_data: %d offset: %" PRIu32 , msg_data_len , msg_topic_len ,
1063- client -> event .total_data_len , msg_data_offset );
1062+ ESP_LOGD (TAG , "Get data len= %" NEWLIB_NANO_COMPAT_FORMAT ", topic len=%" NEWLIB_NANO_COMPAT_FORMAT ", total_data: %d offset: %" NEWLIB_NANO_COMPAT_FORMAT ,
1063+ NEWLIB_NANO_COMPAT_CAST (msg_data_len ), NEWLIB_NANO_COMPAT_CAST (msg_topic_len ),
1064+ client -> event .total_data_len , NEWLIB_NANO_COMPAT_CAST (msg_data_offset ));
10641065 client -> event .event_id = MQTT_EVENT_DATA ;
10651066 client -> event .data = msg_data_len > 0 ? msg_data : NULL ;
10661067 client -> event .data_len = msg_data_len ;
@@ -1149,16 +1150,16 @@ static outbox_item_handle_t mqtt_enqueue(esp_mqtt_client_handle_t client, uint8_
11491150{
11501151 ESP_LOGD (TAG , "mqtt_enqueue id: %d, type=%d successful" ,
11511152 client -> mqtt_state .pending_msg_id , client -> mqtt_state .pending_msg_type );
1152- outbox_message_t msg = { 0 };
1153- msg .data = client -> mqtt_state .connection .outbound_message .data ;
1154- msg .len = client -> mqtt_state .connection .outbound_message .length ;
1155- msg .msg_id = client -> mqtt_state .pending_msg_id ;
1156- msg .msg_type = client -> mqtt_state .pending_msg_type ;
1157- msg .msg_qos = client -> mqtt_state .pending_publish_qos ;
1158- msg .remaining_data = remaining_data ;
1159- msg .remaining_len = remaining_len ;
1160- //Copy to queue buffer
1161- return outbox_enqueue (client -> outbox , & msg , platform_tick_get_ms ());
1153+ outbox_message_t msg = { 0 };
1154+ msg .data = client -> mqtt_state .connection .outbound_message .data ;
1155+ msg .len = client -> mqtt_state .connection .outbound_message .length ;
1156+ msg .msg_id = client -> mqtt_state .pending_msg_id ;
1157+ msg .msg_type = client -> mqtt_state .pending_msg_type ;
1158+ msg .msg_qos = client -> mqtt_state .pending_publish_qos ;
1159+ msg .remaining_data = remaining_data ;
1160+ msg .remaining_len = remaining_len ;
1161+ //Copy to queue buffer
1162+ return outbox_enqueue (client -> outbox , & msg , platform_tick_get_ms ());
11621163}
11631164
11641165
@@ -1218,7 +1219,7 @@ static int mqtt_message_receive(esp_mqtt_client_handle_t client, int read_poll_t
12181219 } while ((client -> mqtt_state .in_buffer_read_len < 6 ) && (* (buf - 1 ) & 0x80 ));
12191220 }
12201221 total_len = mqtt_get_total_length (client -> mqtt_state .in_buffer , client -> mqtt_state .in_buffer_read_len , & fixed_header_len );
1221- ESP_LOGD (TAG , "%s: total message length: %d (already read: %" PRIu32 ")" , __func__ , total_len , client -> mqtt_state .in_buffer_read_len );
1222+ ESP_LOGD (TAG , "%s: total message length: %d (already read: %" NEWLIB_NANO_COMPAT_FORMAT ")" , __func__ , total_len , NEWLIB_NANO_COMPAT_CAST ( client -> mqtt_state .in_buffer_read_len ) );
12221223 client -> mqtt_state .message_length = total_len ;
12231224 if (client -> mqtt_state .in_buffer_length < total_len ) {
12241225 if (mqtt_get_type (client -> mqtt_state .in_buffer ) == MQTT_MSG_TYPE_PUBLISH ) {
@@ -1236,8 +1237,8 @@ static int mqtt_message_receive(esp_mqtt_client_handle_t client, int read_poll_t
12361237 client -> mqtt_state .in_buffer_read_len += read_len ;
12371238 buf += read_len ;
12381239 if (client -> mqtt_state .in_buffer_read_len < fixed_header_len + 2 ) {
1239- ESP_LOGD (TAG , "%s: transport_read(): message reading left in progress :: total message length: %d (already read: %" PRIu32 ")" ,
1240- __func__ , total_len , client -> mqtt_state .in_buffer_read_len );
1240+ ESP_LOGD (TAG , "%s: transport_read(): message reading left in progress :: total message length: %d (already read: %" NEWLIB_NANO_COMPAT_FORMAT ")" ,
1241+ __func__ , total_len , NEWLIB_NANO_COMPAT_CAST ( client -> mqtt_state .in_buffer_read_len ) );
12411242 return 0 ;
12421243 }
12431244 }
@@ -1266,12 +1267,13 @@ static int mqtt_message_receive(esp_mqtt_client_handle_t client, int read_poll_t
12661267 }
12671268 client -> mqtt_state .in_buffer_read_len += read_len ;
12681269 if (client -> mqtt_state .in_buffer_read_len < total_len ) {
1269- ESP_LOGD (TAG , "%s: transport_read(): message reading left in progress :: total message length: %d (already read: %" PRIu32 ")" ,
1270- __func__ , total_len , client -> mqtt_state .in_buffer_read_len );
1270+ ESP_LOGD (TAG , "%s: transport_read(): message reading left in progress :: total message length: %d (already read: %" NEWLIB_NANO_COMPAT_FORMAT ")" ,
1271+ __func__ , total_len , NEWLIB_NANO_COMPAT_CAST ( client -> mqtt_state .in_buffer_read_len ) );
12711272 return 0 ;
12721273 }
12731274 }
1274- ESP_LOGD (TAG , "%s: transport_read():%" PRIu32 " %" PRIu32 , __func__ , client -> mqtt_state .in_buffer_read_len , client -> mqtt_state .message_length );
1275+ ESP_LOGD (TAG , "%s: transport_read():%" NEWLIB_NANO_COMPAT_FORMAT " %" NEWLIB_NANO_COMPAT_FORMAT , __func__ ,
1276+ NEWLIB_NANO_COMPAT_CAST (client -> mqtt_state .in_buffer_read_len ), NEWLIB_NANO_COMPAT_CAST (client -> mqtt_state .message_length ));
12751277 return 1 ;
12761278err :
12771279 esp_mqtt_client_dispatch_transport_error (client );
@@ -1313,7 +1315,8 @@ static esp_err_t mqtt_process_receive(esp_mqtt_client_handle_t client)
13131315#ifdef MQTT_PROTOCOL_5
13141316 esp_mqtt5_parse_suback (client );
13151317#endif
1316- ESP_LOGD (TAG , "deliver_suback, message_length_read=%" PRIu32 ", message_length=%" PRIu32 , client -> mqtt_state .in_buffer_read_len , client -> mqtt_state .message_length );
1318+ ESP_LOGD (TAG , "deliver_suback, message_length_read=%" NEWLIB_NANO_COMPAT_FORMAT ", message_length=%" NEWLIB_NANO_COMPAT_FORMAT ,
1319+ NEWLIB_NANO_COMPAT_CAST (client -> mqtt_state .in_buffer_read_len ), NEWLIB_NANO_COMPAT_CAST (client -> mqtt_state .message_length ));
13171320 if (deliver_suback (client ) != ESP_OK ) {
13181321 ESP_LOGE (TAG , "Failed to deliver suback message id=%d" , msg_id );
13191322 return ESP_FAIL ;
@@ -1331,7 +1334,7 @@ static esp_err_t mqtt_process_receive(esp_mqtt_client_handle_t client)
13311334 }
13321335 break ;
13331336 case MQTT_MSG_TYPE_PUBLISH :
1334- ESP_LOGD (TAG , "deliver_publish, message_length_read=%" PRIu32 ", message_length=%" PRIu32 , client -> mqtt_state .in_buffer_read_len , client -> mqtt_state .message_length );
1337+ ESP_LOGD (TAG , "deliver_publish, message_length_read=%" NEWLIB_NANO_COMPAT_FORMAT ", message_length=%" NEWLIB_NANO_COMPAT_FORMAT , NEWLIB_NANO_COMPAT_CAST ( client -> mqtt_state .in_buffer_read_len ), NEWLIB_NANO_COMPAT_CAST ( client -> mqtt_state .message_length ) );
13351338 if (deliver_publish (client ) != ESP_OK ) {
13361339 ESP_LOGE (TAG , "Failed to deliver publish message id=%d" , msg_id );
13371340 return ESP_FAIL ;
@@ -1830,7 +1833,7 @@ int esp_mqtt_client_subscribe_multiple(esp_mqtt_client_handle_t client,
18301833 }
18311834
18321835 if (client -> config -> outbox_limit > 0 && outbox_get_size (client -> outbox ) > client -> config -> outbox_limit ) {
1833- return -2 ;
1836+ return -2 ;
18341837 }
18351838 MQTT_API_LOCK (client );
18361839 if (client -> state != MQTT_STATE_CONNECTED ) {
0 commit comments