【完善】日志格式，使用 rtdbg

Signed-off-by: armink <armink.ztl@gmail.com>

inc/onenet.h

@@ -43,49 +43,6 @@
 #define ONENET_FREE                    rt_free
 #endif
 
-/* error level log */
-#ifdef  log_e
-#undef  log_e
-#endif
-#define log_e(...)                     rt_kprintf("\033[31;22m[E/ONENET] (%s:%d) ", __FUNCTION__, __LINE__);rt_kprintf(__VA_ARGS__);rt_kprintf("\033[0m\n")
-
-/* info level log */
-#ifdef  log_i
-#undef  log_i
-#endif
-#define log_i(...)                     rt_kprintf("\033[36;22m[I/ONENET] ");                                rt_kprintf(__VA_ARGS__);rt_kprintf("\033[0m\n")
-
-#if ONENET_DEBUG
-#ifdef assert
-#undef assert
-#endif
-#define assert(EXPR)                                                           \
-if (!(EXPR))                                                                   \
-{                                                                              \
-    rt_kprintf("(%s) has assert failed at %s.\n", #EXPR, __FUNCTION__);        \
-    while (1);                                                                 \
-}
-
-/* debug level log */
-#ifdef  log_d
-#undef  log_d
-#endif
-#define log_d(...)                     rt_kprintf("[D/ONENET] (%s:%d) ", __FUNCTION__, __LINE__);           rt_kprintf(__VA_ARGS__);rt_kprintf("\n")
-
-#else
-
-#ifdef assert
-#undef assert
-#endif
-#define assert(EXPR)                   ((void)0);
-
-/* debug level log */
-#ifdef  log_d
-#undef  log_d
-#endif
-#define log_d(...)
-#endif /* ONENET_DEBUG */
-
 #ifndef ONENET_MQTT_SUBTOPIC
 #define ONENET_MQTT_SUBTOPIC           "/topic_test"
 #endif

ports/onenet_port.c

@@ -24,9 +24,20 @@
 
 #include <onenet.h>
 
+#define DBG_ENABLE
+#define DBG_COLOR
+#define DBG_SECTION_NAME    "onenet.port"
+#if ONENET_DEBUG
+#define DBG_LEVEL           DBG_LOG
+#else
+#define DBG_LEVEL           DBG_INFO
+#endif /* ONENET_DEBUG */
+
+#include <rtdbg.h>
+
 int onenet_port_data_process(char *recv_data, rt_size_t size)
 {
-    log_d("Recv data : %.*s", size, recv_data);
+    LOG_D("Recv data : %.*s", size, recv_data);
 
     return 0;
 }

samples/onenet_sample.c

@@ -24,6 +24,17 @@
 
 #include <onenet.h>
 
+#define DBG_ENABLE
+#define DBG_COLOR
+#define DBG_SECTION_NAME    "onenet.sample"
+#if ONENET_DEBUG
+#define DBG_LEVEL           DBG_LOG
+#else
+#define DBG_LEVEL           DBG_INFO
+#endif /* ONENET_DEBUG */
+
+#include <rtdbg.h>
+
 #ifdef FINSH_USING_MSH
 #include <finsh.h>
 
@@ -38,12 +49,12 @@ static void onenet_upload_entry(void *parameter)
 
         if (onenet_mqtt_upload_digit("temperature", value) < 0)
         {
-            log_e("upload has an error, stop uploading");
+            LOG_E("upload has an error, stop uploading");
             break;
         }
         else
         {
-            log_d("buffer : {\"temperature\":%d}", value);
+            LOG_D("buffer : {\"temperature\":%d}", value);
         }
 
         rt_thread_delay(rt_tick_from_millisecond(5 * 1000));
@@ -73,13 +84,13 @@ int onenet_publish_digit(int argc, char **argv)
 {
     if (argc != 3)
     {
-        log_e("onenet_publish [datastream_id]  [value]  - mqtt pulish digit data to OneNET.");
+        LOG_E("onenet_publish [datastream_id]  [value]  - mqtt pulish digit data to OneNET.");
         return -1;
     }
 
     if (onenet_mqtt_upload_digit(argv[1], atoi(argv[2])) < 0)
     {
-        log_e("upload digit data has an error!\n");
+        LOG_E("upload digit data has an error!\n");
     }
 
     return 0;
@@ -90,13 +101,13 @@ int onenet_publish_string(int argc, char **argv)
 {
     if (argc != 3)
     {
-        log_e("onenet_publish [datastream_id]  [string]  - mqtt pulish string data to OneNET.");
+        LOG_E("onenet_publish [datastream_id]  [string]  - mqtt pulish string data to OneNET.");
         return -1;
     }
 
     if (onenet_mqtt_upload_string(argv[1], argv[2]) < 0)
     {
-        log_e("upload string has an error!\n");
+        LOG_E("upload string has an error!\n");
     }
 
     return 0;
@@ -108,7 +119,7 @@ static void onenet_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **re
 {
     char res_buf[] = { "cmd is received!\n" };
 
-    log_d("recv data is %.*s\n", recv_size, recv_data);
+    LOG_D("recv data is %.*s\n", recv_size, recv_data);
 
     /* user have to malloc memory for response data */
     *resp_data = (uint8_t *) ONENET_MALLOC(strlen(res_buf));

src/onenet_http.c

@@ -28,6 +28,17 @@
 
 #include <onenet.h>
 
+#define DBG_ENABLE
+#define DBG_COLOR
+#define DBG_SECTION_NAME    "onenet.http"
+#if ONENET_DEBUG
+#define DBG_LEVEL           DBG_LOG
+#else
+#define DBG_LEVEL           DBG_INFO
+#endif /* ONENET_DEBUG */
+
+#include <rtdbg.h>
+
 #define ONENET_SEND_DATA_LEN           1024
 #define ONENET_HEAD_DATA_LEN           256
 #define ONENET_CON_URI_LEN             256
@@ -63,7 +74,7 @@ static rt_err_t onenet_upload_data(char *send_buffer)
     URI = ONENET_CALLOC(1, ONENET_CON_URI_LEN);
     if (URI == RT_NULL)
     {
-        log_e("OneNet Send data failed! No memory for URI buffer!");
+        LOG_E("OneNet Send data failed! No memory for URI buffer!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -87,7 +98,7 @@ static rt_err_t onenet_upload_data(char *send_buffer)
         goto __exit;
     }
 
-    log_d("buffer : %.*s", strlen(buffer), buffer);
+    LOG_D("buffer : %.*s", strlen(buffer), buffer);
 
 __exit:
     if (session)
@@ -115,7 +126,7 @@ static rt_err_t onenet_get_string_data(const char *ds_name, const char *str, cha
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("onenet publish string data failed! cJSON create object error return NULL!");
+        LOG_E("onenet publish string data failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -125,7 +136,7 @@ static rt_err_t onenet_get_string_data(const char *ds_name, const char *str, cha
     *out_buff = cJSON_PrintUnformatted(root);
     if (!(*out_buff))
     {
-        log_e("onenet publish string data failed! cJSON print unformatted error return NULL!");
+        LOG_E("onenet publish string data failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -150,7 +161,7 @@ static rt_err_t onenet_get_digit_data(const char *ds_name, const double digit, c
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("onenet publish digit data failed! cJSON create object error return NULL!");
+        LOG_E("onenet publish digit data failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -160,7 +171,7 @@ static rt_err_t onenet_get_digit_data(const char *ds_name, const double digit, c
     *out_buff = cJSON_PrintUnformatted(root);
     if (!(*out_buff))
     {
-        log_e("onenet publish digit data failed! cJSON print unformatted error return NULL!");
+        LOG_E("onenet publish digit data failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -263,12 +274,12 @@ static rt_err_t response_register_handlers(const unsigned char *rec_buf, const s
 
     assert(rec_buf);
 
-    log_d("response is %.*s", length, rec_buf);
+    LOG_D("response is %.*s", length, rec_buf);
 
     root = cJSON_Parse((char *)rec_buf);
     if (!root)
     {
-        log_e("onenet register device failed! cJSON Parse data error return NULL!");
+        LOG_E("onenet register device failed! cJSON Parse data error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -282,7 +293,7 @@ static rt_err_t response_register_handlers(const unsigned char *rec_buf, const s
     }
     else
     {
-        log_e("onenet register device failed! errno is %d", item->valueint);
+        LOG_E("onenet register device failed! errno is %d", item->valueint);
         return -RT_ERROR;
     }
 
@@ -312,7 +323,7 @@ static rt_err_t onenet_upload_register_device(char *send_buffer)
     URI = (char *) ONENET_CALLOC(1, ONENET_CON_URI_LEN);
     if (URI == RT_NULL)
     {
-        log_e("OneNet register device failed! No memory for URI buffer!");
+        LOG_E("OneNet register device failed! No memory for URI buffer!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -320,7 +331,7 @@ static rt_err_t onenet_upload_register_device(char *send_buffer)
     rec_buf = (unsigned char *) ONENET_CALLOC(1, ONENET_RECV_RESP_LEN);
     if (rec_buf == RT_NULL)
     {
-        log_e("OneNet register device failed! No memory for response data buffer!");
+        LOG_E("OneNet register device failed! No memory for response data buffer!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -346,7 +357,7 @@ static rt_err_t onenet_upload_register_device(char *send_buffer)
     }
     else
     {
-        log_e("OneNet register device failed! Handle response(%d) error!", session->resp_status);
+        LOG_E("OneNet register device failed! Handle response(%d) error!", session->resp_status);
     }
 
 __exit:
@@ -378,7 +389,7 @@ static rt_err_t onenet_get_register_device_data(const char *ds_name, const char
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("MQTT register device failed! cJSON create object error return NULL!");
+        LOG_E("MQTT register device failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -389,7 +400,7 @@ static rt_err_t onenet_get_register_device_data(const char *ds_name, const char
     msg_str = cJSON_PrintUnformatted(root);
     if (!msg_str)
     {
-        log_e("Device register device failed! cJSON print unformatted error return NULL!");
+        LOG_E("Device register device failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -429,7 +440,7 @@ rt_err_t onenet_http_register_device(const char *name, const char *auth_info)
     send_buffer = (char *) ONENET_CALLOC(1, ONENET_SEND_DATA_LEN);
     if (!send_buffer)
     {
-        log_e("ONENET register device failed! No memory for send buffer!");
+        LOG_E("ONENET register device failed! No memory for send buffer!");
         return -RT_ENOMEM;
     }
 
@@ -469,7 +480,7 @@ static cJSON *response_get_datapoints_handlers(const uint8_t *rec_buf)
     root = cJSON_Parse((char *) rec_buf);
     if (!root)
     {
-        log_e("MQTT processing response data failed! cJSON Parse data error return NULL!");
+        LOG_E("MQTT processing response data failed! cJSON Parse data error return NULL!");
 
         return RT_NULL;
     }
@@ -482,7 +493,7 @@ static cJSON *response_get_datapoints_handlers(const uint8_t *rec_buf)
     }
     else
     {
-        log_e("get datapoints failed! errno is %d", item->valueint);
+        LOG_E("get datapoints failed! errno is %d", item->valueint);
     }
 
     if (root)
@@ -507,14 +518,14 @@ static cJSON *onenet_http_get_datapoints(char *datastream, char *start, char *en
     URI = (char *) ONENET_CALLOC(1, ONENET_CON_URI_LEN);
     if (URI == RT_NULL)
     {
-        log_e("OneNet Send data failed! No memory for URI buffer!");
+        LOG_E("OneNet Send data failed! No memory for URI buffer!");
         goto __exit;
     }
 
     rec_buf = (unsigned char *) ONENET_CALLOC(1, ONENET_RECV_RESP_LEN);
     if (rec_buf == RT_NULL)
     {
-        log_e("OneNet recvice response data failed! No memory for response data buffer!");
+        LOG_E("OneNet recvice response data failed! No memory for response data buffer!");
         goto __exit;
     }
 
@@ -563,7 +574,7 @@ static cJSON *onenet_http_get_datapoints(char *datastream, char *start, char *en
 
     if (res_len > ONENET_HTTP_HEAD_LEN)
     {
-        log_e("response data length(%d) is greater than the default recv buffer size(%d)!", res_len, ONENET_RECV_RESP_LEN);
+        LOG_E("response data length(%d) is greater than the default recv buffer size(%d)!", res_len, ONENET_RECV_RESP_LEN);
         goto __exit;
     }
     else if (webclient_read(session, rec_buf, ONENET_RECV_RESP_LEN) > 0)
@@ -689,7 +700,7 @@ static rt_err_t response_get_datastreams_handlers(const unsigned char *rec_buf,
     root = cJSON_Parse((char *) rec_buf);
     if (!root)
     {
-        log_e("onenet get datastreams failed! cJSON Parse data error return NULL!");
+        LOG_E("onenet get datastreams failed! cJSON Parse data error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -736,7 +747,7 @@ static rt_err_t response_get_datastreams_handlers(const unsigned char *rec_buf,
     }
     else
     {
-        log_e("onenet get datastreams failed! errno is %d", item->valueint);
+        LOG_E("onenet get datastreams failed! errno is %d", item->valueint);
         result = -RT_ERROR;
     }
 
@@ -773,7 +784,7 @@ rt_err_t onenet_http_get_datastream(const char *ds_name, struct rt_onenet_ds_inf
     URI = (char *) ONENET_CALLOC(1, ONENET_CON_URI_LEN);
     if (URI == NULL)
     {
-        log_e("onenet get datastreams failed! No memory for URI buffer!");
+        LOG_E("onenet get datastreams failed! No memory for URI buffer!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -781,7 +792,7 @@ rt_err_t onenet_http_get_datastream(const char *ds_name, struct rt_onenet_ds_inf
     rec_buf = (unsigned char *) ONENET_CALLOC(1, ONENET_RECV_RESP_LEN);
     if (rec_buf == NULL)
     {
-        log_e("onenet get datastreams failed! No memory for response data buffer!");
+        LOG_E("onenet get datastreams failed! No memory for response data buffer!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -808,7 +819,7 @@ rt_err_t onenet_http_get_datastream(const char *ds_name, struct rt_onenet_ds_inf
 
     if (res_len > ONENET_HTTP_HEAD_LEN)
     {
-        log_e("response data length(%d) is greater than the default recv buffer size(%d)!", res_len, ONENET_RECV_RESP_LEN);
+        LOG_E("response data length(%d) is greater than the default recv buffer size(%d)!", res_len, ONENET_RECV_RESP_LEN);
         goto __exit;
     }
     else if (webclient_read(session, rec_buf, ONENET_RECV_RESP_LEN) > 0)

src/onenet_mqtt.c

@@ -30,6 +30,18 @@
 
 #include <onenet.h>
 
+#define DBG_ENABLE
+#define DBG_COLOR
+#define DBG_SECTION_NAME    "onenet.mqtt"
+#if ONENET_DEBUG
+#define DBG_LEVEL           DBG_LOG
+#else
+#define DBG_LEVEL           DBG_INFO
+#endif /* ONENET_DEBUG */
+
+#include <rtdbg.h>
+
+
 #ifdef RT_USING_DFS
 #include <dfs_posix.h>
 #endif
@@ -57,9 +69,9 @@ static void mqtt_callback(MQTTClient *c, MessageData *msg_data)
     assert(c);
     assert(msg_data);
 
-    log_d("topic %.*s receive a message", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data);
+    LOG_D("topic %.*s receive a message", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data);
 
-    log_d("message length is %d", msg_data->message->payloadlen);
+    LOG_D("message length is %d", msg_data->message->payloadlen);
 
     if (onenet_mqtt.cmd_rsp_cb != RT_NULL)
     {
@@ -82,17 +94,17 @@ static void mqtt_callback(MQTTClient *c, MessageData *msg_data)
 
 static void mqtt_connect_callback(MQTTClient *c)
 {
-    log_d("Enter mqtt_connect_callback!");
+    LOG_D("Enter mqtt_connect_callback!");
 }
 
 static void mqtt_online_callback(MQTTClient *c)
 {
-    log_d("Enter mqtt_online_callback!");
+    LOG_D("Enter mqtt_online_callback!");
 }
 
 static void mqtt_offline_callback(MQTTClient *c)
 {
-    log_d("Enter mqtt_offline_callback!");
+    LOG_D("Enter mqtt_offline_callback!");
 }
 
 static rt_err_t onenet_mqtt_entry(void)
@@ -112,7 +124,7 @@ static rt_err_t onenet_mqtt_entry(void)
     mq_client.readbuf = (unsigned char *) ONENET_CALLOC(1, mq_client.readbuf_size);
     if (!(mq_client.buf && mq_client.readbuf))
     {
-        log_e("No memory for MQTT client buffer!");
+        LOG_E("No memory for MQTT client buffer!");
         return -RT_ENOMEM;
     }
 
@@ -140,20 +152,20 @@ static rt_err_t onenet_get_info(void)
     {
         if (onenet_port_get_register_info(name, auth_info) < 0)
         {
-            log_e("onenet get register info fail!");
+            LOG_E("onenet get register info fail!");
             return -RT_ERROR;
         }
 
         if (onenet_http_register_device(name, auth_info) < 0)
         {
-            log_e("onenet register device fail! name is %s,auth info is %s", name, auth_info);
+            LOG_E("onenet register device fail! name is %s,auth info is %s", name, auth_info);
             return -RT_ERROR;
         }
     }
 
     if (onenet_port_get_device_info(dev_id, api_key, auth_info))
     {
-        log_e("onenet get device id fail,dev_id is %s,api_key is %s,auth_info is %s", dev_id, api_key, auth_info);
+        LOG_E("onenet get device id fail,dev_id is %s,api_key is %s,auth_info is %s", dev_id, api_key, auth_info);
         return -RT_ERROR;
     }
 
@@ -192,7 +204,7 @@ int onenet_mqtt_init(void)
 
     if (init_ok)
     {
-        log_d("onenet mqtt already init!");
+        LOG_D("onenet mqtt already init!");
         return 0;
     }
 
@@ -214,12 +226,12 @@ int onenet_mqtt_init(void)
 __exit:
     if (!result)
     {
-        log_i("RT-Thread OneNET package(V%s) initialize success.", ONENET_SW_VERSION);
+        LOG_I("RT-Thread OneNET package(V%s) initialize success.", ONENET_SW_VERSION);
         init_ok = RT_TRUE;
     }
     else
     {
-        log_e("RT-Thread OneNET package(V%s) initialize failed(%d).", ONENET_SW_VERSION, result);
+        LOG_E("RT-Thread OneNET package(V%s) initialize failed(%d).", ONENET_SW_VERSION, result);
     }
 
     return result;
@@ -268,7 +280,7 @@ static rt_err_t onenet_mqtt_get_digit_data(const char *ds_name, const double dig
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("MQTT publish digit data failed! cJSON create object error return NULL!");
+        LOG_E("MQTT publish digit data failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -278,7 +290,7 @@ static rt_err_t onenet_mqtt_get_digit_data(const char *ds_name, const double dig
     msg_str = cJSON_PrintUnformatted(root);
     if (!msg_str)
     {
-        log_e("MQTT publish digit data failed! cJSON print unformatted error return NULL!");
+        LOG_E("MQTT publish digit data failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -286,7 +298,7 @@ static rt_err_t onenet_mqtt_get_digit_data(const char *ds_name, const double dig
     *out_buff = ONENET_MALLOC(strlen(msg_str) + 3);
     if (!(*out_buff))
     {
-        log_e("ONENET mqtt upload digit data failed! No memory for send buffer!");
+        LOG_E("ONENET mqtt upload digit data failed! No memory for send buffer!");
         return -RT_ENOMEM;
     }
 
@@ -338,7 +350,7 @@ rt_err_t onenet_mqtt_upload_digit(const char *ds_name, const double digit)
     result = onenet_mqtt_publish(ONENET_TOPIC_DP, (uint8_t *)send_buffer, length);
     if (result < 0)
     {
-        log_e("onenet publish failed!");
+        LOG_E("onenet publish failed (%d)!", result);
         goto __exit;
     }
 
@@ -365,7 +377,7 @@ static rt_err_t onenet_mqtt_get_string_data(const char *ds_name, const char *str
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("MQTT publish string data failed! cJSON create object error return NULL!");
+        LOG_E("MQTT publish string data failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -375,7 +387,7 @@ static rt_err_t onenet_mqtt_get_string_data(const char *ds_name, const char *str
     msg_str = cJSON_PrintUnformatted(root);
     if (!msg_str)
     {
-        log_e("MQTT publish string data failed! cJSON print unformatted error return NULL!");
+        LOG_E("MQTT publish string data failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -383,7 +395,7 @@ static rt_err_t onenet_mqtt_get_string_data(const char *ds_name, const char *str
     *out_buff = ONENET_MALLOC(strlen(msg_str) + 3);
     if (!(*out_buff))
     {
-        log_e("ONENET mqtt upload string data failed! No memory for send buffer!");
+        LOG_E("ONENET mqtt upload string data failed! No memory for send buffer!");
         return -RT_ENOMEM;
     }
 
@@ -436,7 +448,7 @@ rt_err_t onenet_mqtt_upload_string(const char *ds_name, const char *str)
     result = onenet_mqtt_publish(ONENET_TOPIC_DP, (uint8_t *)send_buffer, length);
     if (result < 0)
     {
-        log_e("onenet mqtt publish digit data failed!");
+        LOG_E("onenet mqtt publish digit data failed!");
         goto __exit;
     }
 
@@ -478,7 +490,7 @@ static rt_err_t onenet_mqtt_get_bin_data(const char *str, const uint8_t *bin, in
     root = cJSON_CreateObject();
     if (!root)
     {
-        log_e("MQTT online push failed! cJSON create object error return NULL!");
+        LOG_E("MQTT online push failed! cJSON create object error return NULL!");
         return -RT_ENOMEM;
     }
 
@@ -488,7 +500,7 @@ static rt_err_t onenet_mqtt_get_bin_data(const char *str, const uint8_t *bin, in
     msg_str = cJSON_PrintUnformatted(root);
     if (!msg_str)
     {
-        log_e("Device online push failed! cJSON print unformatted error return NULL!");
+        LOG_E("Device online push failed! cJSON print unformatted error return NULL!");
         result = -RT_ENOMEM;
         goto __exit;
     }
@@ -556,7 +568,7 @@ rt_err_t onenet_mqtt_upload_bin(const char *ds_name, uint8_t *bin, size_t len)
     result = onenet_mqtt_publish(ONENET_TOPIC_DP, send_buffer, length);
     if (result < 0)
     {
-        log_e("onenet publish data failed(%d)!", result);
+        LOG_E("onenet publish data failed(%d)!", result);
         result = -RT_ERROR;
         goto __exit;
     }
@@ -595,7 +607,7 @@ rt_err_t onenet_mqtt_upload_bin_by_path(const char *ds_name, const char *bin_pat
 
     if (stat(bin_path, &file_stat) < 0)
     {
-        log_e("get file state fail!, bin path is %s",bin_path);
+        LOG_E("get file state fail!, bin path is %s",bin_path);
         return -RT_ERROR;
     }
     else
@@ -603,7 +615,7 @@ rt_err_t onenet_mqtt_upload_bin_by_path(const char *ds_name, const char *bin_pat
         bin_len = file_stat.st_size;
         if (bin_len > 3 * 1024 * 1024)
         {
-            log_e("bin length must be less than 3M, %s length is %d", bin_path, bin_len);
+            LOG_E("bin length must be less than 3M, %s length is %d", bin_path, bin_len);
             return -RT_ERROR;
         }
 
@@ -618,14 +630,14 @@ rt_err_t onenet_mqtt_upload_bin_by_path(const char *ds_name, const char *bin_pat
         close(fd);
         if (bin_size <= 0)
         {
-            log_e("read %s file fail!", bin_path);
+            LOG_E("read %s file fail!", bin_path);
             result = -RT_ERROR;
             goto __exit;
         }
     }
     else
     {
-        log_e("open %s file fail!", bin_path);
+        LOG_E("open %s file fail!", bin_path);
         return -RT_ERROR;
     }
 
@@ -639,7 +651,7 @@ rt_err_t onenet_mqtt_upload_bin_by_path(const char *ds_name, const char *bin_pat
     result = onenet_mqtt_publish(ONENET_TOPIC_DP, send_buffer, length);
     if (result < 0)
     {
-        log_e("onenet publish %s data failed(%d)!", bin_path, result);
+        LOG_E("onenet publish %s data failed(%d)!", bin_path, result);
         result = -RT_ERROR;
         goto __exit;
     }