diff options
Diffstat (limited to 'test/test.c')
| -rw-r--r-- | test/test.c | 605 |
1 files changed, 130 insertions, 475 deletions
diff --git a/test/test.c b/test/test.c index 22337132e..d6f9f0717 100644 --- a/test/test.c +++ b/test/test.c @@ -19,39 +19,46 @@ #include <ch.h>
-#if defined(WIN32)
-void ChkIntSources(void);
-#endif
+#include "test.h"
+#include "testrdy.h"
+#include "testsem.h"
+#include "testmtx.h"
+#include "testmsg.h"
-#if defined(WIN32)
-WorkingArea(wsT1, 512);
-WorkingArea(wsT2, 512);
-WorkingArea(wsT3, 512);
-WorkingArea(wsT4, 512);
-WorkingArea(wsT5, 512);
-#else
-WorkingArea(wsT1, 128);
-WorkingArea(wsT2, 128);
-WorkingArea(wsT3, 128);
-WorkingArea(wsT4, 128);
-WorkingArea(wsT5, 128);
-#endif
-static Thread *t1, *t2, *t3, *t4, *t5;
+/*
+ * Array of all the test cases.
+ */
+static const struct testcase *tests[] = {
+ &testrdy1,
+ &testrdy2,
+ &testsem1,
+ &testsem2,
+ &testmtx1,
+ &testmtx2,
+ &testmtx3,
+ &testmsg1,
+ NULL
+};
+
+static bool_t local_fail, global_fail;
+static char *failmsg;
+static char tokens_buffer[MAX_TOKENS];
+static char *tokp;
+static WorkingArea(waT0, THREADS_STACK_SIZE);
+static WorkingArea(waT1, THREADS_STACK_SIZE);
+static WorkingArea(waT2, THREADS_STACK_SIZE);
+static WorkingArea(waT3, THREADS_STACK_SIZE);
+static WorkingArea(waT4, THREADS_STACK_SIZE);
+
+void *wa[MAX_THREADS] = {waT0, waT1, waT2, waT3, waT4};
+Thread *threads[MAX_THREADS];
+/*
+ * Console output.
+ */
static FullDuplexDriver *comp;
-static Semaphore sem1;
-static Mutex m1, m2;
-static void wait(void) {
-
- chThdWait(t1);
- chThdWait(t2);
- chThdWait(t3);
- chThdWait(t4);
- chThdWait(t5);
-}
-
-static void printn(uint32_t n) {
+void test_printn(uint32_t n) {
char buf[16], *p;
if (!n)
@@ -65,506 +72,154 @@ static void printn(uint32_t n) { }
}
-static void print(char *msgp) {
+void test_print(char *msgp) {
while (*msgp)
chFDDPut(comp, *msgp++);
}
-static void println(char *msgp) {
+void test_println(char *msgp) {
- print(msgp);
+ test_print(msgp);
chFDDPut(comp, '\r');
chFDDPut(comp, '\n');
}
-__attribute__((noinline))
-void CPU(systime_t ms) {
-
- systime_t time = chSysGetTime() + ms;
- while (chSysGetTime() != time) {
-#if defined(WIN32)
- ChkIntSources();
-#endif
- }
-}
-
-__attribute__((noinline))
-systime_t wait_tick(void) {
-
- systime_t time = chSysGetTime() + 1;
- while (chSysGetTime() < time) {
-#if defined(WIN32)
- ChkIntSources();
-#endif
- }
- return time;
-}
-
-msg_t Thread1(void *p) {
-
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
-
-msg_t Thread2(void *p) {
-
- chSemWait(&sem1);
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
-
-msg_t Thread3(void *p) {
-
- chMtxLock(&m1);
- chFDDPut(comp, *(uint8_t *)p);
- chMtxUnlock();
- return 0;
-}
-
-msg_t Thread4(void *p) {
- msg_t msg;
- int i;
-
- for (i = 0; i < 5; i++) {
- msg = chMsgSend(p, 'A' + i);
- chFDDPut(comp, msg);
- }
- chMsgSend(p, 0);
- return 0;
-}
-
-msg_t Thread6(void *p) {
-
- while (!chThdShouldTerminate())
- chMsgRelease(chMsgWait());
- return 0;
-}
-
-msg_t Thread7(void *p) {
-
- return (msg_t)NULL;
-}
-
-void testrdy1(void) {
-
- println("*** Ready List, priority enqueuing test #1, you should read ABCDE:");
- t5 = chThdCreate(chThdGetPriority()-5, 0, wsT5, sizeof(wsT5), Thread1, "E");
- t4 = chThdCreate(chThdGetPriority()-4, 0, wsT4, sizeof(wsT4), Thread1, "D");
- t3 = chThdCreate(chThdGetPriority()-3, 0, wsT3, sizeof(wsT3), Thread1, "C");
- t2 = chThdCreate(chThdGetPriority()-2, 0, wsT2, sizeof(wsT2), Thread1, "B");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread1, "A");
- wait();
- println("");
-}
-
-void testrdy2(void) {
-
- println("*** Ready List, priority enqueuing test #2, you should read ABCDE:");
- t4 = chThdCreate(chThdGetPriority()-4, 0, wsT4, sizeof(wsT4), Thread1, "D");
- t5 = chThdCreate(chThdGetPriority()-5, 0, wsT5, sizeof(wsT5), Thread1, "E");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread1, "A");
- t2 = chThdCreate(chThdGetPriority()-2, 0, wsT2, sizeof(wsT2), Thread1, "B");
- t3 = chThdCreate(chThdGetPriority()-3, 0, wsT3, sizeof(wsT3), Thread1, "C");
- wait();
- println("");
-}
-
-void testsem1(void) {
-
- println("*** Semaphores, FIFO enqueuing test, you should read ABCDE:");
- chSemInit(&sem1, 0);
- t1 = chThdCreate(chThdGetPriority()+5, 0, wsT1, sizeof(wsT1), Thread2, "A");
- t2 = chThdCreate(chThdGetPriority()+1, 0, wsT2, sizeof(wsT2), Thread2, "B");
- t3 = chThdCreate(chThdGetPriority()+3, 0, wsT3, sizeof(wsT3), Thread2, "C");
- t4 = chThdCreate(chThdGetPriority()+4, 0, wsT4, sizeof(wsT4), Thread2, "D");
- t5 = chThdCreate(chThdGetPriority()+2, 0, wsT5, sizeof(wsT5), Thread2, "E");
- chSemSignal(&sem1);
- chSemSignal(&sem1);
- chSemSignal(&sem1);
- chSemSignal(&sem1);
- chSemSignal(&sem1);
- wait();
- println("");
-}
-
-void testsem2(void) {
- unsigned int i;
-
- println("*** Semaphores, timeout test, you should read ABCDE (slowly):");
- chSemInit(&sem1, 0);
- for (i = 0; i < 5; i++) {
- chFDDPut(comp, 'A' + i);
- chSemWaitTimeout(&sem1, 500);
- }
- println("");
-}
-
-void testmtx1(void) {
-
- chMtxInit(&m1);
- println("*** Mutexes, priority enqueuing test, you should read ABCDE:");
- chMtxLock(&m1);
- t5 = chThdCreate(chThdGetPriority()+1, 0, wsT5, sizeof(wsT5), Thread3, "E");
- t4 = chThdCreate(chThdGetPriority()+3, 0, wsT4, sizeof(wsT4), Thread3, "D");
- t3 = chThdCreate(chThdGetPriority()+3, 0, wsT3, sizeof(wsT3), Thread3, "C");
- t2 = chThdCreate(chThdGetPriority()+4, 0, wsT2, sizeof(wsT2), Thread3, "B");
- t1 = chThdCreate(chThdGetPriority()+5, 0, wsT1, sizeof(wsT1), Thread3, "A");
- chMtxUnlock();
- wait();
- println("");
-}
-
-msg_t Thread8(void *p) {
-
- chThdSleep(5);
- chMtxLock(&m1);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
-
-msg_t Thread9(void *p) {
-
- chMtxLock(&m1);
- chThdSleep(20);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
-
-msg_t Thread10(void *p) {
+/*
+ * Tokens.
+ */
+static void clear_tokens(void) {
- chThdSleep(10);
- CPU(50);
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+ tokp = tokens_buffer;
}
-msg_t Thread11(void *p) {
+static void print_tokens(void) {
+ char *cp = tokens_buffer;
- chThdSleep(5);
- chSemWait(&sem1);
- chSemSignal(&sem1);
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+ while (cp < tokp)
+ chFDDPut(comp, *cp++);
}
-msg_t Thread12(void *p) {
+void test_emit_token(char token) {
- chSemWait(&sem1);
- chThdSleep(20);
- chSemSignal(&sem1);
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+ chSysLock();
+ *tokp++ = token;
+ chSysUnlock();
}
/*
- * Time
- * 0 ++++++++++++++++++AL+....2++++++++++++++AU0------------------------------
- * 1 .....................++--------------------------------------------------
- * 2 .......................++AL.............+++++++++AU++++++++++++++++++++++
+ * Assertions.
*/
-void testmtx2(void) {
-
- chMtxInit(&m1);
- println("*** Mutexes, mutex with inheritance (simple case), you should read ABC:");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread8, "A");
- t2 = chThdCreate(chThdGetPriority()-3, 0, wsT2, sizeof(wsT2), Thread9, "C");
- t3 = chThdCreate(chThdGetPriority()-2, 0, wsT3, sizeof(wsT3), Thread10, "B");
- chThdWait(t1);
- chThdWait(t2);
- chThdWait(t3);
- println("");
-}
+void test_fail(char * msg) {
-void testmtx3(void) {
-
- chSemInit(&sem1, 1);
- println("*** Mutexes, mutex without inheritance, inversion happens, you should read BAC:");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread11, "A");
- t2 = chThdCreate(chThdGetPriority()-3, 0, wsT2, sizeof(wsT2), Thread12, "C");
- t3 = chThdCreate(chThdGetPriority()-2, 0, wsT3, sizeof(wsT3), Thread10, "B");
- chThdWait(t1);
- chThdWait(t2);
- chThdWait(t3);
- println("");
+ local_fail = TRUE;
+ global_fail = TRUE;
+ failmsg = msg;
}
-msg_t Thread13(void *p) {
-
- chMtxLock(&m1);
- CPU(50);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
+void test_assert(bool_t condition, char * msg) {
-msg_t Thread14(void *p) {
-
- chThdSleep(10);
- chMtxLock(&m2);
- CPU(20);
- chMtxLock(&m1);
- CPU(50);
- chMtxUnlock();
- CPU(20);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+ if (!condition)
+ test_fail(msg);
}
-msg_t Thread15(void *p) {
-
- chThdSleep(20);
- chMtxLock(&m2);
- CPU(50);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
-}
-
-msg_t Thread16(void *p) {
-
- chThdSleep(40);
- CPU(200);
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+void test_assert_sequence(char *expected) {
+ char *cp = tokens_buffer;
+ while (cp < tokp) {
+ if (*cp++ != *expected++)
+ test_fail(NULL);
+ }
+ if (*expected)
+ test_fail(NULL);
}
-msg_t Thread17(void *p) {
+void test_assert_time_window(systime_t start, systime_t end) {
- chThdSleep(50);
- chMtxLock(&m2);
- CPU(50);
- chMtxUnlock();
- chFDDPut(comp, *(uint8_t *)p);
- return 0;
+ test_assert(chSysInTimeWindow(start, end), "time window error");
}
/*
- * Time 0 10 20 30 40 50
- * 0 +++BL++------------------2++++------4+++++BU0--------------------------
- * 1 .......++AL++--2+++++++++BL.........4.....++++++++BU4++++AU1-----------
- * 2 .............++AL............................................------++AU
- * 3 ..............................++++-------------------------------++....
- * 4 ..................................++AL...................++++AU++......
+ * Threads utils.
*/
-void testmtx4(void) {
-
- chMtxInit(&m1); /* B */
- chMtxInit(&m2); /* A */
- println("*** Mutexes, mutex with inheritance (complex case), you should read ABCDE:");
- t1 = chThdCreate(chThdGetPriority()-5, 0, wsT1, sizeof(wsT1), Thread13, "E");
- t2 = chThdCreate(chThdGetPriority()-4, 0, wsT2, sizeof(wsT2), Thread14, "D");
- t3 = chThdCreate(chThdGetPriority()-3, 0, wsT3, sizeof(wsT3), Thread15, "C");
- t4 = chThdCreate(chThdGetPriority()-2, 0, wsT4, sizeof(wsT4), Thread16, "B");
- t5 = chThdCreate(chThdGetPriority()-1, 0, wsT5, sizeof(wsT5), Thread17, "A");
- wait();
- println("");
-}
+void test_wait_threads(void) {
+ int i;
-void testmsg1(void) {
- msg_t msg;
-
- println("*** Messages, dispatch test, you should read AABBCCDDEE:");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread4, chThdSelf());
- do {
- chMsgRelease(msg = chMsgWait());
- if (msg)
- chFDDPut(comp, msg);
- } while (msg);
- chThdWait(t1);
- println("");
+ for (i = 0; i < MAX_THREADS; i++)
+ if (threads[i])
+ chThdWait(threads[i]);
}
-__attribute__((noinline))
-unsigned int msg_loop_test(Thread *tp) {
- uint32_t i;
+void test_cpu_pulse(systime_t ms) {
- systime_t time = wait_tick() + 1000;
- i = 0;
- while (chSysGetTime() < time) {
- (void)chMsgSend(tp, 0);
- i++;
+ systime_t start = chSysGetTime();
+ while (chSysInTimeWindow(start, start + ms)) {
#if defined(WIN32)
ChkIntSources();
#endif
}
- return i;
}
-__attribute__((noinline))
-void precache(void) {
- uint32_t i;
-
- println("\r\nPreparing for benchmarks\r\n");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread6, 0);
- i = msg_loop_test(t1);
- chThdTerminate(t1);
- chThdWait(t1);
-}
+/*
+ * Test suite execution.
+ */
+static void execute_test(const struct testcase *tcp) {
+ int i;
-__attribute__((noinline))
-void bench1(void) {
- uint32_t i;
-
- println("*** Kernel Benchmark, context switch test #1 (optimal):");
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread6, 0);
- i = msg_loop_test(t1);
- chThdTerminate(t1);
- chThdWait(t1);
- print("Messages throughput = ");
- printn(i);
- print(" msgs/S, ");
- printn(i << 1);
- println(" ctxswc/S");
-}
+ /* Initialization */
+ clear_tokens();
+ local_fail = FALSE;
+ for (i = 0; i < MAX_THREADS; i++)
+ threads[i] = NULL;
-__attribute__((noinline))
-void bench2(void) {
- uint32_t i;
-
- println("*** Kernel Benchmark, context switch test #2 (no threads in ready list):");
- t1 = chThdCreate(chThdGetPriority()+1, 0, wsT1, sizeof(wsT1), Thread6, 0);
- i = msg_loop_test(t1);
- chThdTerminate(t1);
-chMsgSend(t1, 0);
- chThdWait(t1);
- print("Messages throughput = ");
- printn(i);
- print(" msgs/S, ");
- printn(i << 1);
- println(" ctxswc/S");
+ tcp->setup();
+ tcp->execute();
+ tcp->teardown();
}
-__attribute__((noinline))
-void bench3(void) {
- uint32_t i;
-
- println("*** Kernel Benchmark, context switch test #3 (04 threads in ready list):");
- t1 = chThdCreate(chThdGetPriority()+1, 0, wsT1, sizeof(wsT1), Thread6, "A");
- t2 = chThdCreate(chThdGetPriority()-2, 0, wsT2, sizeof(wsT2), Thread7, "B");
- t3 = chThdCreate(chThdGetPriority()-3, 0, wsT3, sizeof(wsT3), Thread7, "C");
- t4 = chThdCreate(chThdGetPriority()-4, 0, wsT4, sizeof(wsT4), Thread7, "D");
- t5 = chThdCreate(chThdGetPriority()-5, 0, wsT5, sizeof(wsT5), Thread7, "E");
- i = msg_loop_test(t1);
- chThdTerminate(t1);
-chMsgSend(t1, 0);
- wait();
- print("Messages throughput = ");
- printn(i);
- print(" msgs/S, ");
- printn(i << 1);
- println(" ctxswc/S");
-}
+msg_t TestThread(void *p) {
+ int i;
-__attribute__((noinline))
-void bench4(void) {
- uint32_t i;
- systime_t time;
+ comp = p;
+ test_println("");
+ test_println("*****************************");
+ test_println("*** ChibiOS/RT test suite ***");
+ test_println("*****************************");
+ test_println("");
- println("*** Kernel Benchmark, threads creation/termination:");
- time = wait_tick() + 1000;
+ global_fail = FALSE;
i = 0;
- while (chSysGetTime() < time) {
- t1 = chThdCreate(chThdGetPriority()-1, 0, wsT1, sizeof(wsT1), Thread7, NULL);
- chThdWait(t1);
- i++;
-#if defined(WIN32)
- ChkIntSources();
+ while (tests[i]) {
+#if DELAY_BETWEEN_TESTS > 0
+ chThdSleep(DELAY_BETWEEN_TESTS);
#endif
- }
- print("Threads throughput = ");
- printn(i);
- println(" threads/S");
-}
-
-__attribute__((noinline))
-void bench5(void) {
- static uint8_t ib[16];
- static Queue iq;
- uint32_t i;
- systime_t time;
-
- println("*** Kernel Benchmark, I/O Queues throughput:");
- chIQInit(&iq, ib, sizeof(ib), NULL);
- time = wait_tick() + 1000;
- i = 0;
- while (chSysGetTime() < time) {
- chIQPutI(&iq, 0);
- chIQPutI(&iq, 1);
- chIQPutI(&iq, 2);
- chIQPutI(&iq, 3);
- (void)chIQGet(&iq);
- (void)chIQGet(&iq);
- (void)chIQGet(&iq);
- (void)chIQGet(&iq);
+ test_println("------------------------------------------------------------");
+ test_print("--- Test Case ");
+ test_printn(i + 1);
+ test_print(" (");
+ test_print(tests[i]->gettest());
+ test_println(")");
+ execute_test(tests[i]);
+ if (local_fail) {
+ test_print("--- Result: FAIL (");
+ if (failmsg)
+ test_print(failmsg);
+ else {
+ test_print("sequence error: ");
+ print_tokens();
+ }
+ test_println(")");
+ }
+ else
+ test_println("--- Result: SUCCESS");
i++;
-#if defined(WIN32)
- ChkIntSources();
-#endif
}
- print("Queues throughput = ");
- printn(i * 4);
- println(" bytes/S");
-}
+ test_println("------------------------------------------------------------");
+ test_println("");
+ test_print("Final result: ");
+ if (global_fail)
+ test_println("FAIL");
+ else
+ test_println("SUCCESS");
-/**
- * Tester thread, this thread must be created with priority \p NORMALPRIO.
- */
-msg_t TestThread(void *p) {
-
- comp = p;
- println("*****************************");
- println("*** ChibiOS/RT test suite ***");
- println("*****************************");
- println("");
-
- /*
- * Ready list ordering tests.
- */
- testrdy1();
- testrdy2();
-
- /*
- * Semaphores tests.
- */
- testsem1();
- testsem2();
-
- /*
- * Mutexes tests.
- */
- testmtx1();
- testmtx2();
- testmtx3();
- testmtx4();
-
- /*
- * Messages tests.
- */
- testmsg1();
-
- /*
- * Kernel benchmarks.
- * NOTE: The calls to chThdSleep() are required in order to give I/O queues
- * enough time to transmit everything, else the tests would get some
- * extra interrupts to serve from previous tests.
- */
- precache();
- chThdSleep(100);
- bench1();
- chThdSleep(100);
- bench2();
- chThdSleep(100);
- bench3();
- chThdSleep(100);
- bench4();
- chThdSleep(100);
- bench5();
- chThdSleep(100);
-
- println("\r\nTest complete");
return 0;
}
|