Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
9900202
Integrate BULKI serializer to save and restore server checkpoints
biqar Feb 25, 2026
0a53f02
Add code to test metadata checkpointing
biqar Feb 27, 2026
5430beb
Refactor kvtag add/get/verify test code
biqar Feb 27, 2026
602c5e6
Add bulki-based new transfer request metadata query for checkpointing
biqar Mar 17, 2026
050a723
Update call to bulki serialization and de-serialization directly to a…
biqar Mar 17, 2026
7efb945
Refactor bulki-based checkpointing integration in pdc-server
biqar Mar 17, 2026
684bf32
Refactor kvtag-get-verify test code
biqar Mar 17, 2026
389273a
Merge branch 'develop' into feature_metadata-serialization
jeanbez Mar 17, 2026
2c92c0b
Refactor code
biqar Mar 18, 2026
f1ce9f9
Merge remote-tracking branch 'origin/feature_metadata-serialization' …
biqar Mar 18, 2026
65c546f
Committing clang-format changes
github-actions[bot] Mar 26, 2026
ca6b636
Move the bulki logs under build preprocessor
biqar Mar 26, 2026
b995ac8
Add timer log for server restart
biqar Mar 26, 2026
0b76afc
Fix issue in printing server close time
biqar Mar 26, 2026
c9265b9
Merge remote-tracking branch 'origin/feature_metadata-serialization' …
biqar Mar 26, 2026
bfceb4a
Merge branch 'develop' into feature_metadata-serialization
biqar Mar 26, 2026
0fac8be
Merge branch 'develop' into feature_metadata-serialization
jeanbez May 13, 2026
08bff24
Fix log level to report the total checkpoint time
biqar May 15, 2026
fe12777
Merge remote-tracking branch 'origin/feature_metadata-serialization' …
biqar May 15, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions src/api/close_server.c
Original file line number Diff line number Diff line change
Expand Up @@ -42,18 +42,20 @@ main(int argc, char *argv[])
int rank;
double start;
MPI_Init(&argc, &argv);

#endif
pdc = PDCinit("pdc");
#ifdef ENABLE_MPI
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
start = MPI_Wtime();
#endif
pdc = PDCinit("pdc");

PDC_Client_close_all_server();

if (PDCclose(pdc) < 0)
LOG_ERROR("Failed to close PDC\n");

#ifdef ENABLE_MPI
MPI_Barrier(MPI_COMM_WORLD);
if (!rank) {
LOG_INFO("total close time = %lf\n", MPI_Wtime() - start);
}
Expand Down
10 changes: 10 additions & 0 deletions src/commons/serde/bulki/bulki.c
Original file line number Diff line number Diff line change
Expand Up @@ -624,31 +624,41 @@ BULKI_Entity_free(BULKI_Entity *bulk_entity, int free_struct)
for (size_t i = 0; i < bulk_entity->count; i++) {
BULKI_free(&bulki_array[i], 0);
}
#ifdef BUKLI_DEBUG_LOG
LOG_INFO("Freeing bulki_array 1\n");
#endif
bulki_array = NULL;
}
else if (bulk_entity->pdc_type == PDC_BULKI_ENT && bulk_entity->data != NULL) {
BULKI_Entity *bulki_entity_array = (BULKI_Entity *)bulk_entity->data;
for (size_t i = 0; i < bulk_entity->count; i++) {
BULKI_Entity_free(&bulki_entity_array[i], 0);
}
#ifdef BUKLI_DEBUG_LOG
LOG_INFO("Freeing bulki_array 2\n");
#endif
bulki_entity_array = NULL;
}
}
else if (bulk_entity->pdc_class == PDC_CLS_ITEM) {
if (bulk_entity->pdc_type == PDC_BULKI && bulk_entity->data != NULL) {
BULKI_free((BULKI *)bulk_entity->data, 0);
bulk_entity->data = NULL;
#ifdef BUKLI_DEBUG_LOG
LOG_INFO("Freeing bulki_item 1\n");
#endif
}
}
#ifdef BUKLI_DEBUG_LOG
LOG_INFO("Freeing bulk_entity\n");
#endif
if (bulk_entity->data != NULL) {
#ifdef BUKLI_DEBUG_LOG
LOG_INFO(
"bulki_entity->class: %d, bulki_entity->class: %d, bulki_entity->data: %p, bulki_entity: "
"%p\n",
bulk_entity->pdc_class, bulk_entity->pdc_type, bulk_entity->data, bulk_entity);
#endif
bulk_entity->data = (void *)PDC_free(bulk_entity->data);
bulk_entity->data = NULL;
}
Expand Down
Loading
Loading