Add test cases for enforcement of periods of periodic tasks

1 files changed, 83 insertions, 0 deletions

diff --git a/tests/sched.c b/tests/sched.c
index 6fd6d89..a91e736 100644
--- a/tests/sched.c
+++ b/tests/sched.c
@@ -1,6 +1,7 @@
 #include <sys/wait.h> /* for waitpid() */
 #include <unistd.h>
 #include <stdio.h>
+#include <math.h>
 
 #include "tests.h"
 #include "litmus.h"
@@ -76,4 +77,86 @@ TESTCASE(preempt_on_resume, P_FP | PSN_EDF,
         ASSERT( status ==  SIGUSR2);
 }
 
+#define PERIOD 100 /* in ms */
+#define JOBS 10
+#define ACCEPTABLE_MARGIN 5 /* in ms --- must be largish for QEMU */
 
+TESTCASE(jobs_are_rate_limited, LITMUS,
+         "periodic jobs are rate-limited (w/o synchronous release)")
+{
+        struct rt_task params;
+        double start, end, actual_delta_ms;
+        int i;
+
+        init_rt_task_param(&params);
+        params.cpu        = 0;
+        params.exec_cost  = ms2ns(40);
+        params.period     = ms2ns(PERIOD);
+        params.release_policy = TASK_PERIODIC;
+
+        SYSCALL( set_rt_task_param(gettid(), &params) );
+        SYSCALL( be_migrate_to_cpu(params.cpu) );
+        SYSCALL( task_mode(LITMUS_RT_TASK) );
+
+        start = wctime();
+        for (i = 0; i < JOBS; i++)
+                SYSCALL( sleep_next_period() );
+        end  = wctime();
+
+        SYSCALL( task_mode(BACKGROUND_TASK) );
+
+        actual_delta_ms = (end - start) * 1000.0;
+        if (fabs(JOBS * PERIOD - actual_delta_ms) > ACCEPTABLE_MARGIN)
+                fprintf(stderr, "actual_delta_ms:%.4f  expected:%.4f\n",
+                        actual_delta_ms, (double) (JOBS * PERIOD));
+        ASSERT( fabs(JOBS * PERIOD - actual_delta_ms) <= ACCEPTABLE_MARGIN);
+}
+
+TESTCASE(jobs_are_rate_limited_synch, LITMUS,
+         "periodic jobs are rate-limited (w/ synchronous release)")
+{
+        struct rt_task params;
+        double start, end, actual_delta_ms;
+        int i;
+        int child, status, waiters;
+        lt_t delay = ms2ns(100);
+
+        child = FORK_TASK(
+                init_rt_task_param(&params);
+                params.cpu        = 0;
+                params.exec_cost  = ms2ns(5);
+                params.period     = ms2ns(PERIOD);
+                params.release_policy = TASK_PERIODIC;
+
+                SYSCALL( set_rt_task_param(gettid(), &params) );
+                SYSCALL( be_migrate_to_cpu(params.cpu) );
+                SYSCALL( task_mode(LITMUS_RT_TASK) );
+
+                SYSCALL(  wait_for_ts_release() );
+
+                start = wctime();
+                for (i = 0; i < JOBS; i++)
+                        SYSCALL( sleep_next_period() );
+                end  = wctime();
+
+                SYSCALL( task_mode(BACKGROUND_TASK) );
+
+                actual_delta_ms = (end - start) * 1000.0;
+                if (fabs(JOBS * PERIOD - actual_delta_ms) > ACCEPTABLE_MARGIN)
+                        fprintf(stderr, "actual_delta_ms:%.4f  expected:%.4f\n",
+                                actual_delta_ms, (double) (JOBS * PERIOD));
+                ASSERT( fabs(JOBS * PERIOD - actual_delta_ms) <= ACCEPTABLE_MARGIN);
+        );
+
+        do {
+                waiters = get_nr_ts_release_waiters();
+                ASSERT( waiters >= 0 );
+        } while (waiters != 1);
+
+        waiters = release_ts(&delay);
+
+
+        /* wait for child to exit */
+        SYSCALL( waitpid(child, &status, 0) );
+        ASSERT( status == 0 );
+}