Skip to content

Commit e4072fe

Browse files
author
Mamzi Bayatpour [email protected] ()
committed
fixing the macros
1 parent 5c28f90 commit e4072fe

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

ompi/mca/osc/ucx/osc_ucx.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,12 +47,12 @@ typedef struct ompi_osc_ucx_component {
4747

4848
OMPI_DECLSPEC extern ompi_osc_ucx_component_t mca_osc_ucx_component;
4949

50-
#define INCREMENT_OUTSTANDING_NB_OPS \
50+
#define OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS() \
5151
do { \
5252
mca_osc_ucx_component.num_incomplete_req_ops++; \
5353
} while(0);
5454

55-
#define DECREMENT_OUTSTANDING_NB_OPS \
55+
#define OSC_UCX_DECREMENT_OUTSTANDING_NB_OPS() \
5656
do { \
5757
mca_osc_ucx_component.num_incomplete_req_ops--; \
5858
} while(0);

ompi/mca/osc/ucx/osc_ucx_comm.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1135,7 +1135,7 @@ int ompi_osc_ucx_rput(const void *origin_addr, int origin_count,
11351135

11361136
OMPI_OSC_UCX_REQUEST_ALLOC(win, ucx_req);
11371137

1138-
INCREMENT_OUTSTANDING_NB_OPS;
1138+
OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS();
11391139
ret = opal_common_ucx_wpmem_flush_ep_nb(mem, target, req_completion, ucx_req, ep);
11401140

11411141
if (ret != OMPI_SUCCESS) {
@@ -1190,7 +1190,7 @@ int ompi_osc_ucx_rget(void *origin_addr, int origin_count,
11901190

11911191
OMPI_OSC_UCX_REQUEST_ALLOC(win, ucx_req);
11921192

1193-
INCREMENT_OUTSTANDING_NB_OPS;
1193+
OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS();
11941194
ret = opal_common_ucx_wpmem_flush_ep_nb(mem, target, req_completion, ucx_req, ep);
11951195

11961196
if (ret != OMPI_SUCCESS) {
@@ -1349,7 +1349,7 @@ static inline int ompi_osc_ucx_acc_rputget(void *stage_addr, int stage_count,
13491349

13501350
module->skip_sync_check = sync_check;
13511351
if (acc_type != NONE) {
1352-
INCREMENT_OUTSTANDING_NB_OPS;
1352+
OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS();
13531353
ret = opal_common_ucx_wpmem_flush_ep_nb(mem, target, req_completion, ucx_req, ep);
13541354

13551355
if (ret != OMPI_SUCCESS) {
@@ -1660,7 +1660,7 @@ void req_completion(void *request) {
16601660
}
16611661
}
16621662

1663-
DECREMENT_OUTSTANDING_NB_OPS;
1663+
OSC_UCX_DECREMENT_OUTSTANDING_NB_OPS();
16641664
ompi_request_complete(&(req->super), true);
16651665
assert(mca_osc_ucx_component.num_incomplete_req_ops >= 0);
16661666
}

ompi/mca/osc/ucx/osc_ucx_component.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -995,7 +995,7 @@ inline int ompi_osc_ucx_nonblocking_ops_finalize(ompi_osc_ucx_module_t *module,
995995
}
996996

997997
if (lock_acquired) {
998-
INCREMENT_OUTSTANDING_NB_OPS;
998+
OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS();
999999
ret = opal_common_ucx_wpmem_fetch_nb(module->state_mem,
10001000
UCP_ATOMIC_FETCH_OP_SWAP, TARGET_LOCK_UNLOCKED,
10011001
target, &(module->req_result), sizeof(module->req_result),
@@ -1008,7 +1008,7 @@ inline int ompi_osc_ucx_nonblocking_ops_finalize(ompi_osc_ucx_module_t *module,
10081008
} else {
10091009
/* Lock is not acquired, but still, we need to know when the
10101010
* acc is finalized so that we can free the temp buffers */
1011-
INCREMENT_OUTSTANDING_NB_OPS;
1011+
OSC_UCX_INCREMENT_OUTSTANDING_NB_OPS();
10121012
ret = opal_common_ucx_wpmem_flush_ep_nb(module->mem, target, req_completion, ucx_req, ep);
10131013

10141014
if (ret != OMPI_SUCCESS) {

0 commit comments

Comments
 (0)