latest changes on pound.wip-rwrnlp

6 files changed, 95 insertions, 38 deletions

diff --git a/Makefile b/Makefile
index 6bf9ed9..84f83e2 100644
--- a/Makefile
+++ b/Makefile
@@ -207,7 +207,7 @@ obj-base_mt_task = base_mt_task.o
 ldf-base_mt_task = -pthread
 
 obj-rwrnlp = rwrnlp.o
-ldf-rwrnlp = -pthread -lrt
+ldf-rwrnlp = -lrt -pthread
 
 obj-rt_launch = rt_launch.o common.o
 
@@ -224,7 +224,7 @@ lib-measure_syscall = -lm
 
 .SECONDEXPANSION:
 ${rt-apps}: $${obj-$$@} liblitmus.a
-        $(CC) -o $@ $(LDFLAGS) ${ldf-$@} $(filter-out liblitmus.a,$+) $(LOADLIBS) $(LDLIBS) ${liblitmus-flags} ${lib-$@}
+        $(CC) -o $@ $(LDFLAGS) ${ldf-$@} $(filter-out liblitmus.a,$+) $(LOADLIBS) $(LDLIBS) ${liblitmus-flags} ${lib-$@} -lrt
 
 # ##############################################################################
 # Dependency resolution.
diff --git a/bin/rwrnlp.c b/bin/rwrnlp.c
index 07e3899..a73e2ad 100644
--- a/bin/rwrnlp.c
+++ b/bin/rwrnlp.c
@@ -146,7 +146,7 @@ struct thread_context* parse_csv(const char *file, int *num_tasks)
         } else {
             ctx[cur_task].type = write_req;
         }
