@@ -8069,8 +8069,8 @@ PDC_assign_server(int32_t *my_server_start, int32_t *my_server_end, int32_t *my_
8069
8069
}
8070
8070
8071
8071
// 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 )
8074
8074
{
8075
8075
FUNC_ENTER (NULL );
8076
8076
@@ -8177,7 +8177,7 @@ _customized_all_gather_result(int query_sent, int *n_res, uint64_t **pdc_ids, MP
8177
8177
int sub_n_obj_len = n_sent_ranks + 1 ; // the last element is the first rank who sent the query.
8178
8178
int * sub_n_obj_arr = (int * )PDC_calloc (sub_n_obj_len , sizeof (int ));
8179
8179
// 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
8181
8181
// first N ranks to send the query, where N is the number of servers.
8182
8182
sub_n_obj_arr [sub_n_obj_len - 1 ] = 0 ;
8183
8183
@@ -8242,7 +8242,7 @@ PDC_Client_query_kvtag_coll(const pdc_kvtag_t *kvtag, int *n_res, uint64_t **pdc
8242
8242
MPI_Barrier (world_comm );
8243
8243
stime = MPI_Wtime ();
8244
8244
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 );
8246
8246
8247
8247
MPI_Barrier (world_comm );
8248
8248
duration = MPI_Wtime () - stime ;
0 commit comments