#include <stdio.h>
#include <stdlib.h>
#include <malloc.h>
#include <pthread.h>
#include "semaphore.h"

Semaphore *make_semaphore (int value)
{
  Semaphore *semaphore = malloc (sizeof(Semaphore));
  semaphore->value = value;
  semaphore->wakeups = 0;
  semaphore->lock = make_lock ();
  semaphore->cond = make_cond ();
  return semaphore;
}

void semaphore_wait (Semaphore *semaphore)
{
  lock_acquire (semaphore->lock);
  semaphore->value--;

  if (semaphore->value < 0) {
    do {
      cond_wait (semaphore->cond, semaphore->lock);
    } while (semaphore->wakeups < 1);
    semaphore->wakeups--;
  }
  lock_release (semaphore->lock);
}

void semaphore_signal (Semaphore *semaphore)
{
  lock_acquire (semaphore->lock);
  semaphore->value++;

  if (semaphore->value <= 0) {
    semaphore->wakeups++;
    cond_signal (semaphore->cond);
  }
  lock_release (semaphore->lock);
}