/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
/*
 *
 *  (C) 2001 by Argonne National Laboratory.
 *      See COPYRIGHT in top-level directory.
 */

#ifndef MPIU_THREAD_WIN_H_INCLUDED
#define MPIU_THREAD_WIN_H_INCLUDED

#define WIN32_LEAN_AND_MEAN

#include <windows.h>

typedef HANDLE MPIU_Thread_mutex_t;
typedef HANDLE MPIU_Thread_id_t;
typedef DWORD MPIU_Thread_tls_t;

typedef struct MPIUI_Win_thread_cond_fifo_t {
    HANDLE event;
    struct MPIUI_Win_thread_cond_fifo_t *next;
} MPIUI_Win_thread_cond_fifo_t;
typedef struct MPIU_Thread_cond_t {
    MPIU_Thread_tls_t tls;
    MPIU_Thread_mutex_t fifo_mutex;
    MPIUI_Win_thread_cond_fifo_t *fifo_head, *fifo_tail;
} MPIU_Thread_cond_t;

typedef void (*MPIU_Thread_func_t) (void *data);

void MPIU_Thread_create(MPIU_Thread_func_t func, void *data, MPIU_Thread_id_t * id, int *err);
void MPIU_Thread_exit(void);
void MPIU_Thread_self(MPIU_Thread_id_t * id);
void MPIU_Thread_same(MPIU_Thread_id_t * id1, MPIU_Thread_id_t * id2, int *same);
void MPIU_Thread_yield(void);

void MPIU_Thread_mutex_create(MPIU_Thread_mutex_t * mutex, int *err);
void MPIU_Thread_mutex_destroy(MPIU_Thread_mutex_t * mutex, int *err);
void MPIU_Thread_mutex_lock(MPIU_Thread_mutex_t * mutex, int *err);
void MPIU_Thread_mutex_unlock(MPIU_Thread_mutex_t * mutex, int *err);

void MPIU_Thread_cond_create(MPIU_Thread_cond_t * cond, int *err);
void MPIU_Thread_cond_destroy(MPIU_Thread_cond_t * cond, int *err);
void MPIU_Thread_cond_wait(MPIU_Thread_cond_t * cond, MPIU_Thread_mutex_t * mutex, int *err);
void MPIU_Thread_cond_broadcast(MPIU_Thread_cond_t * cond, int *err);
void MPIU_Thread_cond_signal(MPIU_Thread_cond_t * cond, int *err);

/*
 * Thread Local Storage
 */

#define MPIU_Thread_tls_create(exit_func_ptr_, tls_ptr_, err_ptr_)	\
    do {                                                                \
        *(tls_ptr_) = TlsAlloc();                                       \
        if ((err_ptr_) != NULL) {                                       \
            if (*(tls_ptr_) == TLS_OUT_OF_INDEXES) {                    \
                *(int *)(err_ptr_) = GetLastError();			\
            }								\
            else {                                                      \
                *(int *)(err_ptr_) = MPIU_THREAD_SUCCESS;               \
            }                                                           \
        }                                                               \
    } while (0)

#define MPIU_Thread_tls_destroy(tls_ptr_, err_ptr_)		\
    do {                                                        \
        BOOL result__;                                          \
        result__ = TlsFree(*(tls_ptr_));                        \
        if ((err_ptr_) != NULL) {                               \
            if (result__) {                                     \
                *(int *)(err_ptr_) = MPIU_THREAD_SUCCESS;       \
            }                                                   \
            else {                                              \
                *(int *)(err_ptr_) = GetLastError();		\
            }							\
        }                                                       \
    } while (0)

#define MPIU_Thread_tls_set(tls_ptr_, value_, err_ptr_)		\
    do {                                                        \
        BOOL result__;                                          \
        result__ = TlsSetValue(*(tls_ptr_), (value_));		\
        if ((err_ptr_) != NULL) {                               \
            if (result__) {                                     \
                *(int *)(err_ptr_) = MPIU_THREAD_SUCCESS;       \
            }                                                   \
            else {                                              \
                *(int *)(err_ptr_) = GetLastError();		\
            }							\
        }                                                       \
    } while (0)

#define MPIU_Thread_tls_get(tls_ptr_, value_ptr_, err_ptr_)             \
    do {								\
        *((void **)value_ptr_) = TlsGetValue(*(tls_ptr_));              \
        if ((err_ptr_) != NULL) {                                       \
            if (*(value_ptr_) == 0 && GetLastError() != NO_ERROR) {     \
                *(int *)(err_ptr_) = GetLastError();                    \
            }                                                           \
            else {                                                      \
                *(int *)(err_ptr_) = MPIU_THREAD_SUCCESS;               \
            }                                                           \
        }                                                               \
    } while (0)

#endif /* MPIU_THREAD_WIN_H_INCLUDED */