1 #include <rtthread.h>
2 #include <rtdevice.h>
3 #include "utest.h"
4
5 #ifdef UTEST_SERIAL_TC
6
nonblock_read(rt_device_t uart_dev)7 static rt_bool_t nonblock_read(rt_device_t uart_dev)
8 {
9 rt_size_t total_length, recv_length;
10 char uart_read_buffer[1024], log_buffer[64];
11
12 /* make sure device is closed and reopen it */
13 while (rt_device_close(uart_dev) != -RT_ERROR);
14 rt_device_open(uart_dev, RT_DEVICE_FLAG_TX_BLOCKING | RT_DEVICE_FLAG_RX_NON_BLOCKING);
15
16 rt_sprintf(log_buffer, "\nNONBLOCKING READ BEGIN, PLEASE SEND SOME DATAS\n");
17 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
18
19 total_length = 0;
20 rt_device_write(uart_dev, 0, "5\n", 2);
21 recv_length = 0;
22 recv_length = rt_device_read(uart_dev, -1, uart_read_buffer, 256);
23 rt_device_write(uart_dev, 0, uart_read_buffer, 256);
24 total_length += recv_length;
25
26 rt_sprintf(log_buffer, "\nnonblock : %d bytes read, total: %d \n", recv_length, total_length);
27 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
28
29 rt_device_write(uart_dev, 0, "4\n", 2);
30 recv_length = 0;
31 recv_length = rt_device_read(uart_dev, -1, uart_read_buffer, 256);
32 rt_device_write(uart_dev, 0, uart_read_buffer, 256);
33 total_length += recv_length;
34
35 rt_sprintf(log_buffer, "\nnonblock : %d bytes read , total: %d \n", recv_length, total_length);
36 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
37
38 rt_device_write(uart_dev, 0, "3\n", 2);
39 recv_length = 0;
40 recv_length = rt_device_read(uart_dev, -1, uart_read_buffer, 256);
41 rt_device_write(uart_dev, 0, uart_read_buffer, 256);
42 total_length += recv_length;
43
44 rt_sprintf(log_buffer, "\nnonblock : %d bytes read, total: %d \n", recv_length, total_length);
45 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
46
47 rt_device_write(uart_dev, 0, "2\n", 2);
48 recv_length = 0;
49 recv_length = rt_device_read(uart_dev, -1, uart_read_buffer, 128);
50 rt_device_write(uart_dev, 0, uart_read_buffer, 128);
51 total_length += recv_length;
52
53 rt_sprintf(log_buffer, "\nnonblock : %d bytes read , total: %d \n", recv_length, total_length);
54 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
55
56 rt_device_write(uart_dev, 0, "1\n", 2);
57 recv_length = 0;
58 recv_length = rt_device_read(uart_dev, -1, uart_read_buffer, 128);
59 rt_device_write(uart_dev, 0, uart_read_buffer, 128);
60 total_length += recv_length;
61
62 rt_sprintf(log_buffer, "\nnonblock : %d bytes read , total: %d \n", recv_length, total_length);
63 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
64
65 rt_sprintf(log_buffer, "BLOCKING READ END");
66 rt_device_write(uart_dev, 0, log_buffer, rt_strlen(log_buffer));
67
68 return RT_TRUE;
69 }
70
uart_test_nonblocking_rx(void)71 static void uart_test_nonblocking_rx(void)
72 {
73 rt_device_t uart_dev;
74 uart_dev = rt_device_find(RT_SERIAL_TC_DEVICE_NAME);
75 uassert_not_null(uart_dev);
76
77 uassert_true(nonblock_read(uart_dev));
78 }
79
utest_tc_init(void)80 static rt_err_t utest_tc_init(void)
81 {
82 return RT_EOK;
83 }
84
utest_tc_cleanup(void)85 static rt_err_t utest_tc_cleanup(void)
86 {
87 rt_device_t uart_dev = rt_device_find(RT_SERIAL_TC_DEVICE_NAME);
88 while (rt_device_close(uart_dev) != -RT_ERROR);
89 return RT_EOK;
90 }
91
testcase(void)92 static void testcase(void)
93 {
94 UTEST_UNIT_RUN(uart_test_nonblocking_rx);
95 }
96 UTEST_TC_EXPORT(testcase, "uart_nonblocking_rx", utest_tc_init, utest_tc_cleanup, 10);
97
98 #endif
99