---

eventqueue.cpp

Go to the documentation of this file.

#include "sysconfig.h"
#include "eventqueue.h"
#include "guard.h"

#pragma argsused
EventQueue::EventQueue(int num_threads) {
//  mFree = CreateSemaphore(0, num_threads, num_threads, 0);
//  mUsed = CreateSemaphore(0, 0, num_threads, 0);
  InitializeCriticalSection(&mMutex);
//  if (mFree == FALSE || mUsed == FALSE)
//    mOk = false;
//  else
//    mOk = true;
}

EventQueue::~EventQueue() {
  DeleteCriticalSection(&mMutex);
//  if (mUsed != FALSE)
//    CloseHandle(mUsed);
//  if (mFree != FALSE)
//    CloseHandle(mFree);
}

void EventQueue::Push(Event * event) {
//  if (!mOk)
//    return;
//  WaitForSingleObject(mFree, INFINITE);
  {
    Guard g(mMutex);
    mQue.push(event);
  }  
//  ReleaseSemaphore(mUsed, 1, 0);
}

Event* EventQueue::Pop() {
  Event * event = NULL;
//  if (!mOk)
//    return NULL;
//  WaitForSingleObject(mUsed, INFINITE);
  {
    Guard g(mMutex);
    if (!mQue.empty()) {
      event = mQue.front();
      mQue.pop();
    }
  }
//  ReleaseSemaphore(mFree, 1, 0);
  return event;
}

int EventQueue::Size() {
  Guard g(mMutex);
  return mQue.size();
}

bool EventQueue::IsOk() {
//  return mOk;
  return true;
}

---