|
|
@@ -67,8 +67,8 @@ mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t flags)
|
|
|
const struct mqtt_connect_client_info_t* client_info = (const struct mqtt_connect_client_info_t*)arg;
|
|
|
LWIP_UNUSED_ARG(data);
|
|
|
|
|
|
- printf("MQTT client \"%s\" data cb: len %d, flags %d\n", client_info->client_id,
|
|
|
- (int)len, (int)flags);
|
|
|
+ LWIP_PLATFORM_DIAG(("MQTT client \"%s\" data cb: len %d, flags %d\n", client_info->client_id,
|
|
|
+ (int)len, (int)flags));
|
|
|
}
|
|
|
|
|
|
static void
|
|
|
@@ -76,8 +76,8 @@ mqtt_incoming_publish_cb(void *arg, const char *topic, u32_t tot_len)
|
|
|
{
|
|
|
const struct mqtt_connect_client_info_t* client_info = (const struct mqtt_connect_client_info_t*)arg;
|
|
|
|
|
|
- printf("MQTT client \"%s\" publish cb: topic %s, len %d\n", client_info->client_id,
|
|
|
- topic, (int)tot_len);
|
|
|
+ LWIP_PLATFORM_DIAG(("MQTT client \"%s\" publish cb: topic %s, len %d\n", client_info->client_id,
|
|
|
+ topic, (int)tot_len));
|
|
|
}
|
|
|
|
|
|
static void
|
|
|
@@ -85,7 +85,7 @@ mqtt_request_cb(void *arg, err_t err)
|
|
|
{
|
|
|
const struct mqtt_connect_client_info_t* client_info = (const struct mqtt_connect_client_info_t*)arg;
|
|
|
|
|
|
- printf("MQTT client \"%s\" request cb: err %d\n", client_info->client_id, (int)err);
|
|
|
+ LWIP_PLATFORM_DIAG(("MQTT client \"%s\" request cb: err %d\n", client_info->client_id, (int)err));
|
|
|
}
|
|
|
|
|
|
static void
|
|
|
@@ -94,7 +94,7 @@ mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t st
|
|
|
const struct mqtt_connect_client_info_t* client_info = (const struct mqtt_connect_client_info_t*)arg;
|
|
|
LWIP_UNUSED_ARG(client);
|
|
|
|
|
|
- printf("MQTT client \"%s\" connection cb: status %d\n", client_info->client_id, (int)status);
|
|
|
+ LWIP_PLATFORM_DIAG(("MQTT client \"%s\" connection cb: status %d\n", client_info->client_id, (int)status));
|
|
|
|
|
|
if (status == MQTT_CONNECT_ACCEPTED) {
|
|
|
mqtt_sub_unsub(client,
|