1 #include <gtest/gtest.h>
5 #include "AllocationTestHarness.h"
8 #include "osi/include/data_dispatcher.h"
9 #include "osi/include/fixed_queue.h"
10 #include "osi/include/osi.h"
13 #define DUMMY_TYPE_0 34
14 #define DUMMY_TYPE_1 42
15 #define TYPE_EDGE_CASE_ZERO 0
16 #define TYPE_EDGE_CASE_MAX INT_MAX
18 #define DUMMY_QUEUE_SIZE 10
20 class DataDispatcherTest : public AllocationTestHarness {};
22 static char dummy_data_0[42] = "please test your code";
23 static char dummy_data_1[42] = "testing is good for your sanity";
25 TEST_F(DataDispatcherTest, test_new_free_simple) {
26 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
27 ASSERT_TRUE(dispatcher != NULL);
28 data_dispatcher_free(dispatcher);
31 TEST_F(DataDispatcherTest, test_dispatch_single_to_nowhere) {
32 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
33 EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
34 data_dispatcher_free(dispatcher);
37 TEST_F(DataDispatcherTest, test_dispatch_single_to_single) {
38 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
41 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
42 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
43 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
45 // Send data to the queue
46 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
49 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
50 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
51 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
53 fixed_queue_free(dummy_queue, NULL);
54 data_dispatcher_free(dispatcher);
57 TEST_F(DataDispatcherTest, test_dispatch_single_to_multiple) {
58 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
60 // Register two queues
61 fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE);
62 fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE);
63 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue0);
64 data_dispatcher_register(dispatcher, DUMMY_TYPE_1, dummy_queue1);
65 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
66 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
68 // Send data to one of them
69 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
72 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue0));
73 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
74 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue0));
75 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
77 fixed_queue_free(dummy_queue0, NULL);
78 fixed_queue_free(dummy_queue1, NULL);
79 data_dispatcher_free(dispatcher);
82 TEST_F(DataDispatcherTest, test_dispatch_single_to_default) {
83 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
85 // Register two queues, a default and a typed one
86 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
87 fixed_queue_t *default_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
88 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
89 data_dispatcher_register_default(dispatcher, default_queue);
90 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
91 EXPECT_TRUE(fixed_queue_is_empty(default_queue));
93 // Send data to nowhere
94 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_1, dummy_data_1));
97 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
98 EXPECT_FALSE(fixed_queue_is_empty(default_queue));
99 EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(default_queue));
100 EXPECT_TRUE(fixed_queue_is_empty(default_queue));
102 fixed_queue_free(dummy_queue, NULL);
103 fixed_queue_free(default_queue, NULL);
104 data_dispatcher_free(dispatcher);
107 TEST_F(DataDispatcherTest, test_dispatch_multiple_to_single) {
108 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
111 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
112 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
113 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
115 // Send data to the queue
116 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
117 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_1));
120 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
121 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
122 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
123 EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(dummy_queue));
124 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
126 fixed_queue_free(dummy_queue, NULL);
127 data_dispatcher_free(dispatcher);
130 TEST_F(DataDispatcherTest, test_dispatch_multiple_to_multiple) {
131 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
133 // Register two queues
134 fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE);
135 fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE);
136 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue0);
137 data_dispatcher_register(dispatcher, DUMMY_TYPE_1, dummy_queue1);
138 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
139 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
141 // Send data to both of them
142 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
143 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_1, dummy_data_1));
146 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue0));
147 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue1));
148 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue0));
149 EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(dummy_queue1));
150 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
151 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
153 fixed_queue_free(dummy_queue0, NULL);
154 fixed_queue_free(dummy_queue1, NULL);
155 data_dispatcher_free(dispatcher);
158 TEST_F(DataDispatcherTest, test_dispatch_single_to_single_reregistered) {
159 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
161 // Register a queue, then reregister
162 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
163 fixed_queue_t *dummy_queue_reregistered = fixed_queue_new(DUMMY_QUEUE_SIZE);
164 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
165 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue_reregistered);
166 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
167 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue_reregistered));
169 // Send data to the queue
170 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
173 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
174 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue_reregistered));
175 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue_reregistered));
176 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue_reregistered));
178 fixed_queue_free(dummy_queue, NULL);
179 fixed_queue_free(dummy_queue_reregistered, NULL);
180 data_dispatcher_free(dispatcher);
183 TEST_F(DataDispatcherTest, test_dispatch_single_to_reregistered_null) {
184 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
187 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
188 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
189 data_dispatcher_register(dispatcher, DUMMY_TYPE_0, NULL);
190 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
192 EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
193 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
195 fixed_queue_free(dummy_queue, NULL);
196 data_dispatcher_free(dispatcher);
199 TEST_F(DataDispatcherTest, test_dispatch_single_to_default_reregistered_null) {
200 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
203 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
204 data_dispatcher_register_default(dispatcher, dummy_queue);
205 data_dispatcher_register_default(dispatcher, NULL);
206 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
208 EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
209 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
211 fixed_queue_free(dummy_queue, NULL);
212 data_dispatcher_free(dispatcher);
215 TEST_F(DataDispatcherTest, test_dispatch_edge_zero) {
216 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
219 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
220 data_dispatcher_register(dispatcher, TYPE_EDGE_CASE_ZERO, dummy_queue);
221 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
223 // Send data to the queue
224 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_ZERO, dummy_data_0));
227 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
228 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
229 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
231 fixed_queue_free(dummy_queue, NULL);
232 data_dispatcher_free(dispatcher);
235 TEST_F(DataDispatcherTest, test_dispatch_edge_max) {
236 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
239 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
240 data_dispatcher_register(dispatcher, TYPE_EDGE_CASE_MAX, dummy_queue);
241 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
243 // Send data to the queue
244 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_MAX, dummy_data_0));
247 EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
248 EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
249 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
251 fixed_queue_free(dummy_queue, NULL);
252 data_dispatcher_free(dispatcher);