mutex_attr.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_mutex_attr_create(ABT_mutex_attr *newattr)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_mutex_attr *p_newattr;

    p_newattr = (ABTI_mutex_attr *)ABTU_malloc(sizeof(ABTI_mutex_attr));

    /* Default values */
    p_newattr->attrs = ABTI_MUTEX_ATTR_NONE;
    p_newattr->nesting_cnt = 0;
    p_newattr->owner_id = 0;
    p_newattr->max_handovers = ABTI_global_get_mutex_max_handovers();
    p_newattr->max_wakeups = ABTI_global_get_mutex_max_wakeups();

    /* Return value */
    *newattr = ABTI_mutex_attr_get_handle(p_newattr);

    return abt_errno;
}

int ABT_mutex_attr_free(ABT_mutex_attr *attr)
{
    int abt_errno = ABT_SUCCESS;
    ABT_mutex_attr h_attr = *attr;
    ABTI_mutex_attr *p_attr = ABTI_mutex_attr_get_ptr(h_attr);
    ABTI_CHECK_NULL_MUTEX_ATTR_PTR(p_attr);

    /* Free the memory */
    ABTU_free(p_attr);

    /* Return value */
    *attr = ABT_MUTEX_ATTR_NULL;

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}

int ABT_mutex_attr_set_recursive(ABT_mutex_attr attr, ABT_bool recursive)
{
    int abt_errno = ABT_SUCCESS;
    ABTI_mutex_attr *p_attr = ABTI_mutex_attr_get_ptr(attr);
    ABTI_CHECK_NULL_MUTEX_ATTR_PTR(p_attr);

    /* Set the value */
    if (recursive == ABT_TRUE) {
        p_attr->attrs |= ABTI_MUTEX_ATTR_RECURSIVE;
    } else {
        p_attr->attrs &= ~ABTI_MUTEX_ATTR_RECURSIVE;
    }

fn_exit:
    return abt_errno;

fn_fail:
    HANDLE_ERROR_FUNC_WITH_CODE(abt_errno);
    goto fn_exit;
}

/*****************************************************************************/
/* Private APIs                                                              */
/*****************************************************************************/

void ABTI_mutex_attr_print(ABTI_mutex_attr *p_attr, FILE *p_os, int indent)
{
    char *prefix = ABTU_get_indent_str(indent);
    char attr[100];

    ABTI_mutex_attr_get_str(p_attr, attr);
    fprintf(p_os, "%smutex attr: %s\n", prefix, attr);
    fflush(p_os);
    ABTU_free(prefix);
}

void ABTI_mutex_attr_get_str(ABTI_mutex_attr *p_attr, char *p_buf)
{
    if (p_attr == NULL) {
        sprintf(p_buf, "[NULL ATTR]");
        return;
    }

    sprintf(p_buf,
            "["
            "attrs:%x "
            "nesting_cnt:%u "
            "owner_id:%p "
            "]",
            p_attr->attrs, p_attr->nesting_cnt, (void *)p_attr->owner_id);
}