4 files changed, 38 insertions, 0 deletions

diff --git a/sys/wasapi/gstwasapisink.c b/sys/wasapi/gstwasapisink.c
index 0f0d299d4..8a9d3f89d 100644
--- a/sys/wasapi/gstwasapisink.c
+++ b/sys/wasapi/gstwasapisink.c
@@ -40,6 +40,8 @@
 
 #include "gstwasapisink.h"
 
+#include <avrt.h>
+
 GST_DEBUG_CATEGORY_STATIC (gst_wasapi_sink_debug);
 #define GST_CAT_DEFAULT gst_wasapi_sink_debug
 
@@ -472,6 +474,15 @@ gst_wasapi_sink_prepare (GstAudioSink * asink, GstAudioRingBufferSpec * spec)
   gst_audio_ring_buffer_set_channel_positions (GST_AUDIO_BASE_SINK
       (self)->ringbuffer, self->positions);
 
+#if defined(_MSC_VER) || defined(GST_FORCE_WIN_AVRT)
+  /* Increase the thread priority to reduce glitches */
+  {
+    DWORD taskIndex = 0;
+    self->thread_priority_handle =
+        AvSetMmThreadCharacteristics (TEXT ("Pro Audio"), &taskIndex);
+  }
+#endif
+
   res = TRUE;
 
 beach:
@@ -489,6 +500,13 @@ gst_wasapi_sink_unprepare (GstAudioSink * asink)
   if (self->sharemode == AUDCLNT_SHAREMODE_EXCLUSIVE)
     CoUninitialize ();
 
+#if defined(_MSC_VER) || defined(GST_FORCE_WIN_AVRT)
+  if (self->thread_priority_handle != NULL) {
+    AvRevertMmThreadCharacteristics (self->thread_priority_handle);
+    self->thread_priority_handle = NULL;
+  }
+#endif
+
   if (self->client != NULL) {
     IAudioClient_Stop (self->client);
   }
diff --git a/sys/wasapi/gstwasapisink.h b/sys/wasapi/gstwasapisink.h
index 882f46e2c..588d5807d 100644
--- a/sys/wasapi/gstwasapisink.h
+++ b/sys/wasapi/gstwasapisink.h
@@ -44,6 +44,7 @@ struct _GstWasapiSink
   IAudioClient *client;
   IAudioRenderClient *render_client;
   HANDLE event_handle;
+  HANDLE thread_priority_handle;
 
   /* Actual size of the allocated buffer */
   guint buffer_frame_count;
diff --git a/sys/wasapi/gstwasapisrc.c b/sys/wasapi/gstwasapisrc.c
index dec93f829..49f1d31b5 100644
--- a/sys/wasapi/gstwasapisrc.c
+++ b/sys/wasapi/gstwasapisrc.c
@@ -38,6 +38,8 @@
 
 #include "gstwasapisrc.h"
 
+#include <avrt.h>
+
 GST_DEBUG_CATEGORY_STATIC (gst_wasapi_src_debug);
 #define GST_CAT_DEFAULT gst_wasapi_src_debug
 
@@ -477,6 +479,15 @@ gst_wasapi_src_prepare (GstAudioSrc * asrc, GstAudioRingBufferSpec * spec)
   gst_audio_ring_buffer_set_channel_positions (GST_AUDIO_BASE_SRC
       (self)->ringbuffer, self->positions);
 
+#if defined(_MSC_VER) || defined(GST_FORCE_WIN_AVRT)
+  /* Increase the thread priority to reduce glitches */
+  {
+    DWORD taskIndex = 0;
+    self->thread_priority_handle =
+        AvSetMmThreadCharacteristics (TEXT ("Pro Audio"), &taskIndex);
+  }
+#endif
+
   res = TRUE;
 
 beach:
@@ -499,6 +510,13 @@ gst_wasapi_src_unprepare (GstAudioSrc * asrc)
   if (self->sharemode == AUDCLNT_SHAREMODE_EXCLUSIVE)
     CoUninitialize ();
 
+#if defined(_MSC_VER) || defined(GST_FORCE_WIN_AVRT)
+  if (self->thread_priority_handle != NULL) {
+    AvRevertMmThreadCharacteristics (self->thread_priority_handle);
+    self->thread_priority_handle = NULL;
+  }
+#endif
+
   if (self->client != NULL) {
     IAudioClient_Stop (self->client);
   }
diff --git a/sys/wasapi/gstwasapisrc.h b/sys/wasapi/gstwasapisrc.h
index fc89391a9..530fb2b92 100644
--- a/sys/wasapi/gstwasapisrc.h
+++ b/sys/wasapi/gstwasapisrc.h
@@ -46,6 +46,7 @@ struct _GstWasapiSrc
   guint64 client_clock_freq;
   IAudioCaptureClient *capture_client;
   HANDLE event_handle;
+  HANDLE thread_priority_handle;
 
   /* Actual size of the allocated buffer */
   guint buffer_frame_count;