@@ -8069,8 +8069,8 @@ PDC_assign_server(int32_t *my_server_start, int32_t *my_server_end, int32_t *my_
80698069}
80708070
80718071// All clients collectively query all servers, each client gets partial results
8072- perr_t
8073- PDC_Client_query_kvtag_coll (const pdc_kvtag_t * kvtag , int * n_res , uint64_t * * pdc_ids , int * query_sent )
8072+ static perr_t
8073+ PDC_Client_query_partial_kvtag_coll (const pdc_kvtag_t * kvtag , int * n_res , uint64_t * * pdc_ids , int * query_sent )
80748074{
80758075 FUNC_ENTER (NULL );
80768076
@@ -8177,7 +8177,7 @@ _customized_all_gather_result(int query_sent, int *n_res, uint64_t **pdc_ids, MP
81778177 int sub_n_obj_len = n_sent_ranks + 1 ; // the last element is the first rank who sent the query.
81788178 int * sub_n_obj_arr = (int * )PDC_calloc (sub_n_obj_len , sizeof (int ));
81798179 // FIXME: how to get the global rank number of the first rank who sent the query?
8180- // currently, we use 0, since each time when PDC_Client_query_kvtag_col runs, it is always using the
8180+ // currently, we use 0, since each time when PDC_Client_query_kvtag_coll runs, it is always using the
81818181 // first N ranks to send the query, where N is the number of servers.
81828182 sub_n_obj_arr [sub_n_obj_len - 1 ] = 0 ;
81838183
@@ -8242,7 +8242,7 @@ PDC_Client_query_kvtag_coll(const pdc_kvtag_t *kvtag, int *n_res, uint64_t **pdc
82428242 MPI_Barrier (world_comm );
82438243 stime = MPI_Wtime ();
82448244
8245- ret_value = PDC_Client_query_kvtag_coll (kvtag , n_res , pdc_ids , & query_sent );
8245+ ret_value = PDC_Client_query_partial_kvtag_coll (kvtag , n_res , pdc_ids , & query_sent );
82468246
82478247 MPI_Barrier (world_comm );
82488248 duration = MPI_Wtime () - stime ;
0 commit comments