-                if (1 != fscanf(fstream, "%ld",&ctx[cur_task].resources)){
+                if (1 != fscanf(fstream, "%lu",&ctx[cur_task].resources)){
                         fprintf(stderr, "invalid resource mask near line %d\n", cur_task);
                         exit(EXIT_FAILURE);
                 }
@@ -286,32 +286,35 @@ static int loop_for(double exec_time, double emergency_exit)
 static int job(struct thread_context *ctx, double program_end)
 {
     double ncs_length;
-    double cs_length;
+    long lock_overhead, unlock_overhead;
         if (wctime() > program_end){
         printf("Terminating...\n");
                 return 0;
     }
         else {
         ncs_length = (ctx->cost-ctx->cs_length)/2*S_PER_MS;
-        cs_length = ctx->cs_length * S_PER_MS;
                 loop_for(ncs_length, program_end + 1);
 
         if(ctx->type == read_req){
             //printf("%d:%d read locking...\n", __sync_fetch_and_add(&events,1), gettid());
-            rwrnlp_read_lock(&rw_lock, ctx->resources, ctx->processor);
+            lock_overhead = rwrnlp_read_lock(&rw_lock, ctx->resources, ctx->processor);
             //printf("%d:%d read CS...\n", __sync_fetch_and_add(&events, 1), gettid());
             loop_for(ctx->cs_length*S_PER_MS, program_end + 1);
             //printf("%d:%d read unlocking...\n", __sync_fetch_and_add(&events,1), gettid());
-            rwrnlp_read_unlock(&rw_lock, ctx->processor);
+            unlock_overhead = rwrnlp_read_unlock(&rw_lock, ctx->processor);
             //printf("%d:%d ncs...\n", __sync_fetch_and_add(&events,1), gettid());
+            printf("read lock overhead: %ld\n", lock_overhead);
+            printf("read unlock overhead: %ld\n", unlock_overhead);
         }else{
             //printf("%d:%d write locking %lu\n", __sync_fetch_and_add(&events,1), gettid(), ctx->resources);
-            rwrnlp_write_lock(&rw_lock, ctx->resources, ctx->processor);
+            lock_overhead = rwrnlp_write_lock(&rw_lock, ctx->resources, ctx->processor);
             //printf("%d:%d write CS...\n", __sync_fetch_and_add(&events,1), gettid());
             loop_for(ctx->cs_length*S_PER_MS, program_end + 1);
             //printf("%d:%d write unlocking...\n", __sync_fetch_and_add(&events,1), gettid());
-            rwrnlp_write_unlock(&rw_lock, ctx->processor);
+            unlock_overhead = rwrnlp_write_unlock(&rw_lock, ctx->processor);
             //printf("%d:%d ncs...\n", __sync_fetch_and_add(&events,1), gettid());
+            printf("write lock overhead: %ld\n", lock_overhead);
+            printf("write unlock overhead: %ld\n", unlock_overhead);
         }
 
 
diff --git a/include/litmus/rt_param.h b/include/litmus/rt_param.h
index 2026819..de29bac 100644
--- a/include/litmus/rt_param.h
+++ b/include/litmus/rt_param.h
@@ -33,6 +33,24 @@ typedef enum {
         PRECISE_ENFORCEMENT  /* budgets are enforced with hrtimers */
 } budget_policy_t;
 
+/* Release behaviors for jobs. PERIODIC and EARLY jobs
+   must end by calling sys_complete_job() (or equivalent)
+   to set up their next release and deadline. */
+typedef enum {
+        /* Jobs are released sporadically (provided job precedence
+       constraints are met). */
+        SPORADIC,
+
+        /* Jobs are released periodically (provided job precedence
+       constraints are met). */
+        PERIODIC,
+
+    /* Jobs are released immediately after meeting precedence
+       constraints. Beware this can peg your CPUs if used in
+       the wrong applications. Only supported by EDF schedulers. */
+        EARLY
+} release_policy_t;
+
 /* We use the common priority interpretation "lower index == higher priority",
  * which is commonly used in fixed-priority schedulability analysis papers.
  * So, a numerically lower priority value implies higher scheduling priority,
@@ -61,7 +79,8 @@ struct rt_task {
         unsigned int    cpu;
         unsigned int    priority;
         task_class_t    cls;
-        budget_policy_t budget_policy; /* ignored by pfair */
+        budget_policy_t  budget_policy;  /* ignored by pfair */
+        release_policy_t release_policy;
 };
 
 union np_flag {
@@ -89,11 +108,29 @@ union np_flag {
  * determining preemption/migration overheads).
  */
 struct control_page {
+        /* This flag is used by userspace to communicate non-preempive
+         * sections. */
         volatile union np_flag sched;
 
+        volatile uint64_t irq_count; /* Incremented by the kernel each time an IRQ is
+                                      * handled. */
+
+        /* Locking overhead tracing: userspace records here the time stamp
+         * and IRQ counter prior to starting the system call. */
+        uint64_t ts_syscall_start;  /* Feather-Trace cycles */
+        uint64_t irq_syscall_start; /* Snapshot of irq_count when the syscall
+                                     * started. */
+
         /* to be extended */
 };
 
+/* Expected offsets within the control page. */
+
+#define LITMUS_CP_OFFSET_SCHED          0
+#define LITMUS_CP_OFFSET_IRQ_COUNT      8
+#define LITMUS_CP_OFFSET_TS_SC_START    16
+#define LITMUS_CP_OFFSET_IRQ_SC_START   24
+
 /* don't export internal data structures to user space (liblitmus) */
 #ifdef __KERNEL__
 
@@ -142,11 +179,19 @@ struct rt_param {
         /* is the task present? (true if it can be scheduled) */
         unsigned int            present:1;
 
+        /* has the task completed? */
+        unsigned int            completed:1;
+
 #ifdef CONFIG_LITMUS_LOCKING
         /* Is the task being priority-boosted by a locking protocol? */
         unsigned int            priority_boosted:1;
         /* If so, when did this start? */
         lt_t                    boost_start_time;
+
+        /* How many LITMUS^RT locks does the task currently hold/wait for? */
+        unsigned int            num_locks_held;
+        /* How many PCP/SRP locks does the task currently hold/wait for? */
+        unsigned int            num_local_locks_held;
 #endif
 
         /* user controlled parameters */
@@ -233,11 +278,6 @@ struct rt_param {
         lt_t tot_exec_time;
 };
 
-/*      Possible RT flags       */
-#define RT_F_RUNNING            0x00000000
-#define RT_F_SLEEP              0x00000001
-#define RT_F_EXIT_SEM           0x00000008
-