@@ -456,6 +456,7 @@ int pmix2x_get(const opal_process_name_t *proc, const char *key,
456
456
size_t sz = 0 , n ;
457
457
opal_value_t * ival ;
458
458
pmix_value_t * pval = NULL ;
459
+ int ret ;
459
460
460
461
opal_output_verbose (1 , opal_pmix_base_framework .framework_output ,
461
462
"%s pmix2x:client get on proc %s key %s" ,
@@ -517,8 +518,11 @@ int pmix2x_get(const opal_process_name_t *proc, const char *key,
517
518
rc = PMIx_Get (& p , key , pinfo , sz , & pval );
518
519
if (PMIX_SUCCESS == rc ) {
519
520
ival = OBJ_NEW (opal_value_t );
520
- pmix2x_value_unload (ival , pval );
521
- * val = ival ;
521
+ if (OPAL_SUCCESS != (ret = pmix2x_value_unload (ival , pval ))) {
522
+ rc = pmix2x_convert_opalrc (ret );
523
+ } else {
524
+ * val = ival ;
525
+ }
522
526
PMIX_VALUE_FREE (pval , 1 );
523
527
}
524
528
PMIX_INFO_FREE (pinfo , sz );
@@ -728,6 +732,7 @@ int pmix2x_lookup(opal_list_t *data, opal_list_t *info)
728
732
size_t cnt , n , sz ;
729
733
opal_value_t * iptr ;
730
734
opal_pmix2x_jobid_trkr_t * jptr , * job ;
735
+ int ret ;
731
736
732
737
opal_output_verbose (1 , opal_pmix_base_framework .framework_output ,
733
738
"pmix2x:client lookup" );
@@ -792,7 +797,9 @@ int pmix2x_lookup(opal_list_t *data, opal_list_t *info)
792
797
opal_list_append (& mca_pmix_pmix2x_component .jobids , & job -> super );
793
798
}
794
799
d -> proc .vpid = pmix2x_convert_rank (pdata [n ].proc .rank );
795
- pmix2x_value_unload (& d -> value , & pdata [n ].value );
800
+ if (OPAL_SUCCESS != (ret = pmix2x_value_unload (& d -> value , & pdata [n ].value ))) {
801
+ OPAL_ERROR_LOG (ret );
802
+ }
796
803
}
797
804
OPAL_PMIX_RELEASE_THREAD (& opal_pmix_base .lock );
798
805
}
@@ -1069,7 +1076,7 @@ static void spcbfunc(pmix_status_t status,
1069
1076
{
1070
1077
pmix2x_opcaddy_t * op = (pmix2x_opcaddy_t * )cbdata ;
1071
1078
opal_pmix2x_jobid_trkr_t * job ;
1072
- opal_jobid_t jobid ;
1079
+ opal_jobid_t jobid = OPAL_JOBID_INVALID ;
1073
1080
int rc ;
1074
1081
1075
1082
OPAL_ACQUIRE_OBJECT (op );
0 commit comments