From 3bcf13b5c38f23b3663f6a7030ae34383f651b4e Mon Sep 17 00:00:00 2001
From: Andrea Bastoni <bastoni@cs.unc.edu>
Date: Thu, 24 Jun 2010 21:08:02 -0400
Subject: [NPS-F] Add rt_launch version for NPS-F algo

---
 bin/rt_launch_npsf.c | 110 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 110 insertions(+)
 create mode 100644 bin/rt_launch_npsf.c

(limited to 'bin')

diff --git a/bin/rt_launch_npsf.c b/bin/rt_launch_npsf.c
new file mode 100644
index 0000000..97ad361
--- /dev/null
+++ b/bin/rt_launch_npsf.c
@@ -0,0 +1,110 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <limits.h>
+#include <signal.h>
+
+#include "litmus.h"
+#include "common.h"
+
+typedef struct {
+	int  wait;
+	char * exec_path;
+	char ** argv;
+} startup_info_t;
+
+
+int launch(void *task_info_p) {
+	startup_info_t *info = (startup_info_t*) task_info_p;
+	int ret;
+	if (info->wait) {
+		ret = wait_for_ts_release();
+		if (ret != 0)
+			perror("wait_for_ts_release()");
+	}
+	ret = execvp(info->exec_path, info->argv);
+	perror("execv failed");
+	return ret;
+}
+
+void usage(char *error) {
+	fprintf(stderr, "%s\nUsage: rt_launch [-w][-v] wcet period cpu npsf-id program [arg1 arg2 ...]\n"
+			"\t-w\tSynchronous release\n"
+			"\t-v\tVerbose\n"
+			"\twcet, period in ms\n"
+			"\tprogram to be launched\n",
+			error);
+	exit(1);
+}
+
+
+#define OPTSTR "vw"
+
+int main(int argc, char** argv)
+{
+	int ret;
+	lt_t wcet;
+	lt_t period;
+	int migrate = 0;
+	int cpu = 0;
+	int npsf_id;
+	int opt;
+	int verbose = 0;
+	int wait = 0;
+	startup_info_t info;
+
+	while ((opt = getopt(argc, argv, OPTSTR)) != -1) {
+		switch (opt) {
+		case 'w':
+			wait = 1;
+			break;
+		case 'v':
+			verbose = 1;
+			break;
+		case ':':
+			usage("Argument missing.");
+			break;
+		case '?':
+		default:
+			usage("Bad argument.");
+			break;
+		}
+	}
+
+	signal(SIGUSR1, SIG_IGN);
+
+	if (argc - optind < 5)
+		usage("Arguments missing.");
+	wcet   = ms2lt(atoi(argv[optind + 0]));
+	period = ms2lt(atoi(argv[optind + 1]));
+	cpu = atoi(argv[optind + 2]);
+	migrate = 1;
+	npsf_id = atoi(argv[optind + 3]);
+	if (wcet <= 0)
+	usage("The worst-case execution time must be a "
+	      "positive number.");
+	if (period <= 0)
+		usage("The period must be a positive number.");
+	if (wcet > period) {
+		usage("The worst-case execution time must not "
+		      "exceed the period.");
+	}
+	info.exec_path = argv[optind + 4];
+	info.argv      = argv + optind + 4;
+	info.wait      = wait;
+	if (migrate) {
+		ret = be_migrate_to(cpu);
+		if (ret < 0)
+			bail_out("could not migrate to target partition");
+	}
+	ret = __create_rt_task_npsf(launch, &info, cpu, wcet, period, npsf_id, RT_CLASS_HARD);
+
+
+	if (ret < 0)
+		bail_out("could not create rt child process");
+	else if (verbose)
+		printf("%d\n", ret);
+
+	return 0;
+}
-- 
cgit v1.2.2