Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

use exceptions instead of return codes for error handling

Browse source
This commit is contained in:
Steffen Vogel 2019-02-12 17:28:37 +01:00
parent 34a1406ec8
commit 45b4dec42d
2 changed files with 13 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
common/include/villas/kernel/rt.hpp
View file

@ -32,20 +32,20 @@ namespace villas {
namespace kernel {
namespace rt {
int init(int priority, int affinity);
void init(int priority, int affinity);
int setAffinity(int affinity);
void setAffinity(int affinity);
int setPriority(int priority);
void setPriority(int priority);
/** Checks for realtime (PREEMPT_RT) patched kernel.
*
* See https://rt.wiki.kernel.org
*
* @retval 0 Kernel is patched.
* @reval <>0 Kernel is not patched.
* @retval true Kernel is patched.
* @retval false Kernel is not patched.
*/
int isPreemptible();
bool isPreemptible();
} // namespace villas
} // namespace kernel

23
common/lib/kernel/rt.cpp
View file

@ -22,7 +22,6 @@
#include <sched.h>
#include <unistd.h>
#include <sys/mman.h>
#include <villas/log.hpp>
#include <villas/cpuset.hpp>
@ -42,7 +41,7 @@ namespace villas {
namespace kernel {
namespace rt {
int init(int priority, int affinity)
void init(int priority, int affinity)
{
Logger logger = logging.get("kernel:rt");
@ -53,7 +52,7 @@ int init(int priority, int affinity)
/* Use FIFO scheduler with real time priority */
is_rt = isPreemptible();
if (is_rt)
if (!is_rt)
logger->warn("We recommend to use an PREEMPT_RT patched kernel!");
if (priority)
@ -65,20 +64,16 @@ int init(int priority, int affinity)
setAffinity(affinity);
else
logger->warn("You might want to use the 'affinity' setting to pin " PROJECT_NAME " to dedicate CPU cores");
lockMemory();
#else
logger->warn("This platform is not optimized for real-time execution");
(void) affinity;
(void) priority;
#endif
return 0;
}
#ifdef __linux__
int setAffinity(int affinity)
void setAffinity(int affinity)
{
char isolcpus[255];
int is_isol, ret;
@ -109,11 +104,9 @@ int setAffinity(int affinity)
throw SystemError("Failed to set CPU affinity to {}", (std::string) cset_pin);
logger->debug("Set affinity to {}", (std::string) cset_pin);
return 0;
}
int setPriority(int priority)
void setPriority(int priority)
{
int ret;
struct sched_param param = {
@ -127,13 +120,11 @@ int setPriority(int priority)
throw SystemError("Failed to set real time priority");
logger->debug("Task priority set to {}", priority);
return 0;
}
int isPreemptible()
bool isPreemptible()
{
return access(SYSFS_PATH "/kernel/realtime", R_OK);
return access(SYSFS_PATH "/kernel/realtime", R_OK) == 0;
}
#endif /* __linux__ */