// This code is in the public domain -- castano@gmail.com

#include "Event.h"

#if NV_OS_WIN32
#include "Win32.h"
#elif NV_OS_USE_PTHREAD
#include <pthread.h>
#endif

using namespace nv;

#if NV_OS_WIN32

struct Event::Private {
    HANDLE handle;
};

Event::Event() : m(new Private) {
    m->handle = CreateEvent(/*lpEventAttributes=*/NULL, /*bManualReset=*/FALSE, /*bInitialState=*/FALSE, /*lpName=*/NULL);
}

Event::~Event() {
    CloseHandle(m->handle);
}

void Event::post() {
    SetEvent(m->handle);
}

void Event::wait() {
    WaitForSingleObject(m->handle, INFINITE);
}

#elif NV_OS_USE_PTHREAD

struct Event::Private {
    pthread_cond_t pt_cond;
    pthread_mutex_t pt_mutex;
    int count;
    int wait_count;
};

Event::Event() : m(new Private) {
    m->count=0;
    m->wait_count=0;
    pthread_mutex_init(&m->pt_mutex, NULL);
    pthread_cond_init(&m->pt_cond, NULL);
}

Event::~Event() {
    pthread_cond_destroy(&m->pt_cond);
    pthread_mutex_destroy(&m->pt_mutex);
}

void Event::post() {
    pthread_mutex_lock(&m->pt_mutex);

    m->count++;
    
    //ACS: move this after the unlock?
    if(m->wait_count>0) {
        pthread_cond_signal(&m->pt_cond);
    }
    
    pthread_mutex_unlock(&m->pt_mutex);
}

void Event::wait() {
    pthread_mutex_lock(&m->pt_mutex);
    
    while(m->count==0) {
        m->wait_count++;
        pthread_cond_wait(&m->pt_cond, &m->pt_mutex);
        m->wait_count--;
    }
    m->count--;
    
    pthread_mutex_unlock(&m->pt_mutex);
}

#endif // NV_OS_UNIX


/*static*/ void Event::post(Event * events, uint count) {
    for (uint i = 0; i < count; i++) {
        events[i].post();
    }
}

/*static*/ void Event::wait(Event * events, uint count) {
    // @@ Use wait for multiple objects in win32?

    for (uint i = 0; i < count; i++) {
        events[i].wait();
    }
}