@@ -46,8 +46,10 @@
#include <time.h>
#include <errno.h>
#include <stdio.h>
+#include <sched.h>
#define DEFAULT_PRIORITY 70
+#define SET_RT_SCHEDULER(paraA, paraB, paraC) sched_setscheduler(paraA, paraB, paraC)
#if 0
int openlog (char *);
@@ -90,7 +90,9 @@ int verbose = 0;
int debug = 0;
long execution_time = DEFAULT_EXECUTION_TIME;
char *priority = DEFAULT_PRIORITY_TYPE;
-
+struct sched_param param = {
+ .sched_priority = DEFAULT_PRIORITY
+};
/*---------------------------------------------------------------------+
| main |
| ==================================================================== |
@@ -127,10 +129,10 @@ int main(int argc, char **argv)
if (!strcmp(priority, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
}
@@ -72,7 +72,9 @@
void process_file(char *);
void parse_args(int, char **);
void signal_handler();
-
+struct sched_param param = {
+ .sched_priority = DEFAULT_PRIORITY
+};
/*
* Global variables:
*
@@ -128,10 +130,10 @@ int main(int argc, char **argv)
if (!strcmp(priority, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
}
@@ -47,7 +47,9 @@
#include <sys/time.h>
#include <sys/resource.h>
#include "sched.h"
-
+struct sched_param param = {
+ .sched_priority = DEFAULT_PRIORITY
+};
/*
* Defines:
*
@@ -129,10 +131,10 @@ int main(int argc, char **argv)
if (!strcmp(priority, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
}
@@ -95,7 +95,9 @@ int verbose = 0;
int debug = 0;
int signaled = 0;
char *priority = DEFAULT_PRIORITY_TYPE;
-
+struct sched_param param = {
+ .sched_priority = DEFAULT_PRIORITY
+};
/*---------------------------------------------------------------------+
| main |
| ==================================================================== |
@@ -131,10 +133,10 @@ int main(int argc, char **argv)
if (!strcmp(priority, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
}
@@ -99,7 +99,7 @@ int debug = 0;
int priority = DEFAULT_PRIORITY;
char *logfile = DEFAULT_LOGFILE;
char *priority_type = DEFAULT_PRIORITY_TYPE;
-
+struct sched_param param;
/*---------------------------------------------------------------------+
| main |
| ==================================================================== |
@@ -133,10 +133,11 @@ int main(int argc, char **argv)
if (!strcmp(priority_type, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ param.sched_priority = priority;
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
} else {
if (nice((priority - 50) - (nice(0) + 20)) < 0 && errno != 0)
@@ -95,7 +95,7 @@ int debug = 0;
int priority = DEFAULT_PRIORITY;
char *logfile = DEFAULT_LOGFILE;
char *priority_type = DEFAULT_PRIORITY_TYPE;
-
+struct sched_param param;
/*---------------------------------------------------------------------+
| main |
| ==================================================================== |
@@ -130,10 +130,11 @@ int main(int argc, char **argv)
if (!strcmp(priority_type, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ param.sched_priority = priority;
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
} else {
if (nice((priority - 50) - (nice(0) + 20)) < 0 && errno != 0)
@@ -117,6 +117,7 @@ char *logfile = DEFAULT_LOGFILE;
char *priority_type = DEFAULT_PRIORITY_TYPE;
struct flock flock_struct;
struct flock *flock_ptr = &flock_struct;
+struct sched_param param;
int open_file(char *, int);
@@ -163,10 +164,11 @@ int main(int argc, char **argv)
if (!strcmp(priority_type, "fixed")) {
#ifndef __linux__
if (setpri(0, DEFAULT_PRIORITY) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#else
- if (setpriority(PRIO_PROCESS, 0, 0) < 0)
- sys_error("setpri failed", __FILE__, __LINE__);
+ param.sched_priority = priority;
+ if (SET_RT_SCHEDULER(0, SCHED_RR, ¶m) < 0)
+ sys_error("set rt pri failed", __FILE__, __LINE__);
#endif
} else {
if (nice((priority - 50) - (nice(0) + 20)) < 0 && errno != 0)