code.delx.au - pulseaudio/blob - src/pulsecore/semaphore-posix.c

   1 /* $Id$ */
   2
   3 /***
   4   This file is part of PulseAudio.
   5
   6   Copyright 2006 Lennart Poettering
   7
   8   PulseAudio is free software; you can redistribute it and/or modify
   9   it under the terms of the GNU Lesser General Public License as published
  10   by the Free Software Foundation; either version 2 of the License,
  11   or (at your option) any later version.
  12
  13   PulseAudio is distributed in the hope that it will be useful, but
  14   WITHOUT ANY WARRANTY; without even the implied warranty of
  15   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  16   General Public License for more details.
  17
  18   You should have received a copy of the GNU Lesser General Public License
  19   along with PulseAudio; if not, write to the Free Software
  20   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
  21   USA.
  22 ***/
  23
  24 #ifdef HAVE_CONFIG_H
  25 #include <config.h>
  26 #endif
  27
  28 #include <errno.h>
  29 #include <pthread.h>
  30 #include <semaphore.h>
  31
  32 #include <pulse/xmalloc.h>
  33 #include <pulsecore/macro.h>
  34
  35 #include "semaphore.h"
  36
  37 struct pa_semaphore {
  38     sem_t sem;
  39 };
  40
  41 pa_semaphore* pa_semaphore_new(unsigned value) {
  42     pa_semaphore *s;
  43
  44     s = pa_xnew(pa_semaphore, 1);
  45     pa_assert_se(sem_init(&s->sem, 0, value) == 0);
  46     return s;
  47 }
  48
  49 void pa_semaphore_free(pa_semaphore *s) {
  50     pa_assert(s);
  51     pa_assert_se(sem_destroy(&s->sem) == 0);
  52     pa_xfree(s);
  53 }
  54
  55 void pa_semaphore_post(pa_semaphore *s) {
  56     pa_assert(s);
  57     pa_assert_se(sem_post(&s->sem) == 0);
  58 }
  59
  60 void pa_semaphore_wait(pa_semaphore *s) {
  61     int ret;
  62     pa_assert(s);
  63
  64     do {
  65         ret = sem_wait(&s->sem);
  66     } while (ret < 0 && errno == EINTR);
  67
  68     pa_assert(ret == 0);
  69 }