Searched refs:queueID (Results 1 – 7 of 7) sorted by relevance
| /vendor/hisilicon/hispark_pegasus/demo/iottencent_demo/ |
| D | iot_main.c | 70 unsigned int queueID; member
112 if (IOT_SUCCESS != osMessageQueuePut(gIoTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in MsgRcvCallBack()
170 ret = osMessageQueueGet(gIoTAppCb.queueID, &msg, &msgSize, timeout); in ProcessQueueMsg()
260 gIoTAppCb.queueID = osMessageQueueNew(CN_QUEUE_MSGNUM, CN_QUEUE_MSGSIZE, NULL); in IoTMain()
306 if (IOT_SUCCESS != osMessageQueuePut(gIoTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in IotSendMsg()
|
| D | app_demo_iot.c | 44 hi_u32 queueID; member
|
| /vendor/hisilicon/hispark_pegasus/demo/mqtt_demo/ |
| D | iot_main.c | 70 unsigned int queueID; member
112 if (IOT_SUCCESS != osMessageQueuePut(gIoTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in MsgRcvCallBack()
170 ret = osMessageQueueGet(gIoTAppCb.queueID, &msg, &msgSize, timeout); in ProcessQueueMsg()
260 gIoTAppCb.queueID = osMessageQueueNew(CN_QUEUE_MSGNUM, CN_QUEUE_MSGSIZE, NULL); in IoTMain()
306 if (IOT_SUCCESS != osMessageQueuePut(gIoTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in IotSendMsg()
|
| D | app_demo_iot.c | 44 hi_u32 queueID; member
|
| /vendor/hisilicon/hispark_pegasus/demo/oc_demo/ |
| D | iot_main.c | 67 hi_u32 queueID; member
112 if (IOT_SUCCESS != osMessageQueuePut(g_ioTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in MsgRcvCallBack()
171 ret = osMessageQueueGet(g_ioTAppCb.queueID, &msg, &msgSize, timeout); in ProcessQueueMsg()
285 g_ioTAppCb.queueID = osMessageQueueNew(CN_QUEUE_MSGNUM, CN_QUEUE_MSGSIZE, NULL); in IoTMain()
327 if (osMessageQueuePut(g_ioTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT) != IOT_SUCCESS) { in IotSendMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/coap_demo/ |
| D | iot_main.c | 66 hi_u32 queueID; member
118 if (IOT_SUCCESS != osMessageQueuePut(g_ioTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in MsgRcvCallBack()
177 ret = osMessageQueueGet(g_ioTAppCb.queueID, &msg, &msgSize, timeout); in ProcessQueueMsg()
296 g_ioTAppCb.queueID = osMessageQueueNew(CN_QUEUE_MSGNUM, CN_QUEUE_MSGSIZE, NULL); in IoTMain()
345 if (IOT_SUCCESS != osMessageQueuePut(g_ioTAppCb.queueID, &msg, 0, CN_QUEUE_WAITTIMEOUT)) { in IotSendMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/udp_demo/ |
| D | udp_server.c | 52 hi_u32 queueID; member
|