diff options
author | Lennart Poettering <lennart@poettering.net> | 2009-08-16 02:02:51 +0200 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2009-08-16 02:02:51 +0200 |
commit | 01e4b61a910afdd21f860fadbe98075735c2bf51 (patch) | |
tree | e8cd7a63000a8fd354647c35c87a93236d32512d /src/pulsecore/aupdate.c | |
parent | 8dd0d871a7dd2d97c63ec8e38e1b408637d1b639 (diff) |
aupdate: implicitly call _write_swap() if it wasn't called explicitly
Diffstat (limited to 'src/pulsecore/aupdate.c')
-rw-r--r-- | src/pulsecore/aupdate.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/pulsecore/aupdate.c b/src/pulsecore/aupdate.c index 56ebb8e5..85b6e00e 100644 --- a/src/pulsecore/aupdate.c +++ b/src/pulsecore/aupdate.c @@ -39,6 +39,7 @@ struct pa_aupdate { pa_atomic_t read_lock; pa_mutex *write_lock; pa_semaphore *semaphore; + pa_bool_t swapped; }; pa_aupdate *pa_aupdate_new(void) { @@ -101,6 +102,8 @@ unsigned pa_aupdate_write_begin(pa_aupdate *a) { n = (unsigned) pa_atomic_load(&a->read_lock); + a->swapped = FALSE; + return !WHICH(n); } @@ -119,11 +122,16 @@ unsigned pa_aupdate_write_swap(pa_aupdate *a) { break; } + a->swapped = TRUE; + return WHICH(n); } void pa_aupdate_write_end(pa_aupdate *a) { pa_assert(a); + if (!a->swapped) + pa_aupdate_write_swap(a); + pa_mutex_unlock(a->write_lock); } |