Change liblitmus to have a more sane repository layout.

3 files changed, 229 insertions, 0 deletions

diff --git a/include/edf-hsb.h b/include/edf-hsb.h
new file mode 100644
index 0000000..0ac3d4f
--- /dev/null
+++ b/include/edf-hsb.h
@@ -0,0 +1,10 @@
+#ifndef EDF_HSB_H
+#define EDF_HSB_H
+
+
+int set_hrt(int cpu, unsigned int  wcet, unsigned int  period);
+int get_hrt(int cpu, unsigned int *wcet, unsigned int *period);
+int create_be(unsigned int wcet, unsigned int period);
+
+
+#endif
diff --git a/include/litmus.h b/include/litmus.h
new file mode 100644
index 0000000..88b0f0b
--- /dev/null
+++ b/include/litmus.h
@@ -0,0 +1,107 @@
+#ifndef LITMUS_H
+#define LITMUS_H
+
+#include <sys/types.h>
+
+/* This flag is needed to start new RT tasks in STOPPED state   */
+/* Task is going to run in realtime mode */
+#define CLONE_REALTIME          0x10000000      
+
+typedef int (*rt_fn_t)(void*);
+
+/*      Litmus scheduling policies      */
+typedef enum {
+        SCHED_LINUX             =  0,
+        SCHED_PFAIR             =  1,
+        SCHED_PFAIR_STAGGER     =  2,
+        SCHED_PART_EDF          =  3,
+        SCHED_PART_EEVDF        =  4,
+        SCHED_GLOBAL_EDF        =  5,
+        SCHED_PFAIR_DESYNC      =  6,
+        SCHED_GLOBAL_EDF_NP     =  7,   
+        SCHED_CUSTOM            =  8,
+        SCHED_EDF_HSB           =  9,
+        SCHED_GSN_EDF           = 10,
+        SCHED_PSN_EDF           = 11
+} spolicy;
+
+/* different types of clients */
+typedef enum {
+        RT_CLASS_HARD,  
+        RT_CLASS_SOFT,
+        RT_CLASS_BEST_EFFORT
+} task_class_t;
+
+/*      Task RT params for schedulers */
+/*      RT task parameters for scheduling extensions    
+*       These parameters are inherited during clone and therefore must
+*       be explicitly set up before the task set is launched.
+*/
+typedef struct rt_param {       
+        /*      Execution cost  */
+        unsigned long exec_cost;        
+        /*      Period          */
+        unsigned long period;                   
+        /*      Partition       */
+        unsigned int cpu;
+        /*      type of task    */
+        task_class_t    cls;
+} rt_param_t;
+
+typedef int sema_id;     /* ID of a semaphore in the Linux kernel */
+typedef int pi_sema_id;  /* ID of a PI semaphore in the Linux kernel */
+typedef int srp_sema_id; /* ID of an SRP "semaphore" in the Linux kernel */
+
+typedef int pid_t;       /* PID of a task */
+
+#define set_param(t,p,e) do{\
+                        (t).is_realtime=1;\
+                        (t).exec_cost=(e);\
+                        (t).period=(p);\
+                        }while(0);
+
+/*      scheduler modes */
+#define MODE_NON_RT 0
+#define MODE_RT_RUN 1
+
+spolicy sched_setpolicy(spolicy policy);
+spolicy sched_getpolicy(void);
+int set_rt_mode(int mode);
+int set_rt_task_param(pid_t pid, rt_param_t* param);
+int get_rt_task_param(pid_t pid, rt_param_t* param);
+int prepare_rt_task(pid_t pid);
+int tear_down_task(pid_t pid, int sig);
+int reset_stat(void);
+int sleep_next_period(void);
+int scheduler_setup(int cmd, void* param);
+int pi_sema_init(void);
+int pi_down(pi_sema_id sem_id);
+int pi_up(pi_sema_id sem_id);
+int pi_sema_free(pi_sema_id sem_id);
+int sema_init(void);
+int down(sema_id sem_id);
+int up(sema_id sem_id);
+int sema_free(sema_id sem_id);
+int srp_sema_init(void);
+int srp_down(srp_sema_id sem_id);
+int srp_up(srp_sema_id sem_id);
+int reg_task_srp_sem(srp_sema_id sem_id, pid_t t_pid);
+int srp_sema_free(srp_sema_id sem_id);
+int get_job_no(unsigned int* job_no);
+int wait_for_job_release(unsigned int job_no);
+
+/*  library functions */
+void init_litmus(void);
+
+int create_rt_task(rt_fn_t rt_prog, void *arg, int cpu, int wcet, int period);
+int __create_rt_task(rt_fn_t rt_prog, void *arg, int cpu, int wcet, 
+                     int period, task_class_t cls);
+const char* get_scheduler_name(spolicy scheduler);
+void show_rt_param(rt_param_t* tp);
+task_class_t str2class(const char* str);
+
+void enter_np(void);
+void exit_np(void);
+
+
+#endif
diff --git a/include/logformat.h b/include/logformat.h
new file mode 100644
index 0000000..3a74bf7
--- /dev/null
+++ b/include/logformat.h
@@ -0,0 +1,112 @@
+#ifndef LOGFORMAT_H
+#define LOGFORMAT_H
+
+#include <linux/types.h>
+
+#include "litmus.h"
+
+typedef __u8  u8;
+typedef __u32 u32;
+typedef __u16 u16;
+
+typedef enum {
+        ST_INVOCATION           = 0,
+        ST_ARRIVAL              = 1,
+        ST_DEPARTURE            = 2,
+        ST_PREEMPTION           = 3,
+        ST_SCHEDULED            = 4,
+        ST_JOB_RELEASE          = 5,
+        ST_JOB_COMPLETION       = 6,
+        ST_CAPACITY_RELEASE     = 7,
+        ST_CAPACITY_ALLOCATION  = 8,
+        ST_LAST_TYPE            = 8
+} trace_type_t;
+
+typedef struct {
+        trace_type_t            trace:8;
+        unsigned long long      timestamp;
+} trace_header_t;
+
+
+typedef struct {
+        unsigned int            is_rt:1;
+        unsigned int            is_server:1;
+        task_class_t            cls:4;
+        unsigned int            budget:24;
+        u32                     deadline;
+
+        pid_t                   pid;
+} task_info_t;
+
+typedef struct {
+        trace_header_t          header;
+        unsigned long           flags;          
+} invocation_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+} arrival_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+} departure_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+        task_info_t             by;
+} preemption_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+} scheduled_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+        u16                     period;
+        u16                     wcet;   
+} release_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+        u16                     period;
+        u16                     wcet;
+        int                     tardiness;
+} completion_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+} cap_release_record_t;
+
+typedef struct {
+        trace_header_t          header;
+        task_info_t             task;
+        u16                     budget;
+        u32                     deadline;
+        pid_t                   donor;
+} cap_allocation_record_t;
+
+
+typedef union {
+        trace_header_t          header;
+        invocation_record_t     invocation;
+        arrival_record_t        arrival;
+        preemption_record_t     preemption;
+        scheduled_record_t      scheduled;
+
+        release_record_t        release;
+        completion_record_t     completion;     
+
+        cap_release_record_t    cap_release;
+        cap_allocation_record_t cap_alloc;
+} trace_record_t;
+
+
+
+#endif