mercury_atomic.h

Go to the documentation of this file.

/*
 * Copyright (C) 2013 Argonne National Laboratory, Department of Energy,
 *                    UChicago Argonne, LLC and The HDF Group.
 * All rights reserved.
 *
 * The full copyright notice, including terms governing use, modification,
 * and redistribution, is contained in the COPYING file that can be
 * found at the root of the source code distribution tree.
 */

#ifndef MERCURY_ATOMIC_H
#define MERCURY_ATOMIC_H

#include "mercury_util_config.h"

#if defined(_WIN32)
  #include <windows.h>
  typedef struct { volatile LONG value; } hg_atomic_int32_t;
#elif defined(__APPLE__)
  #include <libkern/OSAtomic.h>
  typedef struct { volatile hg_util_int32_t value; } hg_atomic_int32_t;
#else
  #include <opa_primitives.h>
  typedef OPA_int_t hg_atomic_int32_t;
#endif

#ifdef __cplusplus
extern "C" {
#endif

static HG_UTIL_INLINE void
hg_atomic_set32(hg_atomic_int32_t *ptr, hg_util_int32_t value)
{
#if defined(_WIN32) || defined(__APPLE__)
    ptr->value = value;
#else
    OPA_store_int(ptr, value);
#endif
}

static HG_UTIL_INLINE hg_util_int32_t
hg_atomic_get32(hg_atomic_int32_t *ptr)
{
    hg_util_int32_t ret;

#if defined(_WIN32) || defined(__APPLE__)
    ret = ptr->value;
#else
    ret = OPA_load_int(ptr);
#endif

    return ret;
}

static HG_UTIL_INLINE hg_util_int32_t
hg_atomic_incr32(hg_atomic_int32_t *ptr)
{
    hg_util_int32_t ret;

#if defined(_WIN32)
    ret = InterlockedIncrement(&ptr->value);
#elif defined(__APPLE__)
    ret = OSAtomicIncrement32(&ptr->value);
#else
    ret = OPA_fetch_and_incr_int(ptr) + 1;
#endif

    return ret;
}

static HG_UTIL_INLINE hg_util_int32_t
hg_atomic_decr32(hg_atomic_int32_t *ptr)
{
    hg_util_int32_t ret;

#if defined(_WIN32)
    ret = InterlockedDecrement(&ptr->value);
#elif defined(__APPLE__)
    ret = OSAtomicDecrement32(&ptr->value);
#else
    ret = OPA_fetch_and_decr_int(ptr) - 1;
#endif

    return ret;
}

static HG_UTIL_INLINE hg_util_bool_t
hg_atomic_cas32(hg_atomic_int32_t *ptr, hg_util_int32_t compare_value,
        hg_util_int32_t swap_value)
{
    hg_util_bool_t ret;

#if defined(_WIN32)
    ret = (compare_value == InterlockedCompareExchange(&ptr->value, swap_value,
            compare_value));
#elif defined(__APPLE__)
    ret = OSAtomicCompareAndSwap32(compare_value, swap_value, &ptr->value);
#else
    ret = (hg_util_bool_t) (compare_value == OPA_cas_int(ptr, compare_value, swap_value));
#endif

    return ret;
}

#ifdef __cplusplus
}
#endif

#endif /* MERCURY_ATOMIC_H */