| /vendor/hisilicon/hispark_pegasus/demo/udpserver_demo/ |
| H A D | udp_server_test.c | 22 static char message[128] = ""; variable
44 retval = recvfrom(sockfd, message, sizeof(message), 0, (struct sockaddr *)&clientAddr, &clientAddrLen);
50 printf("recv message {%s} %ld done!\r\n", message, retval);
53 retval = sendto(sockfd, message, strlen(message), 0, (struct sockaddr *)&clientAddr, sizeof(clientAddr));
59 printf("send message {%s} %ld done!\r\n", message, retval);
|
| /vendor/hisilicon/hispark_pegasus/demo/samart_environmental_monitoring_system_demo/udpserver_env/ |
| H A D | udp_server_test.c | 30 static char message[256] = ""; variable
54 retval = recvfrom(sockfd, message, sizeof(message), 0, (struct sockaddr *)&clientAddr, &clientAddrLen);
55 printf("recv message %s %ld done!\r\n", message, retval);
59 int ret = cJSONParseAP(message);
61 printf("parse message failed\r\n");
69 int ret = cJSONParseSTA(message);
71 printf("parse message failed\r\n");
82 printf("send message {
[all...] |
| /vendor/hisilicon/hispark_pegasus/demo/smart_night_light_demo/udpserver_light/ |
| H A D | udp_server_test.c | 28 static char message[256] = ""; variable
52 retval = recvfrom(sockfd, message, sizeof(message), 0, (struct sockaddr *)&clientAddr, &clientAddrLen);
53 printf("recv message %s %ld done!\r\n", message, retval);
57 int ret = cJSONParseAP(message);
59 printf("parse message failed\r\n");
68 int ret = cJSONParseSTA(message);
70 printf("parse message failed\r\n");
|
| /vendor/hisilicon/hispark_pegasus/demo/coap_demo/ |
| H A D | iot_main.c | 84 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
95 bufSize = topicLength + 1 + message->payloadlen + 1 + sizeof(IoTMsgT); in MsgRcvCallBack()
101 msg->qos = message->qos; in MsgRcvCallBack()
111 ret = memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack()
115 buf[message->payloadlen] = '\0'; in MsgRcvCallBack()
124 MQTTClient_freeMessage(&message); in MsgRcvCallBack()
163 // use this function to deal all the coming message
185 timeout = 0; // continue to deal the message without wait here in ProcessQueueMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/iottencent_demo/ |
| H A D | iot_main.c | 85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
95 bufSize = topiLen + 1 + message->payloadlen + 1 + sizeof(IoTMsg_t); in MsgRcvCallBack()
101 msg->qos = message->qos; in MsgRcvCallBack()
108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack()
109 buf[message->payloadlen] = '\0'; in MsgRcvCallBack()
118 MQTTClient_freeMessage(&message); in MsgRcvCallBack()
157 // <use this function to deal all the coming message
176 timeout = 0; // < continuos to deal the message without wait here in ProcessQueueMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/mqtt_demo/ |
| H A D | iot_main.c | 85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
95 bufSize = topiLen + 1 + message->payloadlen + 1 + sizeof(IoTMsg_t); in MsgRcvCallBack()
101 msg->qos = message->qos; in MsgRcvCallBack()
108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack()
109 buf[message->payloadlen] = '\0'; in MsgRcvCallBack()
118 MQTTClient_freeMessage(&message); in MsgRcvCallBack()
157 // <use this function to deal all the coming message
176 timeout = 0; // < continuos to deal the message without wait here in ProcessQueueMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/oc_demo/ |
| H A D | iot_main.c | 85 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
95 bufSize = topicLength + 1 + message->payloadlen + 1 + sizeof(IoTMsgT); in MsgRcvCallBack()
101 msg->qos = message->qos; in MsgRcvCallBack()
108 (void)memcpy_s(buf, bufSize, message->payload, message->payloadlen); in MsgRcvCallBack()
109 buf[message->payloadlen] = '\0'; in MsgRcvCallBack()
118 MQTTClient_freeMessage(&message); in MsgRcvCallBack()
157 // use this function to deal all the coming message
179 timeout = 0; // continuos to deal the message without wait here in ProcessQueueMsg()
|
| /vendor/hisilicon/hispark_pegasus/demo/oledplayer_demo/oled/examples/ |
| H A D | ssd1306_tests.c | 88 char message[] = "ABCDEFGHIJK"; in ssd1306_TestFPS() local
95 ssd1306_DrawString(message, Font_11x18, Black); in ssd1306_TestFPS()
98 char ch = message[0]; in ssd1306_TestFPS()
99 if (memmove_s(message, message+1, sizeof(message)-TWO) == TRUE) { in ssd1306_TestFPS()
101 message[sizeof(message)-TWO] = ch; in ssd1306_TestFPS()
|
| /vendor/hisilicon/hispark_pegasus/demo/ssd1306_demo/examples/ |
| H A D | ssd1306_tests.c | 88 char message[] = "ABCDEFGHIJK"; in ssd1306_TestFPS() local
95 ssd1306_DrawString(message, Font_11x18, Black); in ssd1306_TestFPS()
98 char ch = message[0]; in ssd1306_TestFPS()
99 if (memmove_s(message, message+1, sizeof(message)-TWO) == TRUE) { in ssd1306_TestFPS()
101 message[sizeof(message)-TWO] = ch; in ssd1306_TestFPS()
|