nptl/DESIGN-sem-old.txt

   1 Semaphores pseudocode
   2 ==============================
   3
   4        int sem_wait(sem_t * sem);
   5        int sem_trywait(sem_t * sem);
   6        int sem_post(sem_t * sem);
   7        int sem_getvalue(sem_t * sem, int * sval);
   8
   9 struct sem_t {
  10
  11    unsigned int lock:
  12          - internal mutex
  13
  14    unsigned int count;
  15          - current semaphore count, also used as a futex
  16
  17    unsigned int waiters;
  18          - number of threads queued in sem_wait().
  19 }
  20
  21 sem_wait(sem_t *sem)
  22 {
  23   lll_lock(sem->lock);
  24   for (;;) {
  25
  26     if (sem->count)
  27       break;
  28
  29     sem->waiters++;
  30     lll_unlock(sem->lock);
  31
  32     futex_wait(&sem->count, 0)
  33
  34     lll_lock(sem->lock);
  35     sem->waiters--;
  36   }
  37   sem->count--;
  38   lll_unlock(sem->lock);
  39 }
  40
  41 sem_post(sem_t *sem)
  42 {
  43   lll_lock(sem->lock);
  44   sem->count++;
  45   if (sem->waiters)
  46     futex_wake(&sem->count, sem->count);
  47   lll_unlock(sem->lock);
  48 }
  49
  50 sem_trywait(sem_t *sem)
  51 {
  52   lll_lock(sem->lock);
  53   if (sem->count) {
  54     sem->count--;
  55     lll_unlock(sem->lock);
  56     return 0;
  57   } else {
  58     lll_unlock(sem->lock);
  59     return -EAGAIN;
  60   }
  61 }
  62
  63 sem_getvalue(sem_t *sem, int *sval)
  64 {
  65   *sval = sem->count;
  66   read_barrier();
  67 }