1 #include <gtest/gtest.h> 2 3 #include <climits> 4 5 #include "AllocationTestHarness.h" 6 7 extern "C" { 8 #include "osi/include/data_dispatcher.h" 9 #include "osi/include/fixed_queue.h" 10 #include "osi/include/osi.h" 11 } 12 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 17 18 #define DUMMY_QUEUE_SIZE 10 19 20 class DataDispatcherTest : public AllocationTestHarness {}; 21 22 static char dummy_data_0[42] = "please test your code"; 23 static char dummy_data_1[42] = "testing is good for your sanity"; 24 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); 29 } 30 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); 35 } 36 37 TEST_F(DataDispatcherTest, test_dispatch_single_to_single) { 38 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 39 40 // Register a queue 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)); 44 45 // Send data to the queue 46 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0)); 47 48 // Did we get it? 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)); 52 53 fixed_queue_free(dummy_queue, NULL); 54 data_dispatcher_free(dispatcher); 55 } 56 57 TEST_F(DataDispatcherTest, test_dispatch_single_to_multiple) { 58 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 59 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)); 67 68 // Send data to one of them 69 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0)); 70 71 // Did we get it? 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)); 76 77 fixed_queue_free(dummy_queue0, NULL); 78 fixed_queue_free(dummy_queue1, NULL); 79 data_dispatcher_free(dispatcher); 80 } 81 82 TEST_F(DataDispatcherTest, test_dispatch_single_to_default) { 83 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 84 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)); 92 93 // Send data to nowhere 94 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_1, dummy_data_1)); 95 96 // Did we get it? 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)); 101 102 fixed_queue_free(dummy_queue, NULL); 103 fixed_queue_free(default_queue, NULL); 104 data_dispatcher_free(dispatcher); 105 } 106 107 TEST_F(DataDispatcherTest, test_dispatch_multiple_to_single) { 108 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 109 110 // Register a queue 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)); 114 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)); 118 119 // Did we get it? 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)); 125 126 fixed_queue_free(dummy_queue, NULL); 127 data_dispatcher_free(dispatcher); 128 } 129 130 TEST_F(DataDispatcherTest, test_dispatch_multiple_to_multiple) { 131 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 132 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)); 140 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)); 144 145 // Did we get it? 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)); 152 153 fixed_queue_free(dummy_queue0, NULL); 154 fixed_queue_free(dummy_queue1, NULL); 155 data_dispatcher_free(dispatcher); 156 } 157 158 TEST_F(DataDispatcherTest, test_dispatch_single_to_single_reregistered) { 159 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 160 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)); 168 169 // Send data to the queue 170 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0)); 171 172 // Did we get it? 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)); 177 178 fixed_queue_free(dummy_queue, NULL); 179 fixed_queue_free(dummy_queue_reregistered, NULL); 180 data_dispatcher_free(dispatcher); 181 } 182 183 TEST_F(DataDispatcherTest, test_dispatch_single_to_reregistered_null) { 184 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 185 186 // Register a queue 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)); 191 192 EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0)); 193 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue)); 194 195 fixed_queue_free(dummy_queue, NULL); 196 data_dispatcher_free(dispatcher); 197 } 198 199 TEST_F(DataDispatcherTest, test_dispatch_single_to_default_reregistered_null) { 200 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 201 202 // Register a queue 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)); 207 208 EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0)); 209 EXPECT_TRUE(fixed_queue_is_empty(dummy_queue)); 210 211 fixed_queue_free(dummy_queue, NULL); 212 data_dispatcher_free(dispatcher); 213 } 214 215 TEST_F(DataDispatcherTest, test_dispatch_edge_zero) { 216 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 217 218 // Register a queue 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)); 222 223 // Send data to the queue 224 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_ZERO, dummy_data_0)); 225 226 // Did we get it? 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)); 230 231 fixed_queue_free(dummy_queue, NULL); 232 data_dispatcher_free(dispatcher); 233 } 234 235 TEST_F(DataDispatcherTest, test_dispatch_edge_max) { 236 data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher"); 237 238 // Register a queue 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)); 242 243 // Send data to the queue 244 EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_MAX, dummy_data_0)); 245 246 // Did we get it? 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)); 250 251 fixed_queue_free(dummy_queue, NULL); 252 data_dispatcher_free(dispatcher); 253 } 254
