Change liblitmus to have a more sane repository layout.

11 files changed, 813 insertions, 0 deletions

diff --git a/src/edf-hsb.c b/src/edf-hsb.c
new file mode 100644
index 0000000..9ace2ca
--- /dev/null
+++ b/src/edf-hsb.c
@@ -0,0 +1,48 @@
+#include "litmus.h"
+#include "edf-hsb.h"
+
+
+typedef enum {
+        EDF_HSB_SET_HRT,
+        EDF_HSB_GET_HRT,
+        EDF_HSB_CREATE_BE
+} edf_hsb_setup_cmds_t;
+
+typedef struct {
+        int             cpu;
+        unsigned int    wcet;
+        unsigned int    period;
+} setup_hrt_param_t;
+
+typedef struct {
+        unsigned int    wcet;
+        unsigned int    period;
+} create_be_param_t;
+
+int set_hrt(int cpu, unsigned int  wcet, unsigned int  period)
+{
+        setup_hrt_param_t param;
+        param.cpu    = cpu;
+        param.wcet   = wcet;
+        param.period = period;
+        return scheduler_setup(EDF_HSB_SET_HRT, &param);
+}
+
+int get_hrt(int cpu, unsigned int *wcet, unsigned int *period)
+{
+        setup_hrt_param_t param;
+        int ret;
+        param.cpu    = cpu;
+        ret = scheduler_setup(EDF_HSB_GET_HRT, &param);
+        *wcet   = param.wcet;
+        *period = param.period;
+        return ret;
+}
+
+int create_be(unsigned int wcet, unsigned int period) 
+{
+        create_be_param_t param;
+        param.wcet   = wcet;
+        param.period = period;
+        return scheduler_setup(EDF_HSB_CREATE_BE, &param);
+}
diff --git a/src/hrt.c b/src/hrt.c
new file mode 100644
index 0000000..224293c
--- /dev/null
+++ b/src/hrt.c
@@ -0,0 +1,78 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include "edf-hsb.h"
+
+
+void usage(char *name) 
+{
+        fprintf(stderr, 
+                "EDF-HSB server setup utility\n"
+                "Usage: %s hrt show    <#cpu>\n"
+                "       %s hrt set     <#cpu> <wcet> <period>\n"
+                "       %s be  create         <wcet> <period>\n", 
+                name, name, name);
+        exit(1);
+}
+
+
+int hrt(int argc, char** argv) 
+{
+        int wcet, period, cpu;
+
+        if (argc == 2 && !strcmp(argv[0], "show")) {
+                cpu = atoi(argv[1]);
+                if (!get_hrt(cpu, &wcet, &period))
+                        printf("HRT/%d = (%d, %d)\n", cpu, wcet, period);
+                else
+                        perror("cannot read HRT settings");
+        } else if (argc == 4 && !strcmp(argv[0], "set")) {
+                cpu    = atoi(argv[1]);
+                wcet   = atoi(argv[2]);
+                period = atoi(argv[3]);
+                printf("Setting HRT/%d to (%d, %d)", cpu, wcet, period);
+                if (!set_hrt(cpu, wcet, period))
+                        printf(" OK.\n");
+                else {
+                        printf("\n");
+                        perror("cannot write HRT settings");
+                }       
+        } else
+                return 1;
+
+        return 0;
+}
+
+int be(int argc, char** argv)
+{
+        int wcet, period;
+        if (argc == 3 && !strcmp(argv[0], "create")) {
+                wcet    = atoi(argv[1]);
+                period   = atoi(argv[2]);
+                printf("Creating BE with (%d, %d)", wcet, period);
+                if (!create_be(wcet, period))
+                        printf(" OK.\n");
+                else {
+                        printf("\n");
+                        perror("cannot create BE server");
+                }
+                return 0;
+        }
+        else
+                return 1;
+}
+
+int main(int argc, char** argv) 
+{
+        int ret = 1;
+        if (argc > 1) {
+                if (!strcmp(argv[1], "hrt"))
+                        ret = hrt(argc - 2, argv + 2);
+                else if (!strcmp(argv[1], "be"))
+                        ret = be(argc - 2, argv + 2);
+        }
+        if (ret)
+                usage(argv[0]);
+        return ret;
+}
diff --git a/src/iotest.c b/src/iotest.c
new file mode 100644
index 0000000..ac07e74
--- /dev/null
+++ b/src/iotest.c
@@ -0,0 +1,74 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <signal.h>
+#include <unistd.h>
+#include <sys/time.h>
+#include <sys/wait.h>
+
+#include "litmus.h"
+
+#define US_PER_MS 1000
+
+int iotest(void *nil) {         
+        int id = getpid();
+        FILE* file;
+        char str[255];
+        unsigned long last = 0;
+        struct timeval time;
+
+        printf("I'am real time task %d  doing IO!\n", id);
+        snprintf(str, sizeof(str), "rt-io-%d.txt", id);
+        file = fopen(str, "w");
+        if (!file) {
+                perror("could not open file for output");
+                exit(1);
+        }
+        while (1) {
+                gettimeofday(&time, NULL);
+                if (time.tv_usec - last > US_PER_MS) {
+                  fprintf(file, "ran at %lus %lums\n", time.tv_sec, time.tv_usec / US_PER_MS);
+                  last = time.tv_usec;
+                }
+                fflush(file);
+        }
+        return id;
+}
+
+#define NUMTASKS 4
+
+int main(int argc, char** argv) 
+{
+        int rt_task[NUMTASKS];
+        int i;
+        int ret, pid;
+        
+        for (i = 0; i < NUMTASKS; i++) {                
+                /*                        func   arg  cpu  wcet  period */
+                rt_task[i] = create_rt_task(iotest, NULL,   0,   25,     100);
+                if (rt_task[i] < 0) {
+                        perror("Could not create rt child process");
+                }
+        }
+
+        sync();
+        sync();
+
+        printf(":: Starting real-time mode.\n");
+        set_rt_mode(MODE_RT_RUN);
+
+        printf(":: Sleeping...\n");
+        sleep(120);     
+
+        printf("Killing real-time tasks.\n");
+        for (i = 0; i < NUMTASKS; i++) {
+                printf(":: sending SIGKILL to %d\n", rt_task[i]);
+                kill(rt_task[i], SIGKILL);                      
+        }
+        for (i = 0; i < NUMTASKS; i++) {
+                pid = wait(&ret);
+                printf(":: %d exited with status %d\n", pid, ret);
+        }
+        printf(":: Leaving real-time mode.\n");
+        set_rt_mode(MODE_NON_RT);
+        return 0;       
+}
diff --git a/src/litmus.c b/src/litmus.c
new file mode 100644
index 0000000..65ad294
--- /dev/null
+++ b/src/litmus.c
@@ -0,0 +1,295 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include <errno.h>