From 24adda3e0d6eb30b8e8283004f7cba9480c359b2 Mon Sep 17 00:00:00 2001 From: David Lin Date: Fri, 31 Jul 2020 20:45:44 +0800 Subject: [PATCH] Update nb-iot_example.c --- examples/nb-iot_demo/nb-iot_example.c | 47 +++++++++++++++++---------- 1 file changed, 30 insertions(+), 17 deletions(-) diff --git a/examples/nb-iot_demo/nb-iot_example.c b/examples/nb-iot_demo/nb-iot_example.c index 616b34d4..df340753 100644 --- a/examples/nb-iot_demo/nb-iot_example.c +++ b/examples/nb-iot_demo/nb-iot_example.c @@ -5,6 +5,7 @@ #define NB_IoT_TEST_TASK_STK_SIZE 1024 + void nb_iot_demo(void); osThreadDef(nb_iot_demo, osPriorityNormal, 1, NB_IoT_TEST_TASK_STK_SIZE); @@ -15,30 +16,42 @@ uint8_t recv_data[RECV_LEN]; void nb_iot_demo(void) { int recv_len = -1; - int bc35_28_95_sal_lwm2m_init(hal_uart_port_t uart_port); + + extern int bc35_28_95_sal_lwm2m_init(hal_uart_port_t uart_port); bc35_28_95_sal_lwm2m_init(HAL_UART_PORT_0); + socket_id = tos_sal_module_connect("49.4.85.232","5683",TOS_SAL_PROTO_UDP); - if(socket_id !=-1){ + if(socket_id !=-1) + { printf("connect to cloud success! fd: %d\n", socket_id); } - else{ + else + { printf("connect to cloud failed!\n"); - } - while (1) { - tos_sal_module_send(socket_id, (const void*)"22", strlen("22")); + } - recv_len = tos_sal_module_recv(socket_id, recv_data, sizeof(recv_data)); - if (recv_len < 0) { - printf("task receive error\n"); - } else if (recv_len == 0) { - printf("task receive none\n"); - } else { - recv_data[recv_len] = 0; - printf("task: receive len: %d\nmsg from remote: %s\n", recv_len, recv_data); - } + while (1) + { + tos_sal_module_send(socket_id, (const void*)"22", strlen("22")); - tos_sleep_ms(2000); - } + memset(&recv_data[0], 0, sizeof(recv_data)); + recv_len = tos_sal_module_recv(socket_id, recv_data, sizeof(recv_data)); + if (recv_len < 0) + { + printf("task receive error\n"); + } + else if (recv_len == 0) + { + printf("task receive none\n"); + } + else + { + recv_data[recv_len] = 0; + printf("task: receive len: %d\nmsg from remote: %s\n", recv_len, recv_data); + } + + tos_sleep_ms(2000); + } } void application_entry(void *arg)