@@ -2428,6 +2428,7 @@ static int _store_data_for_rank(ns_track_elem_t *ns_info, pmix_rank_t rank, pmix
24282428 rank_meta_info * rinfo = NULL ;
24292429 size_t num_elems , free_offset , new_free_offset ;
24302430 int data_exist ;
2431+ int32_t cnt ;
24312432
24322433 PMIX_OUTPUT_VERBOSE ((10 , pmix_globals .debug_output ,
24332434 "%s:%d:%s: for rank %u" , __FILE__ , __LINE__ , __func__ , rank ));
@@ -2458,7 +2459,8 @@ static int _store_data_for_rank(ns_track_elem_t *ns_info, pmix_rank_t rank, pmix
24582459 */
24592460 free_offset = get_free_offset (datadesc );
24602461 kp = PMIX_NEW (pmix_kval_t );
2461- while (PMIX_SUCCESS == (rc = pmix_bfrop .unpack (buf , kp , & (int ){1 }, PMIX_KVAL ))) {
2462+ cnt = 1 ;
2463+ while (PMIX_SUCCESS == (rc = pmix_bfrop .unpack (buf , kp , & cnt , PMIX_KVAL ))) {
24622464 pmix_output_verbose (2 , pmix_globals .debug_output ,
24632465 "pmix: unpacked key %s" , kp -> key );
24642466 if (PMIX_SUCCESS != (rc = pmix_sm_store (ns_info , rank , kp , & rinfo , data_exist ))) {
@@ -2470,6 +2472,7 @@ static int _store_data_for_rank(ns_track_elem_t *ns_info, pmix_rank_t rank, pmix
24702472 }
24712473 PMIX_RELEASE (kp ); // maintain acctg - hash_store does a retain
24722474 kp = PMIX_NEW (pmix_kval_t );
2475+ cnt = 1 ;
24732476 }
24742477 PMIX_RELEASE (kp );
24752478
0 commit comments