Add an option for real-time priority mixing

Default to disable for now, as a safety precaution

5 files changed, 46 insertions, 6 deletions

diff --git a/Alc/ALc.c b/Alc/ALc.c
index 9225f330..970b98c9 100644
--- a/Alc/ALc.c
+++ b/Alc/ALc.c
@@ -208,6 +208,9 @@ static tls_type LocalContext;
 // Context Error
 static ALCenum g_eLastContextError = ALC_NO_ERROR;
 
+// Mixing Priority Level
+ALint RTPrioLevel;
+
 ///////////////////////////////////////////////////////
 
 
@@ -253,6 +256,8 @@ static void alc_init(void)
 
     tls_create(&LocalContext);
 
+    RTPrioLevel = GetConfigValueInt(NULL, "rt-prio", 0);
+
     devs = GetConfigValue(NULL, "drivers", "");
     if(devs[0])
     {
@@ -424,6 +429,39 @@ DECL_APPEND_LIST_FUNC(AllDevice)
 DECL_APPEND_LIST_FUNC(CaptureDevice)
 
 
+void EnableRTPrio(ALint level)
+{
+    ALboolean failed;
+
+#ifdef _WIN32
+    if(level > 0)
+        failed = !SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_TIME_CRITICAL);
+    else
+        failed = !SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_NORMAL);
+#elif defined(HAVE_PTHREAD_SETSCHEDPARAM)
+    struct sched_param param;
+
+    if(level > 0)
+    {
+        /* Use the minimum real-time priority possible for now (on Linux this
+         * should be 1 for SCHED_RR) */
+        param.sched_priority = sched_get_priority_min(SCHED_RR);
+        failed = !!pthread_setschedparam(pthread_self(), SCHED_RR, &param);
+    }
+    else
+    {
+        param.sched_priority = 0;
+        failed = !!pthread_setschedparam(pthread_self(), SCHED_OTHER, &param);
+    }
+#else
+    /* Real-time priority not available */
+    failed = !!level;
+#endif
+    if(failed)
+        AL_PRINT("Failed to set priority level for thread\n");
+}
+
+
 /*
     IsDevice
 
diff --git a/Alc/alsa.c b/Alc/alsa.c
index cfe80640..85092ceb 100644
--- a/Alc/alsa.c
+++ b/Alc/alsa.c
@@ -271,7 +271,7 @@ static ALuint ALSAProc(ALvoid *ptr)
     char *WritePtr;
     int err;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     while(!data->killNow)
     {
@@ -345,7 +345,7 @@ static ALuint ALSANoMMapProc(ALvoid *ptr)
     snd_pcm_sframes_t avail;
     char *WritePtr;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     while(!data->killNow)
     {
@@ -400,7 +400,7 @@ static ALuint ALSANoMMapCaptureProc(ALvoid *ptr)
     alsa_data *data = (alsa_data*)pDevice->ExtraData;
     snd_pcm_sframes_t avail;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     while(!data->killNow)
     {
diff --git a/Alc/dsound.c b/Alc/dsound.c
index 4a20b93e..e6294a43 100644
--- a/Alc/dsound.c
+++ b/Alc/dsound.c
@@ -134,7 +134,7 @@ static ALuint DSoundProc(ALvoid *ptr)
     DWORD avail;
     HRESULT err;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     memset(&DSBCaps, 0, sizeof(DSBCaps));
     DSBCaps.dwSize = sizeof(DSBCaps);
diff --git a/Alc/oss.c b/Alc/oss.c
index 4a7a48be..94380fde 100644
--- a/Alc/oss.c
+++ b/Alc/oss.c
@@ -82,7 +82,7 @@ static ALuint OSSProc(ALvoid *ptr)
     ALint frameSize;
     ssize_t wrote;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     frameSize = aluChannelsFromFormat(pDevice->Format) *
                 aluBytesFromFormat(pDevice->Format);
@@ -124,7 +124,7 @@ static ALuint OSSCaptureProc(ALvoid *ptr)
     int frameSize;
     int amt;
 
-    EnableRTPrio();
+    EnableRTPrio(RTPrioLevel);
 
     frameSize  = aluBytesFromFormat(pDevice->Format);
     frameSize *= aluChannelsFromFormat(pDevice->Format);
diff --git a/Alc/solaris.c b/Alc/solaris.c
index 6cfaaa11..a6a0dda4 100644
--- a/Alc/solaris.c
+++ b/Alc/solaris.c
@@ -57,6 +57,8 @@ static ALuint SolarisProc(ALvoid *ptr)
     ALint frameSize;
     int wrote;
 
+    EnableRTPrio(RTPrioLevel);
+
     frameSize = aluChannelsFromFormat(pDevice->Format) *
                 aluBytesFromFormat(pDevice->Format);