Skip to content

Commit 844ae19

Browse files
committed
checkpoint
1 parent 1da9e1a commit 844ae19

File tree

5 files changed

+622
-195
lines changed

5 files changed

+622
-195
lines changed

src/server/pdc_server_region/include/pdc_server_region_transfer.h

Lines changed: 29 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,23 +3,46 @@
33

44
#include "pdc_region.h"
55

6+
typedef enum pdc_region_writeout_strategy {
7+
/**
8+
* Store data as multiple regions inside a single file.
9+
* Overlapping writes that are not fully contained append new regions
10+
* to the end of the file, with metadata tracking region locations.
11+
* Supports incremental updates without rewriting large parts of the file.
12+
*/
13+
STORE_REGION_BY_REGION_SINGLE_FILE = 0,
14+
15+
/**
16+
* Store the entire object as a single flat file.
17+
* Reads and writes operate by seeking directly within the file.
18+
* No region metadata bookkeeping; simpler but less flexible for partial updates.
19+
*/
20+
STORE_FLATTENED_SINGLE_FILE,
21+
22+
/**
23+
* Store each flattened region in its own separate file.
24+
* Enables independent file management per region.
25+
*/
26+
STORE_FLATTENED_REGION_PER_FILE
27+
} pdc_region_writeout_strategy;
28+
629
typedef struct transfer_request_all_data {
730
uint64_t **obj_dims;
831
uint64_t **remote_offset;
932
uint64_t **remote_length;
10-
pdcid_t * obj_id;
11-
int * obj_ndim;
12-
size_t * unit;
13-
int * remote_ndim;
14-
char ** data_buf;
33+
pdcid_t *obj_id;
34+
int *obj_ndim;
35+
size_t *unit;
36+
int *remote_ndim;
37+
char **data_buf;
1538
int n_objs;
1639
} transfer_request_all_data;
1740

1841
typedef struct pdc_transfer_request_status {
1942
hg_handle_t handle;
2043
uint64_t transfer_request_id;
2144
uint32_t status;
22-
int * handle_ref;
45+
int *handle_ref;
2346
int out_type;
2447
struct pdc_transfer_request_status *next;
2548
} pdc_transfer_request_status;

0 commit comments

Comments
 (0)