/vendor/hisilicon/hispark_pegasus/demo/iottencent_demo/ |
H A D | iot_profile.c | 187 static char *MakeProfileCmdResp(IoTCmdResp_t *payload) in MakeProfileCmdResp() argument 202 retCode = cJSON_CreateNumber(payload->retCode); in MakeProfileCmdResp() 210 if (payload->respName != NULL) { in MakeProfileCmdResp() 211 respName = cJSON_CreateString(payload->respName); in MakeProfileCmdResp() 221 if (payload->paras != NULL) { in MakeProfileCmdResp() 222 paras = MakeKvs(payload->paras); in MakeProfileCmdResp() 237 static char *MakeProfilePropertyReport(IoTProfileService_t *payload) in MakeProfilePropertyReport() argument 250 services = MakeServices(payload); in MakeProfilePropertyReport() 267 static char *MakeProfileReport(WeChatProfile *payload) in MakeProfileReport() argument 290 cJSON_AddItemToObject(root, payload in MakeProfileReport() 314 IoTProfilePropertyReport(char *deviceID, WeChatProfile *payload) IoTProfilePropertyReport() argument [all...] |
H A D | iot_main.h | 19 typedef void (*fnMsgCallBack)(int qos, const char *topic, const char *payload); 35 * @param payload: the mqtt payload 42 int IotSendMsg(int qos, const char *topic, const char *payload);
|
H A D | iot_main.c | 64 const char *payload; member 108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack() 110 msg->payload = buf; in MsgRcvCallBack() 111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack() 136 pubMsg.payload = (void *)msg->payload; in MqttProcessQueueMsg() 137 pubMsg.payloadlen = (int)strlen(msg->payload); in MqttProcessQueueMsg() 149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in MqttProcessQueueMsg() 172 IOT_LOG_DEBUG("QUEUEMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in ProcessQueueMsg() 282 int IotSendMsg(int qos, const char *topic, const char *payload) in IotSendMsg() argument [all...] |
H A D | app_demo_iot.c | 78 // < The payload here is the json string 79 static void DemoMsgRcvCallBack(int qos, const char *topic, const char *payload) in DemoMsgRcvCallBack() argument 81 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", qos, topic, payload); in DemoMsgRcvCallBack() 83 if (strstr(payload, WECHAT_SUBSCRIBE_LIGHT) != NULL) { in DemoMsgRcvCallBack() 84 if (strstr(payload, WECHAT_SUBSCRIBE_LIGHT_OFF_STATE) != NULL) { in DemoMsgRcvCallBack()
|
H A D | iot_profile.h | 91 int IoTProfilePropertyReport(char *deviceID, WeChatProfile *payload);
|
/vendor/hisilicon/hispark_pegasus/demo/mqtt_demo/ |
H A D | iot_profile.c | 187 static char *MakeProfileCmdResp(IoTCmdResp_t *payload) in MakeProfileCmdResp() argument 202 retCode = cJSON_CreateNumber(payload->retCode); in MakeProfileCmdResp() 210 if (payload->respName != NULL) { in MakeProfileCmdResp() 211 respName = cJSON_CreateString(payload->respName); in MakeProfileCmdResp() 221 if (payload->paras != NULL) { in MakeProfileCmdResp() 222 paras = MakeKvs(payload->paras); in MakeProfileCmdResp() 237 static char *MakeProfilePropertyReport(IoTProfileService_t *payload) in MakeProfilePropertyReport() argument 250 services = MakeServices(payload); in MakeProfilePropertyReport() 267 static char *MakeProfileReport(WeChatProfile *payload) in MakeProfileReport() argument 290 cJSON_AddItemToObject(root, payload in MakeProfileReport() 314 IoTProfilePropertyReport(char *deviceID, WeChatProfile *payload) IoTProfilePropertyReport() argument [all...] |
H A D | iot_main.h | 19 typedef void (*fnMsgCallBack)(int qos, const char *topic, const char *payload); 35 * @param payload: the mqtt payload 42 int IotSendMsg(int qos, const char *topic, const char *payload);
|
H A D | iot_main.c | 64 const char *payload; member 108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack() 110 msg->payload = buf; in MsgRcvCallBack() 111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack() 136 pubMsg.payload = (void *)msg->payload; in MqttProcessQueueMsg() 137 pubMsg.payloadlen = (int)strlen(msg->payload); in MqttProcessQueueMsg() 149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in MqttProcessQueueMsg() 172 IOT_LOG_DEBUG("QUEUEMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in ProcessQueueMsg() 282 int IotSendMsg(int qos, const char *topic, const char *payload) in IotSendMsg() argument [all...] |
H A D | app_demo_iot.c | 78 // < The payload here is the json string 79 static void DemoMsgRcvCallBack(int qos, const char *topic, const char *payload) in DemoMsgRcvCallBack() argument 81 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", qos, topic, payload); in DemoMsgRcvCallBack() 83 if (strstr(payload, WECHAT_SUBSCRIBE_LIGHT) != NULL) { in DemoMsgRcvCallBack() 84 if (strstr(payload, WECHAT_SUBSCRIBE_LIGHT_OFF_STATE) != NULL) { in DemoMsgRcvCallBack()
|
H A D | iot_profile.h | 91 int IoTProfilePropertyReport(char *deviceID, WeChatProfile *payload);
|
/vendor/hisilicon/hispark_pegasus/demo/coap_demo/ |
H A D | iot_profile.c | 185 static char *MakeProfileCmdResp(IoTCmdRespT *payload) in MakeProfileCmdResp() argument 200 retCode = cJSON_CreateNumber(payload->retCode); in MakeProfileCmdResp() 209 if (payload->respName != NULL) { in MakeProfileCmdResp() 210 respName = cJSON_CreateString(payload->respName); in MakeProfileCmdResp() 220 if (payload->paras != NULL) { in MakeProfileCmdResp() 221 paras = MakeKvs(payload->paras); in MakeProfileCmdResp() 237 int IoTProfileCmdResp(const char *deviceID, IoTCmdRespT *payload) in IoTProfileCmdResp() argument 243 if ((deviceID == NULL) || (payload == NULL) || (payload->requestID == NULL)) { in IoTProfileCmdResp() 247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload in IoTProfileCmdResp() 261 MakeProfilePropertyReport(IoTProfileServiceT *payload) MakeProfilePropertyReport() argument 289 IoTProfilePropertyReport(char *deviceID, IoTProfileServiceT *payload) IoTProfilePropertyReport() argument [all...] |
H A D | iot_main.h | 19 typedef void (*FnMsgCallBack)(int qos, const char *topic, const char *payload); 38 * @param payload: the mqtt payload 43 int IotSendMsg(int qos, const char *topic, const char *payload);
|
H A D | iot_main.c | 60 const char *payload; member 111 ret = memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack() 116 msg->payload = buf; in MsgRcvCallBack() 117 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack() 141 pubmsg.payload = (void *)msg->payload; in IoTMsgProcess() 142 pubmsg.payloadlen = (int)strlen(msg->payload); in IoTMsgProcess() 154 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess() 314 int IotSendMsg(int qos, const char *topic, const char *payload) in IotSendMsg() argument 322 bufSize = strlen(topic) + 1 + strlen(payload) in IotSendMsg() [all...] |
H A D | iot_profile.h | 62 * and you must supplied the device id, and the payload defines as IoTCmdResp_t 64 int IoTProfileCmdResp(const char *deviceID, IoTCmdRespT *payload); 69 int IoTProfilePropertyReport(char *deviceID, IoTProfileServiceT *payload);
|
H A D | app_demo_iot.c | 33 // The payload here is the json string 34 static void DemoMsgRcvCallBack(int qos, const char *topic, const char *payload) in DemoMsgRcvCallBack() argument 39 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", qos, topic, payload); in DemoMsgRcvCallBack()
|
/vendor/hisilicon/hispark_pegasus/demo/oc_demo/ |
H A D | iot_profile.c | 184 static char *MakeProfileCmdResp(IoTCmdResp *payload) in MakeProfileCmdResp() argument 199 retCode = cJSON_CreateNumber(payload->retCode); in MakeProfileCmdResp() 208 if (payload->respName != NULL) { in MakeProfileCmdResp() 209 respName = cJSON_CreateString(payload->respName); in MakeProfileCmdResp() 219 if (payload->paras != NULL) { in MakeProfileCmdResp() 220 paras = MakeKvs(payload->paras); in MakeProfileCmdResp() 237 int IoTProfileCmdResp(char *deviceID, IoTCmdResp *payload) in IoTProfileCmdResp() argument 243 if ((deviceID == NULL) || (payload == NULL) || (payload->requestID == NULL)) { in IoTProfileCmdResp() 247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload in IoTProfileCmdResp() 261 MakeProfilePropertyReport(IoTProfileService *payload) MakeProfilePropertyReport() argument 289 IoTProfilePropertyReport(char *deviceID, IoTProfileService *payload) IoTProfilePropertyReport() argument [all...] |
H A D | iot_main.h | 19 typedef void (*FnMsgCallBack)(int qos, const char *topic, const char *payload); 38 * @param payload: the mqtt payload 43 int IotSendMsg(int qos, const char *topic, const char *payload);
|
H A D | iot_main.c | 61 const char *payload; member 108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack() 110 msg->payload = buf; in MsgRcvCallBack() 111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack() 135 pubmsg.payload = (void *)msg->payload; in IoTMsgProcess() 136 pubmsg.payloadlen = (int)strlen(msg->payload); in IoTMsgProcess() 148 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess() 303 int IotSendMsg(int qos, const char *topic, const char *payload) in IotSendMsg() argument 310 bufSize = strlen(topic) + 1 + strlen(payload) in IotSendMsg() [all...] |
H A D | app_demo_iot.c | 77 static void TrafficLightMsgRcvCallBack(char *payload) in TrafficLightMsgRcvCallBack() argument 81 IOT_LOG_DEBUG("PAYLOAD:%s\r\n", payload); in TrafficLightMsgRcvCallBack() 82 if (strstr(payload, TRAFFIC_LIGHT_CMD_CONTROL_MODE) != NULL) { in TrafficLightMsgRcvCallBack() 84 if (strstr(payload, TRAFFIC_LIGHT_YELLOW_ON_PAYLOAD) != NULL) { // YELLOW LED in TrafficLightMsgRcvCallBack() 91 } else if (strstr(payload, TRAFFIC_LIGHT_RED_ON_PAYLOAD) != NULL) { // RED LED in TrafficLightMsgRcvCallBack() 98 } else if (strstr(payload, TRAFFIC_LIGHT_GREEN_ON_PAYLOAD) != NULL) { // GREEN LED in TrafficLightMsgRcvCallBack() 107 } else if (strstr(payload, TRAFFIC_LIGHT_CMD_AUTO_MODE) != NULL) { // Auto module in TrafficLightMsgRcvCallBack() 110 } else if (strstr(payload, TRAFFIC_LIGHT_CMD_HUMAN_MODE) != NULL) { // Human module in TrafficLightMsgRcvCallBack() 112 if (strstr(payload, TRAFFIC_LIGHT_HUMAN_INTERVENTION_ON) != NULL) { in TrafficLightMsgRcvCallBack() 114 } else if (strstr(payload, TRAFFIC_LIGHT_HUMAN_INTERVENTION_OF in TrafficLightMsgRcvCallBack() 129 DemoMsgRcvCallBack(int qos, const char *topic, char *payload) DemoMsgRcvCallBack() argument [all...] |
H A D | iot_profile.h | 92 * and you must supplied the device id, and the payload defines as IoTCmdResp_t 95 int IoTProfileCmdResp(char *deviceID, IoTCmdResp *payload); 100 int IoTProfilePropertyReport(char *deviceID, IoTProfileService *payload);
|