Skip to content

Commit

Permalink
Committing clang-format changes
Browse files Browse the repository at this point in the history
  • Loading branch information
github-actions[bot] committed Apr 26, 2024
1 parent ccaf036 commit 145c787
Showing 1 changed file with 13 additions and 11 deletions.
24 changes: 13 additions & 11 deletions src/api/pdc_region/pdc_region_transfer.c
Original file line number Diff line number Diff line change
Expand Up @@ -903,7 +903,7 @@ register_metadata(pdc_transfer_request_start_all_pkg **transfer_request_input, i
* sorted in terms of data_server_id. We pack data from user buffer to contiguous buffers. Static partitioning
* requires having at most n_data_servers number of contiguous regions.
*/
static perr_t
static perr_t
prepare_start_all_requests(pdcid_t *transfer_request_id, int size,
pdc_transfer_request_start_all_pkg ***write_transfer_request_ptr,
pdc_transfer_request_start_all_pkg ***read_transfer_request_ptr,
Expand Down Expand Up @@ -961,7 +961,7 @@ prepare_start_all_requests(pdcid_t *transfer_request_id, int size,
&(transfer_request->output_sizes), &(transfer_request->output_buf));
if (transfer_request->n_obj_servers == 0) {
printf("PDC_Client %d, %s: error with static region partition, no server is selected!\n",
pdc_client_mpi_rank_g, __func__);
pdc_client_mpi_rank_g, __func__);
return FAIL;
}
for (j = 0; j < transfer_request->n_obj_servers; ++j) {
Expand Down Expand Up @@ -1326,8 +1326,9 @@ PDCregion_transfer_start_all(pdcid_t *transfer_request_id, int size)
FUNC_ENTER(NULL);
// Split write and read requests. Handle them separately.
// printf("PDCregion_transfer_start_all: checkpoint %d\n", __LINE__);
ret_value = prepare_start_all_requests(transfer_request_id, size, &write_transfer_requests, &read_transfer_requests,
&write_size, &read_size, &posix_transfer_request_id, &posix_size);
ret_value = prepare_start_all_requests(transfer_request_id, size, &write_transfer_requests,
&read_transfer_requests, &write_size, &read_size,
&posix_transfer_request_id, &posix_size);
/*
printf("PDCregion_transfer_start_all: checkpoint %d, write_size = %d, read_size = %d\n", __LINE__,
write_size, read_size);
Expand Down Expand Up @@ -1459,15 +1460,16 @@ PDCregion_transfer_start(pdcid_t transfer_request_id)

if (transfer_request->region_partition == PDC_REGION_STATIC) {
// Identify which part of the region is going to which data server.
ret_value = static_region_partition(transfer_request->new_buf, transfer_request->remote_region_ndim, unit,
transfer_request->access_type, transfer_request->obj_dims,
transfer_request->remote_region_offset, transfer_request->remote_region_size,
1, &(transfer_request->n_obj_servers), &(transfer_request->obj_servers),
&(transfer_request->sub_offsets), &(transfer_request->output_offsets),
&(transfer_request->output_sizes), &(transfer_request->output_buf));
ret_value = static_region_partition(
transfer_request->new_buf, transfer_request->remote_region_ndim, unit,
transfer_request->access_type, transfer_request->obj_dims, transfer_request->remote_region_offset,
transfer_request->remote_region_size, 1, &(transfer_request->n_obj_servers),
&(transfer_request->obj_servers), &(transfer_request->sub_offsets),
&(transfer_request->output_offsets), &(transfer_request->output_sizes),
&(transfer_request->output_buf));
if (transfer_request->n_obj_servers == 0) {
printf("PDC_Client %d, %s: error with static region partition, no server is selected!\n",
pdc_client_mpi_rank_g, __func__);
pdc_client_mpi_rank_g, __func__);
return FAIL;
}
/*
Expand Down

0 comments on commit 145c787

Please sign in to comment.