|
|
@ -435,8 +435,6 @@ void *_mqtt_manage_thread(void *args)
|
|
|
|
time_t cur_time, report_time, heartbeat_time;
|
|
|
|
time_t cur_time, report_time, heartbeat_time;
|
|
|
|
int diff_time;
|
|
|
|
int diff_time;
|
|
|
|
|
|
|
|
|
|
|
|
//_mqtt_param_init();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
IOTA_SetPrintLogCallback(_mqtt_iota_log_print);
|
|
|
|
IOTA_SetPrintLogCallback(_mqtt_iota_log_print);
|
|
|
|
|
|
|
|
|
|
|
|
ret = IOTA_Init(".", ".");
|
|
|
|
ret = IOTA_Init(".", ".");
|
|
|
@ -448,7 +446,7 @@ void *_mqtt_manage_thread(void *args)
|
|
|
|
|
|
|
|
|
|
|
|
_mqtt_iota_confing_set();
|
|
|
|
_mqtt_iota_confing_set();
|
|
|
|
|
|
|
|
|
|
|
|
//_mqtt_iota_callback_set();
|
|
|
|
_mqtt_iota_callback_set();
|
|
|
|
|
|
|
|
|
|
|
|
ret = IOTA_Login();
|
|
|
|
ret = IOTA_Login();
|
|
|
|
LOG("IOTA_Login, retval=%d", ret);
|
|
|
|
LOG("IOTA_Login, retval=%d", ret);
|
|
|
|