blob: 6194f9236c85cda93ab4630863384629ae08d243 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
/* -*- c++ -*- */
/*
* Copyright 2006,2008,2013 Free Software Foundation, Inc.
*
* This file is part of GNU Radio
*
* SPDX-License-Identifier: GPL-3.0-or-later
*
*/
#ifndef INCLUDED_GNURADIO_REALTIME_H
#define INCLUDED_GNURADIO_REALTIME_H
#include <gnuradio/api.h>
#include <gnuradio/realtime.h>
#include <stdexcept>
/*!
* \brief System independent way to ask for realtime scheduling
*/
namespace gr {
namespace realtime {
/*
* Define the range for our virtual priorities (don't change
* these)
*
* Processes (or threads) with numerically higher priority values
* are scheduled before processes with numerically lower priority
* values. Thus, the value returned by s_rt_priority_max will be
* greater than the value returned by s_rt_priority_min.
*/
static const int s_rt_priority_min = 0;
static const int s_rt_priority_max = 15;
static const int s_rt_priority_default = 1;
struct GR_RUNTIME_API rt_sched_param {
int priority;
rt_sched_policy policy;
rt_sched_param() : priority(s_rt_priority_default), policy(RT_SCHED_RR) {}
rt_sched_param(int priority_, rt_sched_policy policy_ = RT_SCHED_RR)
{
if (priority_ < s_rt_priority_min || priority_ > s_rt_priority_max)
throw std::invalid_argument("rt_sched_param: priority out of range");
priority = priority_;
policy = policy_;
}
};
/*!
* \brief If possible, enable "realtime" scheduling.
* \ingroup misc
*
* In general, this means that the code will be scheduled before
* any non-realtime (normal) processes. Note that if your code
* contains an non-blocking infinite loop and you enable realtime
* scheduling, it's possible to hang the system.
*/
GR_RUNTIME_API rt_status_t enable_realtime_scheduling(rt_sched_param = rt_sched_param());
} /* namespace realtime */
} /* namespace gr */
#endif /* INCLUDED_GNURADIO_REALTIME_H */
|
