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

/* FIXME remove MPI error code references in a meaningful way */

#include "opa_queue.h"

char *OPA_Shm_asymm_base_addr = (char *)(OPA_SHM_ASYMM_NULL_VAL);

int OPA_Shm_asymm_init(char *base)
{
    int mpi_errno = 0/*MPI_SUCCESS*/;

    if (OPA_Shm_asymm_base_addr != (char *)OPA_SHM_ASYMM_NULL_VAL) {
        /* the _base_addr has already been initialized */
        mpi_errno = 16/*MPI_ERR_INTERN*/;
        goto fn_exit;
    }

    OPA_Shm_asymm_base_addr = base;

fn_exit:
    return mpi_errno;
}

void OPA_Queue_init(OPA_Queue_info_t *qhead)
{
    OPA_SHM_SET_REL_NULL((qhead)->head);
    OPA_SHM_SET_REL_NULL((qhead)->tail);
    OPA_SHM_SET_REL_NULL((qhead)->shadow_head);
}

void OPA_Queue_header_init(OPA_Queue_element_hdr_t *hdr)
{
    OPA_SHM_SET_REL_NULL(hdr->next);
}