rwlock.c

Go to the documentation of this file.

/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
/*
 * See COPYRIGHT in top-level directory.
 */

#include "abti.h"

int ABT_rwlock_create(ABT_rwlock *newrwlock)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_rwlock *p_newrwlock;

    p_newrwlock = (ABTI_rwlock *)ABTU_malloc(sizeof(ABTI_rwlock));
    if (p_newrwlock == NULL) {
        abt_errno = ABT_ERR_MEM;
    } else {
        ABTI_rwlock_init(p_newrwlock);
    }

    /* Return value */
    *newrwlock = ABTI_rwlock_get_handle(p_newrwlock);

    return abt_errno;
}

int ABT_rwlock_free(ABT_rwlock *rwlock)
{
    int abt_errno = ABT_SUCCESS;
    ABT_rwlock h_rwlock = *rwlock;
    ABTI_rwlock *p_rwlock = ABTI_rwlock_get_ptr(h_rwlock);
    ABTI_CHECK_NULL_RWLOCK_PTR(p_rwlock);

    ABTI_rwlock_fini(p_rwlock);
    ABTU_free(p_rwlock);

    /* Return value */
    *rwlock = ABT_RWLOCK_NULL;

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}

int ABT_rwlock_rdlock(ABT_rwlock rwlock)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_local *p_local = ABTI_local_get_local();
    ABTI_rwlock *p_rwlock = ABTI_rwlock_get_ptr(rwlock);
    ABTI_CHECK_NULL_RWLOCK_PTR(p_rwlock);

    ABTI_rwlock_rdlock(&p_local, p_rwlock);

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}

int ABT_rwlock_wrlock(ABT_rwlock rwlock)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_local *p_local = ABTI_local_get_local();
    ABTI_rwlock *p_rwlock = ABTI_rwlock_get_ptr(rwlock);
    ABTI_CHECK_NULL_RWLOCK_PTR(p_rwlock);

    ABTI_rwlock_wrlock(&p_local, p_rwlock);

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}

int ABT_rwlock_unlock(ABT_rwlock rwlock)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_local *p_local = ABTI_local_get_local();
    ABTI_rwlock *p_rwlock = ABTI_rwlock_get_ptr(rwlock);
    ABTI_CHECK_NULL_RWLOCK_PTR(p_rwlock);

    ABTI_rwlock_unlock(&p_local, p_rwlock);

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}