Skip to content

Commit a4c7458

Browse files
Committing clang-format changes
1 parent 0787954 commit a4c7458

File tree

3 files changed

+15
-13
lines changed

3 files changed

+15
-13
lines changed

src/server/include/pdc_client_server_common.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ typedef struct data_server_region_t {
352352
* The flag should be set if region size in bytes is greater than or equal
353353
* to chunk size
354354
*/
355-
uint8_t use_region_per_file;
355+
uint8_t use_region_per_file;
356356
struct data_server_region_t *prev;
357357
struct data_server_region_t *next;
358358
} data_server_region_t;

src/server/pdc_server_region/pdc_server_data.c

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4620,14 +4620,15 @@ PDC_Server_data_io_from_region_per_file(uint64_t obj_id, struct pdc_region_info
46204620
}
46214621

46224622
// Used to buffer I/O operations
4623-
uint8_t* buf_io_ops = (uint8_t*)malloc(region->region_size_elements * unit);
4624-
errno = 0;
4623+
uint8_t *buf_io_ops = (uint8_t *)malloc(region->region_size_elements * unit);
4624+
errno = 0;
46254625
if (ftruncate(region->fd, region->region_size_elements * unit) != 0) {
46264626
LOG_ERROR("Error: %s\n", strerror(errno));
46274627
PGOTO_ERROR(FAIL, "Failed to tfruncate");
46284628
}
46294629
errno = 0;
4630-
if(pread(region->fd, buf_io_ops, region->region_size_elements * unit, 0) != region->region_size_elements * unit) {
4630+
if (pread(region->fd, buf_io_ops, region->region_size_elements * unit, 0) !=
4631+
region->region_size_elements * unit) {
46314632
LOG_ERROR("Error: %s\n", strerror(errno));
46324633
PGOTO_ERROR(FAIL, "Failed to pread");
46334634
}
@@ -4670,7 +4671,8 @@ PDC_Server_data_io_from_region_per_file(uint64_t obj_id, struct pdc_region_info
46704671
PGOTO_ERROR(FAIL, "Failed to tfruncate");
46714672
}
46724673
errno = 0;
4673-
if(pread(region->fd, buf_io_ops, region->region_size_elements * unit, 0) != region->region_size_elements * unit) {
4674+
if (pread(region->fd, buf_io_ops, region->region_size_elements * unit, 0) !=
4675+
region->region_size_elements * unit) {
46744676
LOG_ERROR("Error: %s\n", strerror(errno));
46754677
PGOTO_ERROR(FAIL, "Failed to pread");
46764678
}

src/server/pdc_server_region/pdc_server_region_request_handler.h

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -195,13 +195,13 @@ transfer_request_all_bulk_transfer_write_cb(const struct hg_cb_info *info)
195195
for (i = 0; i < request_data.n_objs; ++i) {
196196
temp_ptrs[i] = PDC_Server_get_obj_region(request_data.obj_id[i]);
197197
}
198-
#else
198+
#else
199199
data_server_region_t **temp_ptrs =
200-
(data_server_region_t **)malloc(sizeof(data_server_region_t *) * request_data.n_objs);
201-
for (i = 0; i < request_data.n_objs; ++i) {
202-
temp_ptrs[i] = PDC_Server_get_obj_region(request_data.obj_id[i]);
203-
PDC_Server_register_obj_region_by_pointer(temp_ptrs + i, request_data.obj_id[i], 1, 0);
204-
}
200+
(data_server_region_t **)malloc(sizeof(data_server_region_t *) * request_data.n_objs);
201+
for (i = 0; i < request_data.n_objs; ++i) {
202+
temp_ptrs[i] = PDC_Server_get_obj_region(request_data.obj_id[i]);
203+
PDC_Server_register_obj_region_by_pointer(temp_ptrs + i, request_data.obj_id[i], 1, 0);
204+
}
205205
#endif
206206
#endif
207207
for (i = 0; i < request_data.n_objs; ++i) {
@@ -216,8 +216,8 @@ transfer_request_all_bulk_transfer_write_cb(const struct hg_cb_info *info)
216216

217217
#ifdef PDC_USE_REGION_PER_FILE
218218
PDC_Server_transfer_request_io(request_data.obj_id[i], request_data.obj_ndim[i],
219-
request_data.obj_dims[i], remote_reg_info,
220-
(void *)request_data.data_buf[i], request_data.unit[i], 1);
219+
request_data.obj_dims[i], remote_reg_info,
220+
(void *)request_data.data_buf[i], request_data.unit[i], 1);
221221
#endif
222222

223223
pthread_mutex_lock(&transfer_request_status_mutex);

0 commit comments

Comments
 (0)