blob: 98354bc7c30d6ab5dcad67a56b62a6289078255f [file] [log] [blame]
#include <gtest/gtest.h>
#include <climits>
#include "AllocationTestHarness.h"
extern "C" {
#include "osi/include/data_dispatcher.h"
#include "osi/include/fixed_queue.h"
#include "osi/include/osi.h"
}
#define DUMMY_TYPE_0 34
#define DUMMY_TYPE_1 42
#define TYPE_EDGE_CASE_ZERO 0
#define TYPE_EDGE_CASE_MAX INT_MAX
#define DUMMY_QUEUE_SIZE 10
class DataDispatcherTest : public AllocationTestHarness {};
static char dummy_data_0[42] = "please test your code";
static char dummy_data_1[42] = "testing is good for your sanity";
TEST_F(DataDispatcherTest, test_new_free_simple) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
ASSERT_TRUE(dispatcher != NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_nowhere) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_single) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
// Send data to the queue
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_multiple) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register two queues
fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE);
fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue0);
data_dispatcher_register(dispatcher, DUMMY_TYPE_1, dummy_queue1);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
// Send data to one of them
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
fixed_queue_free(dummy_queue0, NULL);
fixed_queue_free(dummy_queue1, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_default) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register two queues, a default and a typed one
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
fixed_queue_t *default_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
data_dispatcher_register_default(dispatcher, default_queue);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(default_queue));
// Send data to nowhere
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_1, dummy_data_1));
// Did we get it?
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_FALSE(fixed_queue_is_empty(default_queue));
EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(default_queue));
EXPECT_TRUE(fixed_queue_is_empty(default_queue));
fixed_queue_free(dummy_queue, NULL);
fixed_queue_free(default_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_multiple_to_single) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
// Send data to the queue
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_1));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_multiple_to_multiple) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register two queues
fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE);
fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue0);
data_dispatcher_register(dispatcher, DUMMY_TYPE_1, dummy_queue1);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
// Send data to both of them
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_1, dummy_data_1));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue0));
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue1));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue0));
EXPECT_STREQ(dummy_data_1, (char *)fixed_queue_try_dequeue(dummy_queue1));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue1));
fixed_queue_free(dummy_queue0, NULL);
fixed_queue_free(dummy_queue1, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_single_reregistered) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue, then reregister
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
fixed_queue_t *dummy_queue_reregistered = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue_reregistered);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue_reregistered));
// Send data to the queue
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
// Did we get it?
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue_reregistered));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue_reregistered));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue_reregistered));
fixed_queue_free(dummy_queue, NULL);
fixed_queue_free(dummy_queue_reregistered, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_reregistered_null) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, dummy_queue);
data_dispatcher_register(dispatcher, DUMMY_TYPE_0, NULL);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_single_to_default_reregistered_null) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register_default(dispatcher, dummy_queue);
data_dispatcher_register_default(dispatcher, NULL);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
EXPECT_FALSE(data_dispatcher_dispatch(dispatcher, DUMMY_TYPE_0, dummy_data_0));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_edge_zero) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, TYPE_EDGE_CASE_ZERO, dummy_queue);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
// Send data to the queue
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_ZERO, dummy_data_0));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}
TEST_F(DataDispatcherTest, test_dispatch_edge_max) {
data_dispatcher_t *dispatcher = data_dispatcher_new("test_dispatcher");
// Register a queue
fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE);
data_dispatcher_register(dispatcher, TYPE_EDGE_CASE_MAX, dummy_queue);
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
// Send data to the queue
EXPECT_TRUE(data_dispatcher_dispatch(dispatcher, TYPE_EDGE_CASE_MAX, dummy_data_0));
// Did we get it?
EXPECT_FALSE(fixed_queue_is_empty(dummy_queue));
EXPECT_STREQ(dummy_data_0, (char *)fixed_queue_try_dequeue(dummy_queue));
EXPECT_TRUE(fixed_queue_is_empty(dummy_queue));
fixed_queue_free(dummy_queue, NULL);
data_dispatcher_free(dispatcher);
}