Semaphore.cpp

Go to the documentation of this file.

#include "Semaphore.hh"
#include "Thread.hh"

using namespace Nucleo;

void
Semaphore::wait(uint8_t count)
{
  uint8_t key = lock();
  while (count > m_count) {
    unlock(key);
    Thread::s_running->enqueue(&m_queue);
    key = lock();
  }
  m_count -= count;
  unlock(key);
}

void
Semaphore::signal(uint8_t count, bool flag)
{
  synchronized {
    m_count += count;
  }
  Thread::s_running->dequeue(&m_queue, flag);
}