Commit 0ef0149e authored by James Dinan's avatar James Dinan
Browse files

[svn-r10519] Renamed MPIDI_RMA_ops to MPIDI_RMA_Op_t

Reviewer: goodell
parent 0c5783e3
......@@ -210,7 +210,7 @@ struct MPIDI_Win_info_args_s {
};
struct MPIDI_Win_target_state_s {
struct MPIDI_RMA_ops *rma_ops_list; \
struct MPIDI_RMA_Op_s *rma_ops_list; \
/* list of outstanding RMA operations */ \
volatile enum MPIDI_CH3_Lock_states_e remote_lock_state; \
/* Indicates the state of the target \
......
......@@ -54,9 +54,9 @@ typedef struct MPIDI_RMA_dtype_info { /* for derived datatypes */
} MPIDI_RMA_dtype_info;
/* for keeping track of RMA ops, which will be executed at the next sync call */
typedef struct MPIDI_RMA_ops {
struct MPIDI_RMA_ops *prev; /* pointer to next element in list */
struct MPIDI_RMA_ops *next; /* pointer to next element in list */
typedef struct MPIDI_RMA_Op_s {
struct MPIDI_RMA_Op_s *prev; /* pointer to next element in list */
struct MPIDI_RMA_Op_s *next; /* pointer to next element in list */
/* FIXME: It would be better to setup the packet that will be sent, at
least in most cases (if, as a result of the sync/ops/sync sequence,
a different packet type is needed, it can be extracted from the
......@@ -81,7 +81,7 @@ typedef struct MPIDI_RMA_ops {
void *compare_addr;
int compare_count;
MPI_Datatype compare_datatype;
} MPIDI_RMA_ops;
} MPIDI_RMA_Op_t;
typedef struct MPIDI_PT_single_op {
int type; /* put, get, or accum. */
......@@ -108,7 +108,7 @@ void MPIDI_CH3_RMA_SetAccImmed( int flag );
/*** RMA OPS LIST HELPER ROUTINES ***/
typedef MPIDI_RMA_ops * MPIDI_RMA_Ops_list_t;
typedef MPIDI_RMA_Op_t * MPIDI_RMA_Ops_list_t;
/* Return nonzero if the RMA operations list is empty.
*/
......@@ -128,7 +128,7 @@ static inline int MPIDI_CH3I_RMA_Ops_isempty(MPIDI_RMA_Ops_list_t *list)
#define FUNCNAME MPIDI_CH3I_RMA_Ops_head
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline MPIDI_RMA_ops *MPIDI_CH3I_RMA_Ops_head(MPIDI_RMA_Ops_list_t *list)
static inline MPIDI_RMA_Op_t *MPIDI_CH3I_RMA_Ops_head(MPIDI_RMA_Ops_list_t *list)
{
return *list;
}
......@@ -140,7 +140,7 @@ static inline MPIDI_RMA_ops *MPIDI_CH3I_RMA_Ops_head(MPIDI_RMA_Ops_list_t *list)
#define FUNCNAME MPIDI_CH3I_RMA_Ops_tail
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline MPIDI_RMA_ops *MPIDI_CH3I_RMA_Ops_tail(MPIDI_RMA_Ops_list_t *list)
static inline MPIDI_RMA_Op_t *MPIDI_CH3I_RMA_Ops_tail(MPIDI_RMA_Ops_list_t *list)
{
return (*list) ? (*list)->prev : NULL;
}
......@@ -156,7 +156,7 @@ static inline MPIDI_RMA_ops *MPIDI_CH3I_RMA_Ops_tail(MPIDI_RMA_Ops_list_t *list)
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline void MPIDI_CH3I_RMA_Ops_append(MPIDI_RMA_Ops_list_t *list,
MPIDI_RMA_ops *elem)
MPIDI_RMA_Op_t *elem)
{
MPL_DL_APPEND(*list, elem);
}
......@@ -173,14 +173,14 @@ static inline void MPIDI_CH3I_RMA_Ops_append(MPIDI_RMA_Ops_list_t *list,
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline int MPIDI_CH3I_RMA_Ops_alloc_tail(MPIDI_RMA_Ops_list_t *list,
MPIDI_RMA_ops **new_elem)
MPIDI_RMA_Op_t **new_elem)
{
int mpi_errno = MPI_SUCCESS;
MPIDI_RMA_ops *tmp_ptr;
MPIDI_RMA_Op_t *tmp_ptr;
MPIU_CHKPMEM_DECL(1);
/* FIXME: We should use a pool allocator here */
MPIU_CHKPMEM_MALLOC(tmp_ptr, MPIDI_RMA_ops *, sizeof(MPIDI_RMA_ops),
MPIU_CHKPMEM_MALLOC(tmp_ptr, MPIDI_RMA_Op_t *, sizeof(MPIDI_RMA_Op_t),
mpi_errno, "RMA operation entry");
tmp_ptr->next = NULL;
......@@ -210,7 +210,7 @@ static inline int MPIDI_CH3I_RMA_Ops_alloc_tail(MPIDI_RMA_Ops_list_t *list,
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline void MPIDI_CH3I_RMA_Ops_unlink(MPIDI_RMA_Ops_list_t *list,
MPIDI_RMA_ops *elem)
MPIDI_RMA_Op_t *elem)
{
MPL_DL_DELETE(*list, elem);
}
......@@ -226,9 +226,9 @@ static inline void MPIDI_CH3I_RMA_Ops_unlink(MPIDI_RMA_Ops_list_t *list,
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline void MPIDI_CH3I_RMA_Ops_free_elem(MPIDI_RMA_Ops_list_t *list,
MPIDI_RMA_ops *curr_ptr)
MPIDI_RMA_Op_t *curr_ptr)
{
MPIDI_RMA_ops *tmp_ptr = curr_ptr;
MPIDI_RMA_Op_t *tmp_ptr = curr_ptr;
MPIU_Assert(curr_ptr != NULL);
......@@ -253,9 +253,9 @@ static inline void MPIDI_CH3I_RMA_Ops_free_elem(MPIDI_RMA_Ops_list_t *list,
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline void MPIDI_CH3I_RMA_Ops_free_and_next(MPIDI_RMA_Ops_list_t *list,
MPIDI_RMA_ops **curr_ptr)
MPIDI_RMA_Op_t **curr_ptr)
{
MPIDI_RMA_ops *next_ptr = (*curr_ptr)->next;
MPIDI_RMA_Op_t *next_ptr = (*curr_ptr)->next;
MPIDI_CH3I_RMA_Ops_free_elem(list, *curr_ptr);
*curr_ptr = next_ptr;
......@@ -270,7 +270,7 @@ static inline void MPIDI_CH3I_RMA_Ops_free_and_next(MPIDI_RMA_Ops_list_t *list,
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static inline void MPIDI_CH3I_RMA_Ops_free(MPIDI_RMA_Ops_list_t *list)
{
MPIDI_RMA_ops *curr_ptr, *tmp_ptr;
MPIDI_RMA_Op_t *curr_ptr, *tmp_ptr;
MPL_DL_FOREACH_SAFE(*list, curr_ptr, tmp_ptr) {
MPIDI_CH3I_RMA_Ops_free_elem(list, curr_ptr);
......@@ -287,7 +287,7 @@ static inline void MPIDI_CH3I_RMA_Ops_free(MPIDI_RMA_Ops_list_t *list)
static inline MPIDI_RMA_Ops_list_t MPIDI_CH3I_RMA_Ops_concat_all(MPID_Win *win_ptr)
{
int i;
MPIDI_RMA_ops *root = NULL;
MPIDI_RMA_Op_t *root = NULL;
for (i = 0; i < MPIR_Comm_size(win_ptr->comm_ptr); i++) {
/* Attach this list to the end of the aggregate list */
......
......@@ -152,7 +152,7 @@ int MPIDI_Get_accumulate(const void *origin_addr, int origin_count,
}
}
else {
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* Append the operation to the window's RMA ops queue */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -164,7 +164,7 @@ int MPIDI_Get_accumulate(const void *origin_addr, int origin_count,
MPIU_INSTR_DURATION_START(rmaqueue_set);
new_ptr->type = MPIDI_RMA_GET_ACCUMULATE;
/* Cast away const'ness for origin_address as MPIDI_RMA_ops
/* Cast away const'ness for origin_address as MPIDI_RMA_Op_t
* contain both PUT and GET like ops */
new_ptr->origin_addr = (void *) origin_addr;
new_ptr->origin_count = origin_count;
......@@ -245,7 +245,7 @@ int MPIDI_Compare_and_swap(const void *origin_addr, const void *compare_addr,
goto fn_exit;
}
else {
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* Append this operation to the RMA ops queue */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -320,7 +320,7 @@ int MPIDI_Fetch_and_op(const void *origin_addr, void *result_addr,
goto fn_exit;
}
else {
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* Append this operation to the RMA ops queue */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......
......@@ -33,8 +33,8 @@ extern void MPIDI_CH3_RMA_InitInstr(void);
* thread/process; free in Finalize handler. Option to use for
* single-threaded to avoid thread overheads)
* Possible interface
* int MPIDI_RMAListAlloc(MPIDI_RMA_ops **a,MPID_Win *win)
* int MPIDI_RMAListFree(MPIDI_RMA_ops *a, MPID_Win *win)
* int MPIDI_RMAListAlloc(MPIDI_RMA_Op_t **a,MPID_Win *win)
* int MPIDI_RMAListFree(MPIDI_RMA_Op_t *a, MPID_Win *win)
* return value is error code (e.g., allocation failure).
*/
......@@ -149,7 +149,7 @@ int MPIDI_Put(const void *origin_addr, int origin_count, MPI_Datatype
}
else
{
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* queue it up */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -161,7 +161,7 @@ int MPIDI_Put(const void *origin_addr, int origin_count, MPI_Datatype
/* FIXME: For contig and very short operations, use a streamlined op */
new_ptr->type = MPIDI_RMA_PUT;
/* Cast away const'ness for the origin address, as the
* MPIDI_RMA_ops structure is used for both PUT and GET like
* MPIDI_RMA_Op_t structure is used for both PUT and GET like
* operations */
new_ptr->origin_addr = (void *) origin_addr;
new_ptr->origin_count = origin_count;
......@@ -239,7 +239,7 @@ int MPIDI_Get(void *origin_addr, int origin_count, MPI_Datatype
}
else
{
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* queue it up */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -425,7 +425,7 @@ int MPIDI_Accumulate(const void *origin_addr, int origin_count, MPI_Datatype
}
else
{
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* queue it up */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -439,7 +439,7 @@ int MPIDI_Accumulate(const void *origin_addr, int origin_count, MPI_Datatype
new_ptr->type = MPIDI_RMA_ACC_CONTIG;
/* Only the information needed for the contig/predefined acc */
/* Cast away const'ness for origin_address as
* MPIDI_RMA_ops contain both PUT and GET like ops */
* MPIDI_RMA_Op_t contain both PUT and GET like ops */
new_ptr->origin_addr = (void *) origin_addr;
new_ptr->origin_count = origin_count;
new_ptr->origin_datatype = origin_datatype;
......@@ -454,7 +454,7 @@ int MPIDI_Accumulate(const void *origin_addr, int origin_count, MPI_Datatype
MPIU_INSTR_DURATION_START(rmaqueue_set);
new_ptr->type = MPIDI_RMA_ACCUMULATE;
/* Cast away const'ness for origin_address as MPIDI_RMA_ops
/* Cast away const'ness for origin_address as MPIDI_RMA_Op_t
* contain both PUT and GET like ops */
new_ptr->origin_addr = (void *) origin_addr;
new_ptr->origin_count = origin_count;
......
......@@ -100,19 +100,19 @@ static int MPIDI_CH3I_Send_lock_msg(int dest, int lock_type, MPID_Win *win_ptr);
static int MPIDI_CH3I_Send_unlock_msg(int dest, MPID_Win *win_ptr);
static int MPIDI_CH3I_Send_flush_msg(int dest, MPID_Win *win_ptr);
static int MPIDI_CH3I_Wait_for_lock_granted(MPID_Win *win_ptr, int target_rank);
static int MPIDI_CH3I_Send_rma_msg(MPIDI_RMA_ops * rma_op, MPID_Win * win_ptr,
static int MPIDI_CH3I_Send_rma_msg(MPIDI_RMA_Op_t * rma_op, MPID_Win * win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
MPIDI_RMA_dtype_info * dtype_info,
void ** dataloop, MPID_Request ** request);
static int MPIDI_CH3I_Recv_rma_msg(MPIDI_RMA_ops * rma_op, MPID_Win * win_ptr,
static int MPIDI_CH3I_Recv_rma_msg(MPIDI_RMA_Op_t * rma_op, MPID_Win * win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
MPIDI_RMA_dtype_info * dtype_info,
void ** dataloop, MPID_Request ** request);
static int MPIDI_CH3I_Send_contig_acc_msg(MPIDI_RMA_ops *, MPID_Win *,
static int MPIDI_CH3I_Send_contig_acc_msg(MPIDI_RMA_Op_t *, MPID_Win *,
MPI_Win, MPI_Win, MPID_Request ** );
static int MPIDI_CH3I_Send_immed_rmw_msg(MPIDI_RMA_ops *, MPID_Win *,
static int MPIDI_CH3I_Send_immed_rmw_msg(MPIDI_RMA_Op_t *, MPID_Win *,
MPI_Win, MPI_Win, MPID_Request ** );
static int MPIDI_CH3I_Do_passive_target_rma(MPID_Win *win_ptr, int target_rank,
int *wait_for_rma_done_pkt,
......@@ -121,7 +121,7 @@ static int MPIDI_CH3I_Send_lock_put_or_acc(MPID_Win *, int);
static int MPIDI_CH3I_Send_lock_get(MPID_Win *, int);
static int MPIDI_CH3I_RMAListComplete(MPID_Win *, MPIDI_RMA_Ops_list_t *);
static int MPIDI_CH3I_RMAListPartialComplete( MPID_Win *, MPIDI_RMA_Ops_list_t *,
MPIDI_RMA_ops *, int * );
MPIDI_RMA_Op_t *, int * );
static int create_datatype(const MPIDI_RMA_dtype_info *dtype_info,
const void *dataloop, MPI_Aint dataloop_sz,
......@@ -138,7 +138,7 @@ int MPIDI_Win_fence(int assert, MPID_Win *win_ptr)
int mpi_errno = MPI_SUCCESS;
int comm_size;
int *rma_target_proc, *nops_to_proc, i, total_op_count, *curr_ops_cnt;
MPIDI_RMA_ops *curr_ptr;
MPIDI_RMA_Op_t *curr_ptr;
MPIDI_RMA_Ops_list_t ops_list;
MPID_Comm *comm_ptr;
MPI_Win source_win_handle, target_win_handle;
......@@ -485,7 +485,7 @@ static int create_datatype(const MPIDI_RMA_dtype_info *dtype_info,
#define FUNCNAME MPIDI_CH3I_Send_rma_msg
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static int MPIDI_CH3I_Send_rma_msg(MPIDI_RMA_ops *rma_op, MPID_Win *win_ptr,
static int MPIDI_CH3I_Send_rma_msg(MPIDI_RMA_Op_t *rma_op, MPID_Win *win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
MPIDI_RMA_dtype_info *dtype_info,
......@@ -798,7 +798,7 @@ static int MPIDI_CH3I_Send_rma_msg(MPIDI_RMA_ops *rma_op, MPID_Win *win_ptr,
#define FUNCNAME MPIDI_CH3I_Send_contig_acc_msg
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static int MPIDI_CH3I_Send_contig_acc_msg(MPIDI_RMA_ops *rma_op,
static int MPIDI_CH3I_Send_contig_acc_msg(MPIDI_RMA_Op_t *rma_op,
MPID_Win *win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
......@@ -910,7 +910,7 @@ static int MPIDI_CH3I_Send_contig_acc_msg(MPIDI_RMA_ops *rma_op,
#define FUNCNAME MPIDI_CH3I_Send_immed_rmw_msg
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static int MPIDI_CH3I_Send_immed_rmw_msg(MPIDI_RMA_ops *rma_op,
static int MPIDI_CH3I_Send_immed_rmw_msg(MPIDI_RMA_Op_t *rma_op,
MPID_Win *win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
......@@ -1067,7 +1067,7 @@ fn_fail:
#define FUNCNAME MPIDI_CH3I_Recv_rma_msg
#undef FCNAME
#define FCNAME MPIDI_QUOTE(FUNCNAME)
static int MPIDI_CH3I_Recv_rma_msg(MPIDI_RMA_ops *rma_op, MPID_Win *win_ptr,
static int MPIDI_CH3I_Recv_rma_msg(MPIDI_RMA_Op_t *rma_op, MPID_Win *win_ptr,
MPI_Win source_win_handle,
MPI_Win target_win_handle,
MPIDI_RMA_dtype_info *dtype_info,
......@@ -1422,7 +1422,7 @@ int MPIDI_Win_complete(MPID_Win *win_ptr)
int mpi_errno = MPI_SUCCESS;
int comm_size, *nops_to_proc, src, new_total_op_count;
int i, j, dst, total_op_count, *curr_ops_cnt;
MPIDI_RMA_ops *curr_ptr;
MPIDI_RMA_Op_t *curr_ptr;
MPIDI_RMA_Ops_list_t ops_list;
MPID_Comm *comm_ptr;
MPI_Win source_win_handle, target_win_handle;
......@@ -1660,7 +1660,7 @@ int MPIDI_Win_complete(MPID_Win *win_ptr)
/* In the unlikely event that a request is returned (the message
is not sent yet), add it to the list of pending operations */
if (request) {
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
mpi_errno = MPIDI_CH3I_RMA_Ops_alloc_tail(&ops_list, &new_ptr);
......@@ -1829,7 +1829,7 @@ int MPIDI_Win_lock(int lock_type, int dest, int assert, MPID_Win *win_ptr)
MPIU_ERR_CHKANDJUMP(mpi_errno != MPI_SUCCESS, mpi_errno, MPI_ERR_OTHER, "**winRMAmessage");
}
else {
MPIDI_RMA_ops *new_ptr = NULL;
MPIDI_RMA_Op_t *new_ptr = NULL;
/* target is some other process. add the lock request to rma_ops_list */
MPIU_INSTR_DURATION_START(rmaqueue_alloc);
......@@ -1862,7 +1862,7 @@ int MPIDI_Win_unlock(int dest, MPID_Win *win_ptr)
{
int mpi_errno=MPI_SUCCESS;
int single_op_opt, type_size;
MPIDI_RMA_ops *rma_op, *curr_op;
MPIDI_RMA_Op_t *rma_op, *curr_op;
MPID_Comm *comm_ptr;
MPIDI_VC_t * vc;
int wait_for_rma_done_pkt = 0, predefined;
......@@ -2263,7 +2263,7 @@ static int MPIDI_CH3I_Do_passive_target_rma(MPID_Win *win_ptr, int target_rank,
int *wait_for_rma_done_pkt, int unlock_target)
{
int mpi_errno = MPI_SUCCESS, nops;
MPIDI_RMA_ops *curr_ptr;
MPIDI_RMA_Op_t *curr_ptr;
MPI_Win source_win_handle, target_win_handle = MPI_WIN_NULL;
int nRequest=0, nRequestNew=0;
MPIDI_STATE_DECL(MPID_STATE_MPIDI_CH3I_DO_PASSIVE_TARGET_RMA);
......@@ -2301,7 +2301,7 @@ static int MPIDI_CH3I_Do_passive_target_rma(MPID_Win *win_ptr, int target_rank,
*wait_for_rma_done_pkt = 0;
}
else {
MPIDI_RMA_ops *head = MPIDI_CH3I_RMA_Ops_head(&win_ptr->targets[target_rank].rma_ops_list);
MPIDI_RMA_Op_t *head = MPIDI_CH3I_RMA_Ops_head(&win_ptr->targets[target_rank].rma_ops_list);
/* go through the list and move the first get operation
(if there is one) to the end. Note that the first
......@@ -2636,7 +2636,7 @@ static int MPIDI_CH3I_Send_flush_msg(int dest, MPID_Win *win_ptr) {
static int MPIDI_CH3I_Send_lock_put_or_acc(MPID_Win *win_ptr, int target_rank)
{
int mpi_errno=MPI_SUCCESS, lock_type, origin_dt_derived, iovcnt;
MPIDI_RMA_ops *rma_op;
MPIDI_RMA_Op_t *rma_op;
MPID_Request *request=NULL;
MPIDI_VC_t * vc;
MPID_IOV iov[MPID_IOV_LIMIT];
......@@ -2820,7 +2820,7 @@ static int MPIDI_CH3I_Send_lock_put_or_acc(MPID_Win *win_ptr, int target_rank)
MPID_Request_release(request);
}
/* Free MPIDI_RMA_ops_list - the lock packet should still be in place, so
/* Free MPIDI_RMA_Ops_list - the lock packet should still be in place, so
* we have to free two elements. */
MPIDI_CH3I_RMA_Ops_free(&win_ptr->targets[target_rank].rma_ops_list);
......@@ -2837,7 +2837,7 @@ static int MPIDI_CH3I_Send_lock_put_or_acc(MPID_Win *win_ptr, int target_rank)
static int MPIDI_CH3I_Send_lock_get(MPID_Win *win_ptr, int target_rank)
{
int mpi_errno=MPI_SUCCESS, lock_type, predefined;
MPIDI_RMA_ops *rma_op;
MPIDI_RMA_Op_t *rma_op;
MPID_Request *rreq=NULL, *sreq=NULL;
MPIDI_VC_t * vc;
MPID_Comm *comm_ptr;
......@@ -2939,7 +2939,7 @@ static int MPIDI_CH3I_Send_lock_get(MPID_Win *win_ptr, int target_rank)
rreq gets freed. */
MPID_Request_release(rreq);
/* Free MPIDI_RMA_ops_list - the lock packet should still be in place, so
/* Free MPIDI_RMA_Ops_list - the lock packet should still be in place, so
* we have to free two elements. */
MPIDI_CH3I_RMA_Ops_free(&win_ptr->targets[target_rank].rma_ops_list);
......@@ -4578,7 +4578,7 @@ static int MPIDI_CH3I_RMAListComplete( MPID_Win *win_ptr,
MPIDI_RMA_Ops_list_t *ops_list )
{
int ntimes = 0, mpi_errno=0;
MPIDI_RMA_ops *curr_ptr;
MPIDI_RMA_Op_t *curr_ptr;
MPID_Progress_state progress_state;
MPIU_INSTR_DURATION_START_VAR(list_complete);
......@@ -4657,11 +4657,11 @@ static int MPIDI_CH3I_RMAListComplete( MPID_Win *win_ptr,
*/
static int MPIDI_CH3I_RMAListPartialComplete( MPID_Win *win_ptr,
MPIDI_RMA_Ops_list_t *ops_list,
MPIDI_RMA_ops *last_elm,
MPIDI_RMA_Op_t *last_elm,
int *nDone )
{
int mpi_errno=0;
MPIDI_RMA_ops *curr_ptr;
MPIDI_RMA_Op_t *curr_ptr;
MPID_Progress_state progress_state;
int nComplete = 0;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment