485 lines
16 KiB
C
485 lines
16 KiB
C
|
/*
|
||
|
|
* Tencent is pleased to support the open source community by making IoT Hub
|
||
|
|
available.
|
||
|
|
* Copyright (C) 2016 THL A29 Limited, a Tencent company. All rights reserved.
|
||
|
|
|
||
|
|
* Licensed under the MIT License (the "License"); you may not use this file
|
||
|
|
except in
|
||
|
|
* compliance with the License. You may obtain a copy of the License at
|
||
|
|
* http://opensource.org/licenses/MIT
|
||
|
|
|
||
|
|
* Unless required by applicable law or agreed to in writing, software
|
||
|
|
distributed under the License is
|
||
|
|
* distributed on an "AS IS" basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||
|
|
KIND,
|
||
|
|
* either express or implied. See the License for the specific language
|
||
|
|
governing permissions and
|
||
|
|
* limitations under the License.
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <limits.h>
|
||
|
|
#include <stdbool.h>
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <stdlib.h>
|
||
|
|
#include <string.h>
|
||
|
|
|
||
|
|
#include "ql_api_osi.h"
|
||
|
|
|
||
|
|
#include "qcloud_iot_export.h"
|
||
|
|
#include "utils_getopt.h"
|
||
|
|
|
||
|
|
#define MAX_SIZE_OF_TOPIC (128)
|
||
|
|
#define MAX_SIZE_OF_DATA (128)
|
||
|
|
|
||
|
|
#define SUB_DEV_USE_DATA_TEMPLATE_LIGHT
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
|
||
|
|
#define LIGHT_SUB_DEV_PRODUCT_ID "BK7EEF4UIB"
|
||
|
|
#define LIGHT_SUB_DEV_NAME "dev001"
|
||
|
|
extern void *sub_dev1_thread(void *ptr, char *product_id, char *device_name);
|
||
|
|
#endif
|
||
|
|
|
||
|
|
static int sg_sub_packet_id = -1;
|
||
|
|
//static int sg_loop_count = 1;
|
||
|
|
static GatewayDeviceInfo sg_GWdevInfo;
|
||
|
|
|
||
|
|
#ifdef AUTH_MODE_CERT
|
||
|
|
static char sg_cert_file[PATH_MAX + 1]; // full path of device cert file
|
||
|
|
static char sg_key_file[PATH_MAX + 1]; // full path of device key file
|
||
|
|
#endif
|
||
|
|
|
||
|
|
void _event_handler(void *client, void *context, MQTTEventMsg *msg)
|
||
|
|
{
|
||
|
|
MQTTMessage *mqtt_messge = (MQTTMessage *)msg->msg;
|
||
|
|
uintptr_t packet_id = (uintptr_t)msg->msg;
|
||
|
|
|
||
|
|
switch (msg->event_type) {
|
||
|
|
case MQTT_EVENT_UNDEF:
|
||
|
|
Log_i("undefined event occur.");
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_DISCONNECT:
|
||
|
|
Log_i("MQTT disconnect.");
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_RECONNECT:
|
||
|
|
Log_i("MQTT reconnect.");
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_PUBLISH_RECVEIVED:
|
||
|
|
Log_i(
|
||
|
|
"topic message arrived but without any related handle: topic=%.*s, "
|
||
|
|
"topic_msg=%.*s",
|
||
|
|
mqtt_messge->topic_len, mqtt_messge->ptopic, mqtt_messge->payload_len, mqtt_messge->payload);
|
||
|
|
break;
|
||
|
|
case MQTT_EVENT_SUBCRIBE_SUCCESS:
|
||
|
|
Log_i("subscribe success, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
sg_sub_packet_id = packet_id;
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_SUBCRIBE_TIMEOUT:
|
||
|
|
Log_i("subscribe wait ack timeout, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
sg_sub_packet_id = packet_id;
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_SUBCRIBE_NACK:
|
||
|
|
Log_i("subscribe nack, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
sg_sub_packet_id = packet_id;
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_UNSUBCRIBE_SUCCESS:
|
||
|
|
Log_i("unsubscribe success, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_UNSUBCRIBE_TIMEOUT:
|
||
|
|
Log_i("unsubscribe timeout, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_UNSUBCRIBE_NACK:
|
||
|
|
Log_i("unsubscribe nack, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_PUBLISH_SUCCESS:
|
||
|
|
Log_i("publish success, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_PUBLISH_TIMEOUT:
|
||
|
|
Log_i("publish timeout, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
|
||
|
|
case MQTT_EVENT_PUBLISH_NACK:
|
||
|
|
Log_i("publish nack, packet-id=%u", (unsigned int)packet_id);
|
||
|
|
break;
|
||
|
|
default:
|
||
|
|
Log_i("Should NOT arrive here.");
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static void _message_handler(void *client, MQTTMessage *message, void *user_data)
|
||
|
|
{
|
||
|
|
if (message == NULL) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
Log_i("Receive Message With topicName:%.*s, payload:%.*s", (int)message->topic_len, message->ptopic,
|
||
|
|
(int)message->payload_len, (char *)message->payload);
|
||
|
|
}
|
||
|
|
|
||
|
|
static int _setup_connect_init_params(GatewayInitParam *init_params)
|
||
|
|
{
|
||
|
|
int rc;
|
||
|
|
|
||
|
|
rc = HAL_GetGwDevInfo((void *)&sg_GWdevInfo);
|
||
|
|
if (QCLOUD_RET_SUCCESS != rc) {
|
||
|
|
Log_e("Get gateway dev info err,rc:%d", rc);
|
||
|
|
return rc;
|
||
|
|
}
|
||
|
|
|
||
|
|
init_params->init_param.region = sg_GWdevInfo.gw_info.region;
|
||
|
|
init_params->init_param.product_id = sg_GWdevInfo.gw_info.product_id;
|
||
|
|
init_params->init_param.device_name = sg_GWdevInfo.gw_info.device_name;
|
||
|
|
|
||
|
|
#ifdef AUTH_MODE_CERT
|
||
|
|
// char certs_dir[PATH_MAX + 1] = "certs";
|
||
|
|
// char current_path[PATH_MAX + 1];
|
||
|
|
// char *cwd = getcwd(current_path, sizeof(current_path));
|
||
|
|
// if (cwd == NULL) {
|
||
|
|
// Log_e("getcwd return NULL");
|
||
|
|
// return QCLOUD_ERR_FAILURE;
|
||
|
|
// }
|
||
|
|
sprintf(sg_cert_file, "%s", sg_GWdevInfo.gw_info.dev_cert_file_name);
|
||
|
|
sprintf(sg_key_file, "%s", sg_GWdevInfo.gw_info.dev_key_file_name);
|
||
|
|
|
||
|
|
init_params->init_param.cert_file = sg_cert_file;
|
||
|
|
init_params->init_param.key_file = sg_key_file;
|
||
|
|
#else
|
||
|
|
init_params->init_param.device_secret = sg_GWdevInfo.gw_info.device_secret;
|
||
|
|
#endif
|
||
|
|
|
||
|
|
init_params->init_param.command_timeout = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
|
||
|
|
init_params->init_param.auto_connect_enable = 1;
|
||
|
|
init_params->init_param.event_handle.h_fp = _event_handler;
|
||
|
|
init_params->init_param.keep_alive_interval_ms = QCLOUD_IOT_MQTT_KEEP_ALIVE_INTERNAL;
|
||
|
|
|
||
|
|
return QCLOUD_RET_SUCCESS;
|
||
|
|
}
|
||
|
|
|
||
|
|
//static int parse_arguments(int argc, char **argv)
|
||
|
|
//{
|
||
|
|
// int c;
|
||
|
|
// while ((c = utils_getopt(argc, argv, "c:l:")) != EOF) switch (c) {
|
||
|
|
// case 'c':
|
||
|
|
// if (HAL_SetDevInfoFile(utils_optarg))
|
||
|
|
// return -1;
|
||
|
|
// break;
|
||
|
|
//
|
||
|
|
// case 'l':
|
||
|
|
// sg_loop_count = atoi(utils_optarg);
|
||
|
|
// if (sg_loop_count > 10000)
|
||
|
|
// sg_loop_count = 10000;
|
||
|
|
// else if (sg_loop_count < 0)
|
||
|
|
// sg_loop_count = 1;
|
||
|
|
// break;
|
||
|
|
//
|
||
|
|
// default:
|
||
|
|
// HAL_Printf(
|
||
|
|
// "usage: %s [options]\n"
|
||
|
|
// " [-c <config file for DeviceInfo>] \n"
|
||
|
|
// " [-l <loop count>] \n",
|
||
|
|
// argv[0]);
|
||
|
|
// return -1;
|
||
|
|
// }
|
||
|
|
// return 0;
|
||
|
|
//}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* sub dev thread runner
|
||
|
|
*/
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT // show subdev with data template.
|
||
|
|
static void sub_dev_thread(void *user_arg)
|
||
|
|
{
|
||
|
|
sub_dev1_thread(user_arg, LIGHT_SUB_DEV_PRODUCT_ID, LIGHT_SUB_DEV_NAME);
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* show gateway dynamic bind/unbind sub-devices
|
||
|
|
*/
|
||
|
|
#ifdef GATEWAY_DYN_BIND_SUBDEV_ENABLED
|
||
|
|
static int add_new_binded_sub_dev(GatewayDeviceInfo *pGateway, DeviceInfo *pNewSubDev)
|
||
|
|
{
|
||
|
|
int ret;
|
||
|
|
if(pGateway->sub_dev_num < MAX_NUM_SUB_DEV) {
|
||
|
|
memcpy((char *)&pGateway->sub_dev_info[pGateway->sub_dev_num], (char *)pNewSubDev, sizeof(DeviceInfo));
|
||
|
|
pGateway->sub_dev_num++;
|
||
|
|
ret = QCLOUD_RET_SUCCESS; //you can save gateway info to local flash for persistent storage
|
||
|
|
} else {
|
||
|
|
ret = QCLOUD_ERR_FAILURE;
|
||
|
|
}
|
||
|
|
|
||
|
|
return ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
static int show_subdev_bind_unbind(void *client, GatewayParam *param)
|
||
|
|
{
|
||
|
|
int rc;
|
||
|
|
|
||
|
|
//ajust for your bind device info
|
||
|
|
DeviceInfo subDev;
|
||
|
|
memset((char *)&subDev, 0, sizeof(DeviceInfo));
|
||
|
|
strncpy(subDev.product_id, "BIND_PID", MAX_SIZE_OF_PRODUCT_ID);
|
||
|
|
strncpy(subDev.device_name, "BIND_DEV_NAME", MAX_SIZE_OF_DEVICE_NAME);
|
||
|
|
#ifdef AUTH_MODE_CERT
|
||
|
|
strncpy(subDev.dev_cert_file_name, "BIND_CERT_FILE_NAME", MAX_SIZE_OF_DEVICE_CERT_FILE_NAME);
|
||
|
|
strncpy(subDev.dev_key_file_name, "BIND_KEY_FILE_NAME", MAX_SIZE_OF_DEVICE_SECRET_FILE_NAME);
|
||
|
|
|
||
|
|
#else
|
||
|
|
strncpy(subDev.device_secret, "BIND_DEV_PSK", MAX_SIZE_OF_DEVICE_SECRET);
|
||
|
|
#endif
|
||
|
|
Log_d("bind subdev %s/%s", subDev.product_id, subDev.device_name);
|
||
|
|
|
||
|
|
//bind sub dev
|
||
|
|
rc = IOT_Gateway_Subdev_Bind(client, param, &subDev);
|
||
|
|
if(QCLOUD_ERR_BIND_REPEATED_REQ == rc) {
|
||
|
|
Log_d("%s/%s has been binded", subDev.product_id, subDev.device_name);
|
||
|
|
rc = IOT_Gateway_Subdev_Unbind(client, param, &subDev);
|
||
|
|
if(QCLOUD_RET_SUCCESS != rc) {
|
||
|
|
Log_e("unbind %s/%s fail,rc:%d", subDev.product_id, subDev.device_name, rc);
|
||
|
|
} else {
|
||
|
|
Log_d("unbind %s/%s success", subDev.product_id, subDev.device_name);
|
||
|
|
rc = IOT_Gateway_Subdev_Bind(client, param, &subDev);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if(QCLOUD_RET_SUCCESS == rc) {
|
||
|
|
Log_d("bind %s/%s success", subDev.product_id, subDev.device_name);
|
||
|
|
add_new_binded_sub_dev(&sg_GWdevInfo, &subDev);
|
||
|
|
} else {
|
||
|
|
Log_e("bind %s/%s fail,rc:%d", subDev.product_id, subDev.device_name, rc);
|
||
|
|
}
|
||
|
|
|
||
|
|
return rc;
|
||
|
|
}
|
||
|
|
|
||
|
|
#endif
|
||
|
|
|
||
|
|
|
||
|
|
/*Gateway should enable multithread*/
|
||
|
|
void gateway_sample(void *arg)
|
||
|
|
{
|
||
|
|
int rc = QCLOUD_ERR_FAILURE;
|
||
|
|
int errCount = 0;
|
||
|
|
int i;
|
||
|
|
int size;
|
||
|
|
void * client = NULL;
|
||
|
|
GatewayDeviceInfo *gw = &sg_GWdevInfo;
|
||
|
|
GatewayParam param = DEFAULT_GATEWAY_PARAMS;
|
||
|
|
DeviceInfo * subDevInfo;
|
||
|
|
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
|
||
|
|
ThreadParams sub_dev1_thread_params = {0};
|
||
|
|
#endif
|
||
|
|
|
||
|
|
IOT_Log_Set_Level(eLOG_DEBUG);
|
||
|
|
// parse arguments for device info file and loop test;
|
||
|
|
// rc = parse_arguments(argc, argv);
|
||
|
|
// if (rc != QCLOUD_RET_SUCCESS) {
|
||
|
|
// Log_e("parse arguments error, rc = %d", rc);
|
||
|
|
// return rc;
|
||
|
|
// }
|
||
|
|
|
||
|
|
GatewayInitParam init_params = DEFAULT_GATEWAY_INIT_PARAMS;
|
||
|
|
rc = _setup_connect_init_params(&init_params);
|
||
|
|
if (rc != QCLOUD_RET_SUCCESS) {
|
||
|
|
Log_e("init params err,rc=%d", rc);
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
|
||
|
|
client = IOT_Gateway_Construct(&init_params);
|
||
|
|
if (client == NULL) {
|
||
|
|
Log_e("client constructed failed.");
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
|
||
|
|
#ifdef MULTITHREAD_ENABLED
|
||
|
|
rc = IOT_Gateway_Start_Yield_Thread(client);
|
||
|
|
if (rc != QCLOUD_RET_SUCCESS) {
|
||
|
|
Log_e("init params err,rc=%d", rc);
|
||
|
|
goto exit;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
// set GateWay device info
|
||
|
|
param.product_id = gw->gw_info.product_id;
|
||
|
|
param.device_name = gw->gw_info.device_name;
|
||
|
|
|
||
|
|
|
||
|
|
#ifdef GATEWAY_DYN_BIND_SUBDEV_ENABLED
|
||
|
|
//show gateway dynamic bind/unbind sub-devices
|
||
|
|
show_subdev_bind_unbind(client, ¶m);
|
||
|
|
#endif
|
||
|
|
|
||
|
|
// make sub-device online
|
||
|
|
for (i = 0; i < gw->sub_dev_num; i++) {
|
||
|
|
subDevInfo = &gw->sub_dev_info[i];
|
||
|
|
param.subdev_product_id = subDevInfo->product_id;
|
||
|
|
param.subdev_device_name = subDevInfo->device_name;
|
||
|
|
|
||
|
|
rc = IOT_Gateway_Subdev_Online(client, ¶m);
|
||
|
|
if (rc != QCLOUD_RET_SUCCESS) {
|
||
|
|
Log_e("subDev Pid:%s devName:%s online fail.", subDevInfo->product_id, subDevInfo->device_name);
|
||
|
|
errCount++;
|
||
|
|
} else {
|
||
|
|
Log_d("subDev Pid:%s devName:%s online success.", subDevInfo->product_id, subDevInfo->device_name);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (errCount > 0) {
|
||
|
|
Log_e("%d of %d sub devices online fail", errCount, gw->sub_dev_num);
|
||
|
|
}
|
||
|
|
|
||
|
|
// subscribe sub-device data_template down stream topic for example
|
||
|
|
char topic_filter[MAX_SIZE_OF_TOPIC + 1];
|
||
|
|
SubscribeParams sub_param = DEFAULT_SUB_PARAMS;
|
||
|
|
for (i = 0; i < gw->sub_dev_num; i++) {
|
||
|
|
subDevInfo = &gw->sub_dev_info[i];
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT // subdev with data template example.
|
||
|
|
ql_task_t sub_dev1_task = NULL;
|
||
|
|
if ((0 == strcmp(subDevInfo->product_id, LIGHT_SUB_DEV_PRODUCT_ID)) &&
|
||
|
|
(0 == strcmp(subDevInfo->device_name, LIGHT_SUB_DEV_NAME))) {
|
||
|
|
//sub_dev1_thread_params.thread_func = sub_dev_thread;
|
||
|
|
//sub_dev1_thread_params.thread_name = "sub_dev1_thread";
|
||
|
|
//sub_dev1_thread_params.user_arg = client;
|
||
|
|
//sub_dev1_thread_params.stack_size = 4096;
|
||
|
|
//sub_dev1_thread_params.priority = 1;
|
||
|
|
|
||
|
|
int rc = ql_rtos_task_create(&sub_dev1_task, 10*1024, APP_PRIORITY_NORMAL, "sub_dev1_thread", sub_dev_thread, client, 5);
|
||
|
|
|
||
|
|
//int rc = HAL_ThreadCreate(&sub_dev1_thread_params);
|
||
|
|
if (rc) {
|
||
|
|
Log_e("create sub_dev1_thread fail: %d", rc);
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
memset(topic_filter, 0, MAX_SIZE_OF_TOPIC + 1);
|
||
|
|
size = HAL_Snprintf(topic_filter, MAX_SIZE_OF_TOPIC, "$thing/down/property/%s/%s", subDevInfo->product_id,
|
||
|
|
subDevInfo->device_name);
|
||
|
|
|
||
|
|
if (size < 0 || size > MAX_SIZE_OF_TOPIC) {
|
||
|
|
Log_e("buf size < topic length!");
|
||
|
|
rc = QCLOUD_ERR_FAILURE;
|
||
|
|
goto exit;
|
||
|
|
}
|
||
|
|
|
||
|
|
sub_param.on_message_handler = _message_handler;
|
||
|
|
rc = IOT_Gateway_Subscribe(client, topic_filter, &sub_param);
|
||
|
|
if (rc < 0) {
|
||
|
|
Log_e("IOT_Gateway_Subscribe fail.");
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
HAL_SleepMs(2000); /*wait subcribe ack*/
|
||
|
|
|
||
|
|
// publish to sub-device data_template up stream topic for example
|
||
|
|
PublishParams pub_param = DEFAULT_PUB_PARAMS;
|
||
|
|
pub_param.qos = QOS0;
|
||
|
|
|
||
|
|
// pub_param.payload =
|
||
|
|
//"{\"method\":\"report\",\"clientToken\":\"123\",\"params\":{\"data\":\"err
|
||
|
|
// reply wil received\"}}";
|
||
|
|
pub_param.payload = "{\"method\":\"report\",\"clientToken\":\"123\",\"params\":{}}";
|
||
|
|
pub_param.payload_len = strlen(pub_param.payload);
|
||
|
|
for (i = 0; i < gw->sub_dev_num; i++) {
|
||
|
|
subDevInfo = &gw->sub_dev_info[i];
|
||
|
|
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
|
||
|
|
if ((0 == strcmp(subDevInfo->product_id, LIGHT_SUB_DEV_PRODUCT_ID)) &&
|
||
|
|
(0 == strcmp(subDevInfo->device_name, LIGHT_SUB_DEV_NAME))) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
memset(topic_filter, 0, MAX_SIZE_OF_TOPIC + 1);
|
||
|
|
size = HAL_Snprintf(topic_filter, MAX_SIZE_OF_TOPIC, "$thing/up/property/%s/%s", subDevInfo->product_id,
|
||
|
|
subDevInfo->device_name);
|
||
|
|
if (size < 0 || size > MAX_SIZE_OF_TOPIC) {
|
||
|
|
Log_e("buf size < topic length!");
|
||
|
|
return ;
|
||
|
|
}
|
||
|
|
|
||
|
|
rc = IOT_Gateway_Publish(client, topic_filter, &pub_param);
|
||
|
|
if (rc < 0) {
|
||
|
|
Log_e("IOT_Gateway_Publish fail.");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
exit:
|
||
|
|
|
||
|
|
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
|
||
|
|
if (0 != sub_dev1_thread_params.thread_id) {
|
||
|
|
//pthread_join(sub_dev1_thread_params.thread_id, NULL);
|
||
|
|
}
|
||
|
|
#endif
|
||
|
|
|
||
|
|
// set GateWay device info
|
||
|
|
param.product_id = gw->gw_info.product_id;
|
||
|
|
param.device_name = gw->gw_info.device_name;
|
||
|
|
// make sub-device offline
|
||
|
|
errCount = 0;
|
||
|
|
for (i = 0; i < gw->sub_dev_num; i++) {
|
||
|
|
subDevInfo = &gw->sub_dev_info[i];
|
||
|
|
param.subdev_product_id = subDevInfo->product_id;
|
||
|
|
param.subdev_device_name = subDevInfo->device_name;
|
||
|
|
|
||
|
|
rc = IOT_Gateway_Subdev_Offline(client, ¶m);
|
||
|
|
if (rc != QCLOUD_RET_SUCCESS) {
|
||
|
|
Log_e("subDev Pid:%s devName:%s offline fail.", subDevInfo->product_id, subDevInfo->device_name);
|
||
|
|
errCount++;
|
||
|
|
} else {
|
||
|
|
Log_d("subDev Pid:%s devName:%s offline success.", subDevInfo->product_id, subDevInfo->device_name);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (errCount > 0) {
|
||
|
|
Log_e("%d of %d sub devices offline fail", errCount, gw->sub_dev_num);
|
||
|
|
}
|
||
|
|
#ifdef MULTITHREAD_ENABLED
|
||
|
|
// stop running thread
|
||
|
|
IOT_Gateway_Stop_Yield_Thread(client);
|
||
|
|
rc = IOT_Gateway_Destroy(client);
|
||
|
|
#endif
|
||
|
|
}
|
||
|
|
|
||
|
|
int gateway_sample_start(void)
|
||
|
|
{
|
||
|
|
int err = 0;
|
||
|
|
int count = 0;
|
||
|
|
ql_task_t gateway_sample_task = NULL;
|
||
|
|
/* 主循环进入休眠 */
|
||
|
|
while (count < 10)
|
||
|
|
{
|
||
|
|
count++;
|
||
|
|
ql_rtos_task_sleep_s(1);
|
||
|
|
Log_e("ql_qcloud_sdk_gateway_sample_start_init -0x%04X\n", err);
|
||
|
|
}
|
||
|
|
err = ql_rtos_task_create(&gateway_sample_task, 10*1024, APP_PRIORITY_NORMAL, "gateway_sample", gateway_sample, NULL, 5);
|
||
|
|
|
||
|
|
if (err != QL_OSI_SUCCESS)
|
||
|
|
{
|
||
|
|
return -1;
|
||
|
|
}
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|