Commit 68984ea9 authored by Xin Zhao's avatar Xin Zhao
Browse files

Change function name: set_lock_sync_counter -> handle_lock_ack

No reviewer.
parent c07eeba4
......@@ -2160,7 +2160,7 @@ int MPID_nem_ib_PktHandler_GetResp(MPIDI_VC_t * vc,
/* decrement ack_counter on target */
if (get_resp_pkt->flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED) {
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
get_resp_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
}
......
......@@ -498,7 +498,7 @@ static inline int enqueue_lock_origin(MPID_Win *win_ptr, MPIDI_VC_t *vc,
}
static inline int set_lock_sync_counter(MPID_Win *win_ptr, int target_rank,
static inline int handle_lock_ack(MPID_Win *win_ptr, int target_rank,
MPIDI_CH3_Pkt_flags_t flags)
{
MPIDI_RMA_Target_t *t = NULL;
......@@ -654,7 +654,7 @@ static inline int acquire_local_lock(MPID_Win * win_ptr, int lock_type)
MPIR_T_PVAR_TIMER_START(RMA, rma_winlock_getlocallock);
if (MPIDI_CH3I_Try_acquire_win_lock(win_ptr, lock_type) == 1) {
mpi_errno = set_lock_sync_counter(win_ptr, win_ptr->comm_ptr->rank,
mpi_errno = handle_lock_ack(win_ptr, win_ptr->comm_ptr->rank,
MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
}
......@@ -670,7 +670,7 @@ static inline int acquire_local_lock(MPID_Win * win_ptr, int lock_type)
new_ptr = MPIDI_CH3I_Win_lock_entry_alloc(win_ptr, &pkt);
if (new_ptr == NULL) {
mpi_errno = set_lock_sync_counter(win_ptr, win_ptr->comm_ptr->rank,
mpi_errno = handle_lock_ack(win_ptr, win_ptr->comm_ptr->rank,
MPIDI_CH3_PKT_FLAG_RMA_LOCK_DISCARDED);
if (mpi_errno != MPI_SUCCESS) MPIU_ERR_POP(mpi_errno);
goto fn_exit;
......
......@@ -1292,7 +1292,7 @@ static inline int perform_op_in_lock_queue(MPID_Win *win_ptr, MPIDI_RMA_Lock_ent
MPIDI_CH3_Pkt_lock_t *lock_pkt = &(lock_entry->pkt.lock);
if (lock_pkt->origin_rank == win_ptr->comm_ptr->rank) {
mpi_errno = set_lock_sync_counter(win_ptr, lock_pkt->origin_rank,
mpi_errno = handle_lock_ack(win_ptr, lock_pkt->origin_rank,
MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
}
......
......@@ -1016,7 +1016,7 @@ int MPIDI_CH3_PktHandler_CASResp(MPIDI_VC_t * vc ATTRIBUTE((unused)),
/* decrement ack_counter on this target */
if (cas_resp_pkt->flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED) {
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
cas_resp_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......@@ -1184,7 +1184,7 @@ int MPIDI_CH3_PktHandler_FOPResp(MPIDI_VC_t * vc ATTRIBUTE((unused)),
/* decrement ack_counter */
if (fop_resp_pkt->flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED) {
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
fop_resp_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......@@ -1240,7 +1240,7 @@ int MPIDI_CH3_PktHandler_Get_AccumResp(MPIDI_VC_t * vc, MPIDI_CH3_Pkt_t * pkt,
/* decrement ack_counter on target */
if (get_accum_resp_pkt->flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED) {
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
get_accum_resp_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......@@ -1377,7 +1377,7 @@ int MPIDI_CH3_PktHandler_GetResp(MPIDI_VC_t * vc ATTRIBUTE((unused)),
/* decrement ack_counter on target */
if (get_resp_pkt->flags & MPIDI_CH3_PKT_FLAG_RMA_LOCK_GRANTED) {
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
get_resp_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......@@ -1465,7 +1465,7 @@ int MPIDI_CH3_PktHandler_LockAck(MPIDI_VC_t * vc, MPIDI_CH3_Pkt_t * pkt,
MPID_Win_get_ptr(lock_ack_pkt->source_win_handle, win_ptr);
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
lock_ack_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......@@ -1500,7 +1500,7 @@ int MPIDI_CH3_PktHandler_LockOpAck(MPIDI_VC_t * vc, MPIDI_CH3_Pkt_t * pkt,
MPID_Win_get_ptr(lock_op_ack_pkt->source_win_handle, win_ptr);
mpi_errno = set_lock_sync_counter(win_ptr, target_rank,
mpi_errno = handle_lock_ack(win_ptr, target_rank,
lock_op_ack_pkt->flags);
if (mpi_errno) MPIU_ERR_POP(mpi_errno);
......
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