90 lines
1.8 KiB
Plaintext
90 lines
1.8 KiB
Plaintext
|
#include <uhub.h>
|
||
|
|
|
||
|
|
static struct event_queue* eq;
|
||
|
|
static int eq_val;
|
||
|
|
struct event* libevent_handle;
|
||
|
|
|
||
|
|
static void eq_callback(void* callback_data, struct event_data* event_data)
|
||
|
|
{
|
||
|
|
eq_val += event_data->id;
|
||
|
|
}
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_init_1, {
|
||
|
|
eq = 0;
|
||
|
|
eq_val = 0;
|
||
|
|
return event_queue_initialize(&eq, eq_callback, &eq_val) == 0 && event_queue_size(eq) == 0;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_init_2, {
|
||
|
|
/* hack */
|
||
|
|
libevent_handle = eq->event;
|
||
|
|
eq->event = 0;
|
||
|
|
return eq->callback_data == &eq_val && eq->callback == eq_callback && eq->q1 && eq->q2 && !eq->locked;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_post_1, {
|
||
|
|
struct event_data message;
|
||
|
|
message.id = 0x1001;
|
||
|
|
message.ptr = &message;
|
||
|
|
message.flags = message.id * 2;
|
||
|
|
event_queue_post(eq, &message);
|
||
|
|
return event_queue_size(eq) == 1;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_process_1, {
|
||
|
|
event_queue_process(eq);
|
||
|
|
return eq_val == 0x1001;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_size_1, {
|
||
|
|
eq_val = 0;
|
||
|
|
return event_queue_size(eq) == 0;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_post_2, {
|
||
|
|
struct event_data message;
|
||
|
|
message.id = 0x1002;
|
||
|
|
message.ptr = &message;
|
||
|
|
message.flags = message.id * 2;
|
||
|
|
event_queue_post(eq, &message);
|
||
|
|
return event_queue_size(eq) == 1;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_size_2, {
|
||
|
|
eq_val = 0;
|
||
|
|
return event_queue_size(eq) == 1;
|
||
|
|
});
|
||
|
|
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_post_3, {
|
||
|
|
struct event_data message;
|
||
|
|
message.id = 0x1003;
|
||
|
|
message.ptr = &message;
|
||
|
|
message.flags = message.id * 2;
|
||
|
|
event_queue_post(eq, &message);
|
||
|
|
return event_queue_size(eq) == 2;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_size_3, {
|
||
|
|
eq_val = 0;
|
||
|
|
return event_queue_size(eq) == 2;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_process_2, {
|
||
|
|
event_queue_process(eq);
|
||
|
|
return eq_val == 0x2005;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_size_4, {
|
||
|
|
eq_val = 0;
|
||
|
|
return event_queue_size(eq) == 0;
|
||
|
|
});
|
||
|
|
|
||
|
|
EXO_TEST(eventqueue_shutdown_1, {
|
||
|
|
eq->event = libevent_handle;
|
||
|
|
event_queue_shutdown(eq);
|
||
|
|
return 1;
|
||
|
|
});
|
||
|
|
|
||
|
|
|