/* -*- 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 */