mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-02 09:01:46 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

core-util: Clamp RLIMIT_RTTIME to what RealtimeKit accepts

Browse source 
In the default configuration, PulseAudio's rlimit-rttime is set to
1000000 (100%), which is higher than what RealtimeKit requires from
its clients (200000, 20%).

Make an attempt to still get realtime scheduling by clamping the
current RLIMIT_RTTIME to what RealtimeKit accepts. Warn about doing
this.
This commit is contained in:
Jan Alexander Steffens (heftig) 2013-06-09 18:47:05 +02:00 • committed by Tanu Kaskinen
parent baee32f2ee
commit 07290d9da7
1 changed files with 31 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

38
src/pulsecore/core-util.c
View file

@ -684,6 +684,10 @@ static int set_scheduler(int rtprio) {
struct sched_param sp;
#ifdef HAVE_DBUS
int r;
long long rttime;
#ifdef HAVE_SYS_RESOURCE_H
struct rlimit rl;
#endif
DBusError error;
DBusConnection *bus;
@ -721,16 +725,36 @@ static int set_scheduler(int rtprio) {
* https://bugs.freedesktop.org/show_bug.cgi?id=16924 */
dbus_connection_set_exit_on_disconnect(bus, FALSE);
r = rtkit_make_realtime(bus, 0, rtprio);
dbus_connection_close(bus);
dbus_connection_unref(bus);
rttime = rtkit_get_rttime_usec_max(bus);
if (rttime >= 0) {
#ifdef HAVE_SYS_RESOURCE_H
r = getrlimit(RLIMIT_RTTIME, &rl);
if (r >= 0) {
pa_log_debug("RealtimeKit worked.");
return 0;
if (r >= 0 && (long long) rl.rlim_max > rttime) {
pa_log_warn("Clamping rlimit-rttime to %lld for RealtimeKit\n", rttime);
rl.rlim_cur = rl.rlim_max = rttime;
r = setrlimit(RLIMIT_RTTIME, &rl);
if (r < 0)
pa_log_info("setrlimit() failed: %s", pa_cstrerror(errno));
}
#endif
r = rtkit_make_realtime(bus, 0, rtprio);
dbus_connection_close(bus);
dbus_connection_unref(bus);
if (r >= 0) {
pa_log_debug("RealtimeKit worked.");
return 0;
}
errno = -r;
} else {
dbus_connection_close(bus);
dbus_connection_unref(bus);
errno = -rttime;
}
errno = -r;
#else
errno = 0;
#endif