riot-ci/RIOT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

tests/event: Also test multi-queue flavor

Browse Source
This commit is contained in:
Marian Buschsieweke 2020-08-03 12:14:55 +02:00
parent 8bda9fac1b
commit 4aa33d55ac
No known key found for this signature in database
GPG Key ID: 61F64C6599B1539F
1 changed files with 39 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
tests/events/main.c
View File

@ -30,6 +30,7 @@
#define STACKSIZE THREAD_STACKSIZE_DEFAULT #define STACKSIZE THREAD_STACKSIZE_DEFAULT
#define PRIO (THREAD_PRIORITY_MAIN - 1) #define PRIO (THREAD_PRIORITY_MAIN - 1)
#define DELAYED_QUEUES_NUMOF 2
static char stack[STACKSIZE]; static char stack[STACKSIZE];
@ -42,16 +43,18 @@ static void timed_callback(void *arg);
static void forbidden_callback(void *arg); static void forbidden_callback(void *arg);
static void delayed_callback1(event_t *arg); static void delayed_callback1(event_t *arg);
static void delayed_callback2(event_t *arg); static void delayed_callback2(event_t *arg);
static void delayed_callback3(event_t *arg);
static event_t event = { .handler = callback }; static event_t event = { .handler = callback };
static event_t event2 = { .handler = callback }; static event_t event2 = { .handler = callback };
static event_t delayed_event1 = { .handler = delayed_callback1 }; static event_t delayed_event1 = { .handler = delayed_callback1 };
static event_t delayed_event2 = { .handler = delayed_callback2 }; static event_t delayed_event2 = { .handler = delayed_callback2 };
static event_t delayed_event3 = { .handler = delayed_callback3 };
static void callback(event_t *arg) static void callback(event_t *arg)
{ {
order++; order++;
expect(order == 3); expect(order == 4);
expect(arg == &event); expect(arg == &event);
printf("triggered 0x%08x\n", (unsigned)arg); printf("triggered 0x%08x\n", (unsigned)arg);
} }
@ -68,7 +71,7 @@ static event_callback_t noevent_callback = EVENT_CALLBACK_INIT(forbidden_callbac
static void custom_callback(event_t *event) static void custom_callback(event_t *event)
{ {
order++; order++;
expect(order == 4); expect(order == 5);
expect(event == (event_t *)&custom_event); expect(event == (event_t *)&custom_event);
custom_event_t *custom_event = (custom_event_t *)event; custom_event_t *custom_event = (custom_event_t *)event;
printf("triggered custom event with text: \"%s\"\n", custom_event->text); printf("triggered custom event with text: \"%s\"\n", custom_event->text);
@ -77,7 +80,7 @@ static void custom_callback(event_t *event)
static void timed_callback(void *arg) static void timed_callback(void *arg)
{ {
order++; order++;
expect(order == 5); expect(order == 6);
expect(arg == event_callback.arg); expect(arg == event_callback.arg);
uint32_t now = xtimer_now_usec(); uint32_t now = xtimer_now_usec();
expect((now - before >= 100000LU)); expect((now - before >= 100000LU));
@ -99,7 +102,7 @@ static void forbidden_callback(void *arg)
static void delayed_callback1(event_t *arg) static void delayed_callback1(event_t *arg)
{ {
order++; order++;
expect(order == 1); expect(order == 2);
expect(arg == &delayed_event1); expect(arg == &delayed_event1);
printf("triggered delayed event %p\n", (void *)arg); printf("triggered delayed event %p\n", (void *)arg);
} }
@ -107,19 +110,29 @@ static void delayed_callback1(event_t *arg)
static void delayed_callback2(event_t *arg) static void delayed_callback2(event_t *arg)
{ {
order++; order++;
expect(order == 2); expect(order == 3);
expect(arg == &delayed_event2); expect(arg == &delayed_event2);
printf("triggered delayed event %p\n", (void *)arg); printf("triggered delayed event %p\n", (void *)arg);
} }
static void delayed_callback3(event_t *arg)
{
order++;
expect(order == 1);
expect(arg == &delayed_event3);
printf("triggered delayed event %p\n", (void *)arg);
}
static void *claiming_thread(void *arg) static void *claiming_thread(void *arg)
{ {
event_queue_t *dq = (event_queue_t *)arg; event_queue_t *dqs = arg;
printf("claiming event queue %p\n", (void *)dq); printf("claiming event queues %p\n", (void *)dqs);
event_queue_claim(dq); for (size_t i = 0; i < DELAYED_QUEUES_NUMOF; i++) {
printf("launching event queue %p\n", (void *)dq); event_queue_claim(&dqs[i]);
event_loop(dq); }
printf("launching event queue for queues %p\n", (void *)dqs);
event_loop_multi(dqs, DELAYED_QUEUES_NUMOF);
return NULL; return NULL;
} }
@ -129,17 +142,22 @@ int main(void)
puts("[START] event test application.\n"); puts("[START] event test application.\n");
/* test creation of delayed claiming of a detached event queue */ /* test creation of delayed claiming of a detached event queue */
event_queue_t dq = EVENT_QUEUE_INIT_DETACHED; event_queue_t dqs[DELAYED_QUEUES_NUMOF] = {
printf("initializing detached event queue %p\n", (void *)&dq); EVENT_QUEUE_INIT_DETACHED, EVENT_QUEUE_INIT_DETACHED
event_queue_init_detached(&dq); };
printf("initializing detached event queues %p\n", (void *)dqs);
event_queue_init_detached(&dqs[0]);
event_queue_init_detached(&dqs[1]);
printf("posting %p\n", (void *)&delayed_event1); printf("posting %p to delayed queue at index 1\n", (void *)&delayed_event1);
event_post(&dq, &delayed_event1); event_post(&dqs[1], &delayed_event1);
printf("posting %p\n", (void *)&delayed_event2); printf("posting %p to delayed queue at index 1\n", (void *)&delayed_event2);
event_post(&dq, &delayed_event2); event_post(&dqs[1], &delayed_event2);
printf("posting %p to delayed queue at index 0\n", (void *)&delayed_event3);
event_post(&dqs[0], &delayed_event3);
printf("running thread that will claim event queue %p\n", (void *)&dq); printf("running thread that will claim event queues %p\n", (void *)&dqs);
thread_create(stack, sizeof(stack), PRIO, 0, claiming_thread, &dq, "ct"); thread_create(stack, sizeof(stack), PRIO, 0, claiming_thread, dqs, "ct");
/* test posting different kind of events in order to a statically /* test posting different kind of events in order to a statically
* initialized queue */ * initialized queue */