@@ -157,26 +157,26 @@ OMPI_MODULE_DECLSPEC extern mca_coll_sync_component_t mca_coll_sync_component;
157157
158158/* Macro used in most of the collectives */
159159
160- #define COLL_SYNC (module , op ) \
160+ #define COLL_SYNC (m , op ) \
161161do { \
162162 int err = MPI_SUCCESS; \
163- s ->in_operation = true; \
164- if (OPAL_UNLIKELY(++s ->before_num_operations == \
165- mca_coll_sync_component.barrier_before_nops)) { \
166- s ->before_num_operations = 0; \
167- err = s ->c_coll.coll_barrier(comm, s ->c_coll.coll_barrier_module); \
168- } \
169- if (OPAL_LIKELY(MPI_SUCCESS == err)) { \
170- err = op; \
171- } \
172- if (OPAL_UNLIKELY(++s ->after_num_operations == \
173- mca_coll_sync_component.barrier_after_nops) && \
174- OPAL_LIKELY(MPI_SUCCESS == err)) { \
175- s ->after_num_operations = 0; \
176- err = s ->c_coll.coll_barrier(comm, s ->c_coll.coll_barrier_module); \
177- } \
178- s ->in_operation = false; \
179- return err; \
163+ (m) ->in_operation = true; \
164+ if (OPAL_UNLIKELY(++((m) ->before_num_operations) == \
165+ mca_coll_sync_component.barrier_before_nops)) { \
166+ (m) ->before_num_operations = 0; \
167+ err = (m) ->c_coll.coll_barrier(comm, (m) ->c_coll.coll_barrier_module); \
168+ } \
169+ if (OPAL_LIKELY(MPI_SUCCESS == err)) { \
170+ err = op; \
171+ } \
172+ if (OPAL_UNLIKELY(++((m) ->after_num_operations) == \
173+ mca_coll_sync_component.barrier_after_nops) && \
174+ OPAL_LIKELY(MPI_SUCCESS == err)) { \
175+ (m) ->after_num_operations = 0; \
176+ err = (m) ->c_coll.coll_barrier(comm, (m) ->c_coll.coll_barrier_module); \
177+ } \
178+ (m) ->in_operation = false; \
179+ return err; \
180180} while(0)
181181
182182END_C_DECLS
0 commit comments