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

Allocate rtsigs from back to front, to avoid clashes with other libraries makeing use of rtsigs

Browse source 
git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/lennart@1913 fefdeb5f-60dc-0310-8127-8f9354f1896f
This commit is contained in:
Lennart Poettering 2007-09-28 12:52:47 +00:00
parent df33b4c7b3
commit 3cdff5f3cc
1 changed files with 13 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

25
src/pulsecore/rtsig.c
View file

@ -50,17 +50,17 @@ static int rtsig_start = -1, rtsig_end = -1;
int pa_rtsig_get(void) { int pa_rtsig_get(void) {
void *p; void *p;
int sig; int sig;
if ((p = pa_flist_pop(PA_STATIC_FLIST_GET(rtsig_flist)))) if ((p = pa_flist_pop(PA_STATIC_FLIST_GET(rtsig_flist))))
return PA_PTR_TO_INT(p); return PA_PTR_TO_INT(p);
sig = pa_atomic_inc(&rtsig_current); sig = pa_atomic_dec(&rtsig_current);
pa_assert(sig >= SIGRTMIN); pa_assert(sig <= SIGRTMAX);
pa_assert(sig >= rtsig_start); pa_assert(sig <= rtsig_end);
if (sig > rtsig_end) { if (sig < rtsig_start) {
pa_atomic_dec(&rtsig_current); pa_atomic_inc(&rtsig_current);
return -1; return -1;
} }
@ -73,7 +73,7 @@ int pa_rtsig_get_for_thread(void) {
if ((p = PA_STATIC_TLS_GET(rtsig_tls))) if ((p = PA_STATIC_TLS_GET(rtsig_tls)))
return PA_PTR_TO_INT(p); return PA_PTR_TO_INT(p);
if ((sig = pa_rtsig_get()) < 0) if ((sig = pa_rtsig_get()) < 0)
return -1; return -1;
@ -102,11 +102,12 @@ void pa_rtsig_configure(int start, int end) {
rtsig_end = end; rtsig_end = end;
sigemptyset(&ss); sigemptyset(&ss);
for (s = rtsig_start; s <= rtsig_end; s++) for (s = rtsig_start; s <= rtsig_end; s++)
pa_assert_se(sigaddset(&ss, s) == 0); pa_assert_se(sigaddset(&ss, s) == 0);
pa_assert(pthread_sigmask(SIG_BLOCK, &ss, NULL) == 0); pa_assert(pthread_sigmask(SIG_BLOCK, &ss, NULL) == 0);
pa_atomic_store(&rtsig_current, rtsig_start); /* We allocate starting from the end */
pa_atomic_store(&rtsig_current, rtsig_end);
} }