#include <stdio.h>
#include <time.h>
#include "support.h"
#include "include/constants.h"
#include "threads/thread.h"
#include "threads/condition.h"
#include "os/atomic.h"


ompi_mutex_t mutex;
ompi_condition_t thr1_cond;
ompi_condition_t thr2_cond;

int thr1_count = 0;
int thr2_count = 0;


#define TEST_COUNT 1000000


static void* thr1_run(ompi_object_t* obj)
{
    int i;
    clock_t c1, c2;
    ompi_mutex_lock(&mutex);
    c1 = clock();
    for(i=0; i<TEST_COUNT; i++) {
        ompi_condition_wait(&thr1_cond, &mutex); 
        ompi_condition_signal(&thr2_cond);
        thr1_count++;
    }
    c2 = clock();
    ompi_mutex_unlock(&mutex);
    fprintf(stderr, "thr1: time per iteration: %ld usec\n", (c2 - c1) / TEST_COUNT);
    return NULL;
}

static void* thr2_run(ompi_object_t* obj)
{
    int i;
    clock_t c1, c2;
    ompi_mutex_lock(&mutex);
    c1 = clock();
    for(i=0; i<TEST_COUNT; i++) {
        ompi_condition_signal(&thr1_cond);
        ompi_condition_wait(&thr2_cond, &mutex);
        thr2_count++;
    }
    c2 = clock();
    ompi_mutex_unlock(&mutex);
    fprintf(stderr, "thr2: time per iteration: %ld usec\n", (c2 - c1) / TEST_COUNT);
    return NULL;
}


int main(int argc, char** argv)
{
    int rc;
    ompi_thread_t* thr1;
    ompi_thread_t* thr2;

    test_init("ompi_condition_t");

    OBJ_CONSTRUCT(&mutex, ompi_mutex_t);
    OBJ_CONSTRUCT(&thr1_cond, ompi_condition_t);
    OBJ_CONSTRUCT(&thr2_cond, ompi_condition_t);
  
    thr1 = OBJ_NEW(ompi_thread_t);
    thr2 = OBJ_NEW(ompi_thread_t);
    thr1->t_run = thr1_run;
    thr2->t_run = thr2_run;

    rc = ompi_thread_start(thr1);
    test_verify_int(OMPI_SUCCESS, rc);

    rc = ompi_thread_start(thr2);
    test_verify_int(OMPI_SUCCESS, rc);
   
    rc = ompi_thread_join(thr1, NULL);
    test_verify_int(OMPI_SUCCESS, rc);
    test_verify_int(TEST_COUNT, thr1_count);

    rc = ompi_thread_join(thr2, NULL);
    test_verify_int(OMPI_SUCCESS, rc);
    test_verify_int(TEST_COUNT, thr2_count);

    test_finalize();
    return 0;
}