1 /*
2 * Copyright (c) 2006-2021, RT-Thread Development Team
3 *
4 * SPDX-License-Identifier: Apache-2.0
5 *
6 * Change Logs:
7 * Date Author Notes
8 * 2023-02-07 ZXY the first version
9 */
10 #include <rtthread.h>
11 #include <rtdevice.h>
12 #include <string.h>
13 #include <ipc/ringbuffer.h>
14
15 #define RING_BUFFER_LEN 8
16 static struct ringbuffer *rb;
17 static char *str = "Hello, World new ringbuffer32";
18 typedef struct rb_example {
19 rt_uint32_t a;
20 rt_uint32_t b;
21 rt_uint32_t c;
22 } rb_example_t;
23
24
ringbuffer_example(void)25 int ringbuffer_example(void)
26 {
27 rb_example_t data = {
28 .a = 1,
29 .b = 2,
30 };
31
32 struct rt_ringbuffer * rb = rt_ringbuffer_create(sizeof(rb_example_t) * 2);
33 RT_ASSERT(rb != RT_NULL);
34
35 rt_kprintf("Put data to ringbuffer, a: %d b: %d size: %d\n", data.a, data.b, sizeof(data));
36 rt_ringbuffer_put(rb, (rt_uint8_t *)&data, sizeof(data));
37
38
39 rb_example_t recv_data;
40 rt_size_t recv = rt_ringbuffer_get(rb, (rt_uint8_t *)&recv_data, sizeof(recv_data));
41 RT_ASSERT(recv == sizeof(recv_data));
42 rt_kprintf("Get data from ringbuffer, a: %d b: %d size: %d\n", recv_data.a, recv_data.b, sizeof(recv_data));
43
44 return 0;
45 }
46 MSH_CMD_EXPORT(ringbuffer_example, ringbuffer example);
47
48
ringbuffer_force_example(void)49 int ringbuffer_force_example(void)
50 {
51 uint8_t test[6] = {1,2,3,4,5,6};
52 struct rt_ringbuffer * rb;
53 rb = rt_ringbuffer_create(4);
54 RT_ASSERT(rb != RT_NULL);
55
56 rt_kprintf("Put data to ringbuffer, %d %d %d %d %d %d\n", test[0],test[1],test[2],test[3],test[4],test[5]);
57 rt_ringbuffer_put_force(rb, (rt_uint8_t *)&test, sizeof(test));
58
59
60 uint8_t recv_data[4]={0};
61 rt_ringbuffer_get(rb, (rt_uint8_t *)&recv_data, sizeof(test));
62 rt_kprintf("Get data from ringbuffer, %d %d %d %d\n", recv_data[0],recv_data[1],recv_data[2],recv_data[3]);
63 rt_kprintf("write mirror: %d read mirror: %d\n", rb->write_mirror,rb->read_mirror);
64 return 0;
65 }
66 MSH_CMD_EXPORT(ringbuffer_force_example, ringbuffer example);
67
consumer_thread_entry(void * arg)68 static void consumer_thread_entry(void *arg)
69 {
70 char ch;
71 while (1)
72 {
73 if (1 == rt_ringbuffer_getchar(rb, &ch))
74 {
75 rt_kprintf("[Consumer] <- %c\n", ch);
76 }
77 rt_thread_mdelay(500);
78 }
79 }
ringbuffer_sample(int argc,char ** argv)80 static void ringbuffer_sample(int argc, char** argv)
81 {
82 rt_thread_t tid;
83 rt_uint16_t i = 0;
84 rb = rt_ringbuffer_create(RING_BUFFER_LEN);
85 if (rb == RT_NULL)
86 {
87 rt_kprintf("Can't create ringbffer");
88 return;
89 }
90 tid = rt_thread_create("consumer", consumer_thread_entry, RT_NULL,
91 1024, RT_THREAD_PRIORITY_MAX/3, 20);
92 if (tid == RT_NULL)
93 {
94 rt_ringbuffer_destroy(rb);
95 }
96 rt_thread_startup(tid);
97 while (str[i] != '\0')
98 {
99 rt_kprintf("[Producer] -> %c\n", str[i]);
100 rt_ringbuffer_putchar(rb, str[i++]);
101 rt_thread_mdelay(500);
102 }
103 rt_thread_delete(tid);
104 rt_ringbuffer_destroy(rb);
105 }
106 MSH_CMD_EXPORT(ringbuffer_sample, Start a producer and a consumer with a ringbuffer);
107