5 files changed, 21 insertions, 5 deletions

diff --git a/all_pairs/bin/anagram b/all_pairs/bin/anagram
index 1a40ee7..341f73d 100755
--- a/all_pairs/bin/anagram
+++ b/all_pairs/bin/anagram
diff --git a/all_pairs/bin/audiobeam b/all_pairs/bin/audiobeam
index efc4584..d6054c9 100755
--- a/all_pairs/bin/audiobeam
+++ b/all_pairs/bin/audiobeam
diff --git a/all_pairs/bin/g723_enc b/all_pairs/bin/g723_enc
index afe3837..0b14f8d 100755
--- a/all_pairs/bin/g723_enc
+++ b/all_pairs/bin/g723_enc
diff --git a/all_pairs/bin/huff_dec b/all_pairs/bin/huff_dec
index f777646..0bcb0af 100755
--- a/all_pairs/bin/huff_dec
+++ b/all_pairs/bin/huff_dec
diff --git a/extra.h b/extra.h
index d021303..29afd9f 100644
--- a/extra.h
+++ b/extra.h
@@ -77,7 +77,9 @@ char _rt_shm_name[_ID_SZ] = "/_libextra_barrier-";
 #endif /* PAIRED */
 
 #if LITMUS
-long unsigned int _rt_period;
+lt_t _rt_period;
+int _rt_crit;
+struct control_page *_rt_cp;
 #endif
 
 static void _rt_load_params_itrl(int argc, char **argv) {
@@ -202,8 +204,8 @@ static void _rt_load_params_itrl(int argc, char **argv) {
     _rt_jobs_complete = 0;
     mlockall(MCL_CURRENT || MCL_FUTURE);
 #if LITMUS
-    _rt_period = strtoul(argv[end], NULL, 10);
-    unsigned int crit = atoi(argv[end+1]);
+    _rt_period = ms2ns(strtoul(argv[end], NULL, 10));
+    _rt_crit = atoi(argv[end+1]);
     unsigned int wait = 1;
     if (be_migrate_to_domain(_rt_core) < 0) {
         perror("Unable to migrate to specified CPU");
@@ -213,11 +215,11 @@ static void _rt_load_params_itrl(int argc, char **argv) {
     init_rt_task_param(&rt_param);
     // Fake exec cost - this value ignored by the MC^2 scheduler
     rt_param.exec_cost = _rt_period;
-    rt_param.period = ms2ns(_rt_period);
+    rt_param.period = _rt_period;
     rt_param.relative_deadline = 0;
     rt_param.phase = 0;
     rt_param.priority = LITMUS_LOWEST_PRIORITY;
-    rt_param.cls = crit;
+    rt_param.cls = _rt_crit;
     rt_param.budget_policy = NO_ENFORCEMENT;
     rt_param.cpu = _rt_core;
     rt_param.release_policy = TASK_PERIODIC;
@@ -233,6 +235,7 @@ static void _rt_load_params_itrl(int argc, char **argv) {
         perror("Unable to become real-time task");
         exit(1);
     }
+    _rt_cp = get_ctrl_page();
     if (wait && wait_for_ts_release() != 0) {
         perror("Unable to wait for taskset release");
         exit(1);
@@ -412,6 +415,19 @@ out:
 // Start a job
 static void _rt_start_loop() {
 #if LITMUS
+    lt_t now = litmus_clock();
+    if (now > _rt_cp->deadline) {
+        if (_rt_crit == 0)
+            fprintf(stderr, "CATASTROPHIC: Level-A");
+        else if (_rt_crit == 1)
+            fprintf(stderr, "HAZARDOUS: Level-B");
+        else
+            fprintf(stderr, "MAJOR: Level-C");
+        fprintf(stderr, " task %s tardy %llu ns, "
+               "relative tardiness %f\n",
+               _rt_our_prog_name, now - _rt_cp->deadline,
+               (now - _rt_cp->deadline) / (double)_rt_period);
+    }
     if (sleep_next_period() != 0) {
         perror("Unable to sleep for next period");
     }