@@ -101,10 +101,10 @@ int mca_spml_ucx_enable(bool enable)
101
101
102
102
int mca_spml_ucx_del_procs (ompi_proc_t * * procs , size_t nprocs )
103
103
{
104
+ size_t ucp_workers = mca_spml_ucx .ucp_workers ;
104
105
opal_common_ucx_del_proc_t * del_procs ;
105
106
size_t i , w , n ;
106
107
int ret ;
107
- int ucp_workers = mca_spml_ucx .ucp_workers ;
108
108
109
109
oshmem_shmem_barrier ();
110
110
@@ -281,16 +281,16 @@ int mca_spml_ucx_clear_put_op_mask(mca_spml_ucx_ctx_t *ctx)
281
281
282
282
int mca_spml_ucx_add_procs (ompi_proc_t * * procs , size_t nprocs )
283
283
{
284
- size_t i , j , k , w , n ;
285
- int rc = OSHMEM_ERROR ;
286
- int my_rank = oshmem_my_proc_id ();
287
- int ucp_workers = mca_spml_ucx .ucp_workers ;
284
+ int rc = OSHMEM_ERROR ;
285
+ int my_rank = oshmem_my_proc_id ();
286
+ size_t ucp_workers = mca_spml_ucx .ucp_workers ;
287
+ unsigned int * wk_roffs = NULL ;
288
+ unsigned int * wk_rsizes = NULL ;
289
+ char * wk_raddrs = NULL ;
290
+ size_t i , j , w , n ;
288
291
ucs_status_t err ;
289
292
ucp_address_t * * wk_local_addr ;
290
293
unsigned int * wk_addr_len ;
291
- unsigned int * wk_roffs = NULL ;
292
- unsigned int * wk_rsizes = NULL ;
293
- char * wk_raddrs = NULL ;
294
294
ucp_ep_params_t ep_params ;
295
295
296
296
wk_local_addr = calloc (mca_spml_ucx .ucp_workers , sizeof (ucp_address_t * ));
@@ -749,9 +749,9 @@ static int mca_spml_ucx_ctx_create_common(long options, mca_spml_ucx_ctx_t **ucx
749
749
750
750
int mca_spml_ucx_ctx_create (long options , shmem_ctx_t * ctx )
751
751
{
752
- mca_spml_ucx_ctx_t * ucx_ctx = NULL ;
753
- mca_spml_ucx_ctx_array_t * idle_array = & mca_spml_ucx .idle_array ;
752
+ mca_spml_ucx_ctx_t * ucx_ctx = NULL ;
754
753
mca_spml_ucx_ctx_array_t * active_array = & mca_spml_ucx .active_array ;
754
+ mca_spml_ucx_ctx_array_t * idle_array = & mca_spml_ucx .idle_array ;
755
755
int i = 0 , rc = OSHMEM_SUCCESS ;
756
756
757
757
/* Take a lock controlling context creation. AUX context may set specific
@@ -781,8 +781,8 @@ int mca_spml_ucx_ctx_create(long options, shmem_ctx_t *ctx)
781
781
782
782
if (!(options & SHMEM_CTX_PRIVATE )) {
783
783
SHMEM_MUTEX_LOCK (mca_spml_ucx .internal_mutex );
784
- _ctx_add (& mca_spml_ucx . active_array , ucx_ctx );
785
- if (mca_spml_ucx . active_array . ctxs_count == 0 ) {
784
+ _ctx_add (active_array , ucx_ctx );
785
+ if (active_array -> ctxs_count == 0 ) {
786
786
opal_progress_register (spml_ucx_ctx_progress );
787
787
}
788
788
SHMEM_MUTEX_UNLOCK (mca_spml_ucx .internal_mutex );
0 commit comments