@@ -282,7 +282,8 @@ static void wait_cbfunc(struct pmix_peer_t *pr, pmix_ptl_hdr_t *hdr, pmix_buffer
282
282
{
283
283
pmix_lock_t * lock = (pmix_lock_t * ) cbdata ;
284
284
285
- pmix_output_verbose (2 , pmix_client_globals .base_output , "pmix:client wait_cbfunc received" );
285
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
286
+ "pmix:client wait_cbfunc received" );
286
287
if (NULL == pr || NULL == hdr || NULL == buf || NULL == cbdata ) {
287
288
;
288
289
}
@@ -357,7 +358,8 @@ static void notification_fn(size_t evhdlr_registration_id, pmix_status_t status,
357
358
char * name = NULL ;
358
359
size_t n ;
359
360
360
- pmix_output_verbose (2 , pmix_client_globals .base_output , "[%s:%d] DEBUGGER RELEASE RECVD" ,
361
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
362
+ "[%s:%d] DEBUGGER RELEASE RECVD" ,
361
363
pmix_globals .myid .nspace , pmix_globals .myid .rank );
362
364
363
365
PMIX_HIDE_UNUSED_PARAMS (evhdlr_registration_id , status , source , results , nresults );
@@ -625,13 +627,20 @@ PMIX_EXPORT pmix_status_t PMIx_Init(pmix_proc_t *proc, pmix_info_t info[], size_
625
627
626
628
/* setup the runtime - this init's the globals,
627
629
* opens and initializes the required frameworks */
628
- if ( PMIX_SUCCESS
629
- != ( rc = pmix_rte_init ( PMIX_PROC_CLIENT , info , ninfo , pmix_client_notify_recv )) ) {
630
+ rc = pmix_rte_init ( PMIX_PROC_CLIENT , info , ninfo , pmix_client_notify_recv );
631
+ if ( PMIX_SUCCESS != rc ) {
630
632
PMIX_ERROR_LOG (rc );
631
633
pmix_init_result = rc ;
632
634
PMIX_RELEASE_THREAD (& pmix_global_lock );
633
635
return rc ;
634
636
}
637
+ /* setup the base verbosity */
638
+ if (0 < pmix_client_globals .base_verbose ) {
639
+ /* set default output */
640
+ pmix_client_globals .base_output = pmix_output_open (NULL );
641
+ pmix_output_set_verbosity (pmix_client_globals .base_output ,
642
+ pmix_client_globals .base_verbose );
643
+ }
635
644
/* setup the IO Forwarding recv */
636
645
rcv = PMIX_NEW (pmix_ptl_posted_recv_t );
637
646
rcv -> tag = PMIX_PTL_TAG_IOF ;
@@ -673,15 +682,8 @@ PMIX_EXPORT pmix_status_t PMIx_Init(pmix_proc_t *proc, pmix_info_t info[], size_
673
682
return PMIX_ERR_NOMEM ;
674
683
}
675
684
676
- /* setup the base verbosity */
677
- if (0 < pmix_client_globals .base_verbose ) {
678
- /* set default output */
679
- pmix_client_globals .base_output = pmix_output_open (NULL );
680
- pmix_output_set_verbosity (pmix_client_globals .base_output ,
681
- pmix_client_globals .base_verbose );
682
- }
683
-
684
- pmix_output_verbose (2 , pmix_client_globals .base_output , "pmix: init called" );
685
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
686
+ "pmix: init called" );
685
687
686
688
/* see if the required info is present */
687
689
if (NULL == (evar = getenv ("PMIX_NAMESPACE" ))) {
@@ -869,6 +871,11 @@ PMIX_EXPORT pmix_status_t PMIx_Init(pmix_proc_t *proc, pmix_info_t info[], size_
869
871
wildcard .rank = PMIX_RANK_WILDCARD ;
870
872
PMIX_INFO_LOAD (& ginfo , PMIX_OPTIONAL , NULL , PMIX_BOOL );
871
873
if (PMIX_SUCCESS == PMIx_Get (& wildcard , PMIX_DEBUG_STOP_IN_INIT , & ginfo , 1 , & val )) {
874
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
875
+ "[%s:%d] RECEIVED STOP IN INIT FOR RANK %s" ,
876
+ pmix_globals .myid .nspace ,
877
+ pmix_globals .myid .rank ,
878
+ PMIX_RANK_PRINT (val -> data .rank ));
872
879
/* are we one of the procs to stop? */
873
880
if (PMIX_CHECK_RANK (val -> data .rank , pmix_globals .myid .rank )) {
874
881
/* if the value was found, then we need to wait for debugger attach here */
@@ -900,6 +907,11 @@ PMIX_EXPORT pmix_status_t PMIx_Init(pmix_proc_t *proc, pmix_info_t info[], size_
900
907
PMIX_DESTRUCT_LOCK (& releaselock );
901
908
}
902
909
PMIX_VALUE_FREE (val , 1 ); // cleanup memory
910
+ } else {
911
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
912
+ "[%s:%d] NO DEBUGGER WAITING" ,
913
+ pmix_globals .myid .nspace ,
914
+ pmix_globals .myid .rank );
903
915
}
904
916
PMIX_INFO_DESTRUCT (& ginfo );
905
917
@@ -1009,7 +1021,8 @@ PMIX_EXPORT pmix_status_t PMIx_Finalize(const pmix_info_t info[], size_t ninfo)
1009
1021
}
1010
1022
pmix_globals .init_cntr = 0 ;
1011
1023
1012
- pmix_output_verbose (2 , pmix_client_globals .base_output , "%s:%d pmix:client finalize called" ,
1024
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
1025
+ "%s:%d pmix:client finalize called" ,
1013
1026
pmix_globals .myid .nspace , pmix_globals .myid .rank );
1014
1027
1015
1028
/* mark that I called finalize */
@@ -1121,7 +1134,8 @@ PMIX_EXPORT pmix_status_t PMIx_Abort(int flag, const char msg[], pmix_proc_t pro
1121
1134
pmix_status_t rc ;
1122
1135
pmix_lock_t reglock ;
1123
1136
1124
- pmix_output_verbose (2 , pmix_client_globals .base_output , "pmix:client abort called" );
1137
+ pmix_output_verbose (2 , pmix_client_globals .base_output ,
1138
+ "pmix:client abort called" );
1125
1139
1126
1140
PMIX_ACQUIRE_THREAD (& pmix_global_lock );
1127
1141
if (pmix_globals .init_cntr <= 0 ) {
0 commit comments