core: ask RealtimeKit for RT scheduling

[pulseaudio] / src / pulsecore / semaphore.h

diff --git a/src/pulsecore/semaphore.h b/src/pulsecore/semaphore.h
index 850ae8171035e9f2806fcbf50c1a1255fabc153e..2bf81496e0ccded92fc96e0b899833ca96ac4ac0 100644 (file)
--- a/src/pulsecore/semaphore.h
+++ b/src/pulsecore/semaphore.h
@@ -8,7 +8,7 @@
 
   PulseAudio is free software; you can redistribute it and/or modify
   it under the terms of the GNU Lesser General Public License as
 
   PulseAudio is free software; you can redistribute it and/or modify
   it under the terms of the GNU Lesser General Public License as

-  published by the Free Software Foundation; either version 2 of the
+  published by the Free Software Foundation; either version 2.1 of the

   License, or (at your option) any later version.
 
   PulseAudio is distributed in the hope that it will be useful, but
   License, or (at your option) any later version.
 
   PulseAudio is distributed in the hope that it will be useful, but


@@ -22,6 +22,9 @@
   USA.
 ***/
 
   USA.
 ***/
 

+#include <pulsecore/macro.h>
+#include <pulsecore/atomic.h>
+

 typedef struct pa_semaphore pa_semaphore;
 
 pa_semaphore* pa_semaphore_new(unsigned value);
 typedef struct pa_semaphore pa_semaphore;
 
 pa_semaphore* pa_semaphore_new(unsigned value);


@@ -30,4 +33,16 @@ void pa_semaphore_free(pa_semaphore *m);
 void pa_semaphore_post(pa_semaphore *m);
 void pa_semaphore_wait(pa_semaphore *m);
 
 void pa_semaphore_post(pa_semaphore *m);
 void pa_semaphore_wait(pa_semaphore *m);
 

+/* Static semaphores are basically just atomically updated pointers to
+ * pa_semaphore objects */
+
+typedef struct pa_static_semaphore {
+    pa_atomic_ptr_t ptr;
+} pa_static_semaphore;
+
+#define PA_STATIC_SEMAPHORE_INIT { PA_ATOMIC_PTR_INIT(NULL) }
+
+/* When you call this make sure to pass always the same value parameter! */
+pa_semaphore* pa_static_semaphore_get(pa_static_semaphore *m, unsigned value);
+

 #endif
 #endif