1282e98a01
This commit renames the arithmetic atomic operations in opal to indicate that they return the new value not the old value. This naming differentiates these routines from new functions that return the old value. Signed-off-by: Nathan Hjelm <hjelmn@lanl.gov>
81 строка
2.3 KiB
C
81 строка
2.3 KiB
C
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */
|
|
/*
|
|
* Copyright (c) 2011-2012 Sandia National Laboratories. All rights reserved.
|
|
* Copyright (c) 2014-2015 Los Alamos National Security, LLC. All rights
|
|
* reserved.
|
|
* Copyright (c) 2016 The University of Tennessee and The University
|
|
* of Tennessee Research Foundation. All rights
|
|
* reserved.
|
|
* $COPYRIGHT$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
|
|
#include "ompi_config.h"
|
|
|
|
#include "ompi/request/request.h"
|
|
#include "ompi/mca/osc/osc.h"
|
|
#include "ompi/mca/osc/base/base.h"
|
|
#include "ompi/mca/osc/base/osc_base_obj_convert.h"
|
|
|
|
#include "osc_rdma.h"
|
|
#include "osc_rdma_request.h"
|
|
|
|
static int request_cancel(struct ompi_request_t *request, int complete)
|
|
{
|
|
return MPI_ERR_REQUEST;
|
|
}
|
|
|
|
static int request_free(struct ompi_request_t **ompi_req)
|
|
{
|
|
ompi_osc_rdma_request_t *request =
|
|
(ompi_osc_rdma_request_t*) *ompi_req;
|
|
|
|
if( REQUEST_COMPLETE(&request->super) ) {
|
|
return MPI_ERR_REQUEST;
|
|
}
|
|
|
|
OMPI_OSC_RDMA_REQUEST_RETURN(request);
|
|
|
|
*ompi_req = MPI_REQUEST_NULL;
|
|
|
|
return OMPI_SUCCESS;
|
|
}
|
|
|
|
static int request_complete (struct ompi_request_t *request)
|
|
{
|
|
ompi_osc_rdma_request_t *parent_request = ((ompi_osc_rdma_request_t *) request)->parent_request;
|
|
|
|
if (parent_request && 0 == OPAL_THREAD_ADD_FETCH32 (&parent_request->outstanding_requests, -1)) {
|
|
ompi_osc_rdma_request_complete (parent_request, OMPI_SUCCESS);
|
|
}
|
|
|
|
return OMPI_SUCCESS;
|
|
}
|
|
|
|
static void request_construct(ompi_osc_rdma_request_t *request)
|
|
{
|
|
request->super.req_type = OMPI_REQUEST_WIN;
|
|
request->super.req_status._cancelled = 0;
|
|
request->super.req_free = request_free;
|
|
request->super.req_cancel = request_cancel;
|
|
request->super.req_complete_cb = request_complete;
|
|
request->parent_request = NULL;
|
|
request->buffer = NULL;
|
|
request->internal = false;
|
|
request->outstanding_requests = 0;
|
|
OBJ_CONSTRUCT(&request->convertor, opal_convertor_t);
|
|
}
|
|
|
|
static void request_destruct(ompi_osc_rdma_request_t *request)
|
|
{
|
|
OBJ_DESTRUCT(&request->convertor);
|
|
}
|
|
|
|
OBJ_CLASS_INSTANCE(ompi_osc_rdma_request_t,
|
|
ompi_request_t,
|
|
request_construct,
|
|
request_destruct);
|