@@ -75,7 +75,7 @@ typedef struct pdc_transfer_request {
75
75
// For each of the contig buffer sent to a server, we have a bulk buffer.
76
76
char * * bulk_buf ;
77
77
// Reference counter for bulk_buf, if 0, we free it.
78
- int * * bulk_buf_ref ;
78
+ int * * bulk_buf_ref ;
79
79
pdc_region_partition_t region_partition ;
80
80
81
81
// Consistency semantics required by user
@@ -127,7 +127,7 @@ typedef struct pdc_transfer_request_start_all_pkg {
127
127
int index ;
128
128
// Data buffer. This data buffer is contiguous according to the remote region. We assume this is after
129
129
// transformation of local regions
130
- char * buf ;
130
+ char * buf ;
131
131
struct pdc_transfer_request_start_all_pkg * next ;
132
132
} pdc_transfer_request_start_all_pkg ;
133
133
@@ -141,7 +141,7 @@ typedef struct pdc_transfer_request_wait_all_pkg {
141
141
// Record the index of the metadata_id in the current transfer_request
142
142
int index ;
143
143
// Pointer to the transfer request
144
- pdc_transfer_request * transfer_request ;
144
+ pdc_transfer_request * transfer_request ;
145
145
struct pdc_transfer_request_wait_all_pkg * next ;
146
146
} pdc_transfer_request_wait_all_pkg ;
147
147
@@ -195,12 +195,12 @@ PDCregion_transfer_create(void *buf, pdc_access_t access_type, pdcid_t obj_id, p
195
195
pdcid_t remote_reg )
196
196
{
197
197
pdcid_t ret_value = SUCCEED ;
198
- struct _pdc_id_info * objinfo2 ;
199
- struct _pdc_obj_info * obj2 ;
200
- pdc_transfer_request * p ;
201
- struct _pdc_id_info * reginfo1 , * reginfo2 ;
198
+ struct _pdc_id_info * objinfo2 ;
199
+ struct _pdc_obj_info * obj2 ;
200
+ pdc_transfer_request * p ;
201
+ struct _pdc_id_info * reginfo1 , * reginfo2 ;
202
202
struct pdc_region_info * reg1 , * reg2 ;
203
- uint64_t * ptr ;
203
+ uint64_t * ptr ;
204
204
uint64_t unit ;
205
205
int j ;
206
206
@@ -285,7 +285,7 @@ PDCregion_transfer_create(void *buf, pdc_access_t access_type, pdcid_t obj_id, p
285
285
perr_t
286
286
PDCregion_transfer_close (pdcid_t transfer_request_id )
287
287
{
288
- struct _pdc_id_info * transferinfo ;
288
+ struct _pdc_id_info * transferinfo ;
289
289
pdc_transfer_request * transfer_request ;
290
290
perr_t ret_value = SUCCEED ;
291
291
FUNC_ENTER (NULL );
@@ -520,7 +520,7 @@ pack_region_buffer(char *buf, uint64_t *obj_dims, size_t total_data_size, int lo
520
520
{
521
521
uint64_t i , j ;
522
522
perr_t ret_value = SUCCEED ;
523
- char * ptr ;
523
+ char * ptr ;
524
524
525
525
FUNC_ENTER (NULL );
526
526
@@ -586,7 +586,7 @@ pack_region_metadata_query(pdc_transfer_request_start_all_pkg **transfer_request
586
586
{
587
587
perr_t ret_value = SUCCEED ;
588
588
int i ;
589
- char * ptr ;
589
+ char * ptr ;
590
590
uint64_t total_buf_size ;
591
591
uint8_t region_partition ;
592
592
@@ -634,13 +634,13 @@ unpack_region_metadata_query(char *buf, pdc_transfer_request_start_all_pkg **tra
634
634
{
635
635
perr_t ret_value = SUCCEED ;
636
636
pdc_transfer_request_start_all_pkg * transfer_request_head , * transfer_request_end ;
637
- pdc_transfer_request * local_request ;
637
+ pdc_transfer_request * local_request ;
638
638
int size ;
639
639
int i , j , index ;
640
640
int counter ;
641
- char * ptr ;
641
+ char * ptr ;
642
642
uint64_t region_size ;
643
- uint64_t * sub_offset ;
643
+ uint64_t * sub_offset ;
644
644
FUNC_ENTER (NULL );
645
645
646
646
local_request = NULL ;
@@ -733,10 +733,10 @@ register_metadata(pdc_transfer_request_start_all_pkg **transfer_request_input, i
733
733
perr_t ret_value = SUCCEED ;
734
734
int i , j , index , size , output_size , remain_size , n_objs ;
735
735
pdc_transfer_request_start_all_pkg * * transfer_requests ;
736
- pdc_transfer_request_start_all_pkg * transfer_request_head , * transfer_request_front_head ,
736
+ pdc_transfer_request_start_all_pkg * transfer_request_head , * transfer_request_front_head ,
737
737
* transfer_request_end , * * transfer_request_output , * previous = NULL ;
738
738
uint64_t total_buf_size , output_buf_size , query_id ;
739
- char * buf , * output_buf ;
739
+ char * buf , * output_buf ;
740
740
741
741
FUNC_ENTER (NULL );
742
742
transfer_request_output = NULL ;
@@ -867,7 +867,7 @@ prepare_start_all_requests(pdcid_t *transfer_request_id, int size,
867
867
* read_request_pkgs , * write_request_pkgs_end , * read_request_pkgs_end , * request_pkgs ,
868
868
* * transfer_request_output ;
869
869
int write_size , read_size , output_size ;
870
- struct _pdc_id_info * transferinfo ;
870
+ struct _pdc_id_info * transferinfo ;
871
871
pdc_transfer_request * transfer_request ;
872
872
int set_output_buf = 0 ;
873
873
@@ -1069,7 +1069,7 @@ PDC_Client_pack_all_requests(int n_objs, pdc_transfer_request_start_all_pkg **tr
1069
1069
char * * read_bulk_buf )
1070
1070
{
1071
1071
perr_t ret_value = SUCCEED ;
1072
- char * bulk_buf , * ptr , * ptr2 ;
1072
+ char * bulk_buf , * ptr , * ptr2 ;
1073
1073
size_t total_buf_size , obj_data_size , total_obj_data_size , unit , data_size , metadata_size ;
1074
1074
int i , j ;
1075
1075
@@ -1175,10 +1175,10 @@ PDC_Client_start_all_requests(pdc_transfer_request_start_all_pkg **transfer_requ
1175
1175
int index , i , j ;
1176
1176
int n_objs ;
1177
1177
uint64_t * metadata_id ;
1178
- char * * read_bulk_buf ;
1179
- char * bulk_buf ;
1178
+ char * * read_bulk_buf ;
1179
+ char * bulk_buf ;
1180
1180
size_t bulk_buf_size ;
1181
- int * bulk_buf_ref ;
1181
+ int * bulk_buf_ref ;
1182
1182
1183
1183
FUNC_ENTER (NULL );
1184
1184
@@ -1254,10 +1254,10 @@ static perr_t
1254
1254
merge_transfer_request_ids (pdcid_t * transfer_request_id , int size , pdcid_t * merged_request_id ,
1255
1255
int * merged_size )
1256
1256
{
1257
- struct _pdc_id_info * transferinfo ;
1257
+ struct _pdc_id_info * transferinfo ;
1258
1258
pdcid_t obj_id , new_local_reg , new_remote_reg ;
1259
1259
int flag = 0 , i ;
1260
- void * new_buf ;
1260
+ void * new_buf ;
1261
1261
pdc_access_t access_type ;
1262
1262
pdc_transfer_request * * all_transfer_request ;
1263
1263
uint64_t new_buf_size = 0 , copy_off = 0 ;
@@ -1361,7 +1361,7 @@ PDCregion_transfer_start_all_common(pdcid_t *transfer_request_id, int size, int
1361
1361
perr_t ret_value = SUCCEED ;
1362
1362
int write_size = 0 , read_size = 0 , posix_size = 0 , merged_size = 0 ;
1363
1363
pdc_transfer_request_start_all_pkg * * write_transfer_requests = NULL , * * read_transfer_requests = NULL ;
1364
- pdcid_t * posix_transfer_request_id , * merged_request_id ;
1364
+ pdcid_t * posix_transfer_request_id , * merged_request_id ;
1365
1365
1366
1366
FUNC_ENTER (NULL );
1367
1367
@@ -1446,7 +1446,7 @@ PDCregion_transfer_start_common(pdcid_t transfer_request_id,
1446
1446
#endif
1447
1447
{
1448
1448
perr_t ret_value = SUCCEED ;
1449
- struct _pdc_id_info * transferinfo ;
1449
+ struct _pdc_id_info * transferinfo ;
1450
1450
pdc_transfer_request * transfer_request ;
1451
1451
size_t unit ;
1452
1452
int i ;
@@ -1583,7 +1583,7 @@ release_region_buffer(char *buf, uint64_t *obj_dims, int local_ndim, uint64_t *l
1583
1583
int k ;
1584
1584
1585
1585
perr_t ret_value = SUCCEED ;
1586
- char * ptr ;
1586
+ char * ptr ;
1587
1587
FUNC_ENTER (NULL );
1588
1588
if (local_ndim == 2 ) {
1589
1589
if (access_type == PDC_READ ) {
@@ -1621,7 +1621,7 @@ perr_t
1621
1621
PDCregion_transfer_status (pdcid_t transfer_request_id , pdc_transfer_status_t * completed )
1622
1622
{
1623
1623
perr_t ret_value = SUCCEED ;
1624
- struct _pdc_id_info * transferinfo ;
1624
+ struct _pdc_id_info * transferinfo ;
1625
1625
pdc_transfer_request * transfer_request ;
1626
1626
size_t unit ;
1627
1627
int i ;
@@ -1709,13 +1709,13 @@ PDCregion_transfer_wait_all(pdcid_t *transfer_request_id, int size)
1709
1709
int index , i , j , merged_xfer = 0 , ori_size = size , is_first = 1 ;
1710
1710
size_t unit ;
1711
1711
int total_requests , n_objs ;
1712
- uint64_t * metadata_ids , merge_off = 0 , cur_off = 0 ;
1712
+ uint64_t * metadata_ids , merge_off = 0 , cur_off = 0 ;
1713
1713
pdc_transfer_request_wait_all_pkg * * transfer_requests , * transfer_request_head , * transfer_request_end ,
1714
1714
* temp ;
1715
1715
1716
1716
struct _pdc_id_info * * transferinfo ;
1717
1717
pdc_transfer_request * transfer_request , * merged_request ;
1718
- pdcid_t * my_transfer_request_id = transfer_request_id ;
1718
+ pdcid_t * my_transfer_request_id = transfer_request_id ;
1719
1719
1720
1720
double t0 , t1 ;
1721
1721
@@ -1946,7 +1946,7 @@ perr_t
1946
1946
PDCregion_transfer_wait (pdcid_t transfer_request_id )
1947
1947
{
1948
1948
perr_t ret_value = SUCCEED ;
1949
- struct _pdc_id_info * transferinfo ;
1949
+ struct _pdc_id_info * transferinfo ;
1950
1950
pdc_transfer_request * transfer_request ;
1951
1951
size_t unit ;
1952
1952
int i ;
0 commit comments