@@ -289,7 +289,7 @@ int mca_spml_ucx_add_procs(ompi_proc_t** procs, size_t nprocs)
289
289
& ep_params ,
290
290
& mca_spml_ucx .ucp_peers [i ].ucp_conn );
291
291
if (UCS_OK != err ) {
292
- SPML_ERROR ("ucp_ep_create failed: %s\n " , ucs_status_string (err ));
292
+ SPML_ERROR ("ucp_ep_create failed: %s" , ucs_status_string (err ));
293
293
goto error2 ;
294
294
}
295
295
OSHMEM_PROC_DATA (procs [i ])-> num_transports = 1 ;
@@ -387,15 +387,16 @@ void mca_spml_ucx_rmkey_unpack(sshmem_mkey_t *mkey, uint32_t segno, int pe, int
387
387
388
388
void mca_spml_ucx_memuse_hook (void * addr , size_t length )
389
389
{
390
- int my_pe = oshmem_my_proc_id () ;
391
- spml_ucx_mkey_t * ucx_mkey ;
390
+ int my_pe ;
391
+ spml_ucx_mkey_t * ucx_mkey ;
392
392
ucp_mem_advise_params_t params ;
393
393
ucs_status_t status ;
394
394
395
395
if (!(mca_spml_ucx .heap_reg_nb && memheap_is_va_in_segment (addr , HEAP_SEG_INDEX ))) {
396
396
return ;
397
397
}
398
398
399
+ my_pe = oshmem_my_proc_id ();
399
400
ucx_mkey = & mca_spml_ucx .ucp_peers [my_pe ].mkeys [HEAP_SEG_INDEX ].key ;
400
401
401
402
params .field_mask = UCP_MEM_ADVISE_PARAM_FIELD_ADDRESS |
@@ -568,7 +569,7 @@ int mca_spml_ucx_fence(void)
568
569
569
570
err = ucp_worker_flush (mca_spml_ucx .ucp_worker );
570
571
if (UCS_OK != err ) {
571
- SPML_ERROR ("fence failed: %s" , ucs_status_string (err ));
572
+ SPML_ERROR ("fence failed: %s" , ucs_status_string (err ));
572
573
oshmem_shmem_abort (-1 );
573
574
return OSHMEM_ERROR ;
574
575
}
@@ -581,7 +582,7 @@ int mca_spml_ucx_quiet(void)
581
582
582
583
err = ucp_worker_flush (mca_spml_ucx .ucp_worker );
583
584
if (UCS_OK != err ) {
584
- SPML_ERROR ("fence failed: %s" , ucs_status_string (err ));
585
+ SPML_ERROR ("fence failed: %s" , ucs_status_string (err ));
585
586
oshmem_shmem_abort (-1 );
586
587
return OSHMEM_ERROR ;
587
588
}
0 commit comments