Skip to content

Commit e08d826

Browse files
houjunjeanbezTheAssembler1
authored
Fix restart issue (#228)
* Fix cache flush (#226) * Fix a thread race issue that may cause memory error when larger than cache max size data is transferred * Add a test that writes more data than server cache size * Fix CI run command * Fix restart issue * Update nersc.yml (#238) * Since PDCinit returns a uint64_t, 0 should indicate failure (#233) Co-authored-by: Jean Luca Bez <[email protected]> * Check the return value of `PDC_Client_init` in `PDC_init` (#230) * Check that return value of PDC_Client_init in PDC_init * Change return to 0 This will make is simpler when merging #233 (comment) --------- Co-authored-by: Jean Luca Bez <[email protected]> * Change `printf` to PDC logger (#232) * Changed all printf to use pdc logger Also removed large blocks of comments and chanegd the pdc logger to print the file name, function, and line number. * Change typo of LOG_INFO to LOG_ERROR * Correct grammar from fail -> failed * update grammer succesfully close -> successfully closed * switch type of LOG_INFO to LOG_ERROR * Add logging docs and fix some LOG_INFO->LOG_JUST_PRINT * update clang formatting --------- Co-authored-by: Jean Luca Bez <[email protected]> * Malloc correct size for pdc_obj_metadata_pkg (#237) Co-authored-by: Jean Luca Bez <[email protected]> * PDCregion_transfer_create validate client buf, local region, and remote regions (#236) Co-authored-by: Jean Luca Bez <[email protected]> --------- Co-authored-by: Jean Luca Bez <[email protected]> Co-authored-by: Noah Lewis <[email protected]>
1 parent abaf753 commit e08d826

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/server/pdc_server.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -957,6 +957,9 @@ PDC_Server_init(int port, hg_class_t **hg_class, hg_context_t **hg_context)
957957
LOG_INFO("==PDC_SERVER[%d]: Read cache enabled!\n", pdc_server_rank_g);
958958
#endif
959959

960+
// Initialize IDIOMS
961+
PDC_Server_metadata_index_init(pdc_server_size_g, pdc_server_rank_g);
962+
960963
// TODO: support restart with different number of servers than previous run
961964
char checkpoint_file[ADDR_MAX + sizeof(int) + 1];
962965
if (is_restart_g == 1) {
@@ -995,9 +998,6 @@ PDC_Server_init(int port, hg_class_t **hg_class, hg_context_t **hg_context)
995998

996999
n_metadata_g = 0;
9971000

998-
// Initialize IDIOMS
999-
PDC_Server_metadata_index_init(pdc_server_size_g, pdc_server_rank_g);
1000-
10011001
// PDC transfer_request infrastructures
10021002
PDC_server_transfer_request_init();
10031003
#ifdef PDC_SERVER_CACHE

0 commit comments

Comments
 (0)