diff --git a/examples/c/ADM_cancel_transfer.c b/examples/c/ADM_cancel_transfer.c index fb921deda24d4cb5ad65164cf336e71bb76b0a8e..806033118de5764719c6e85ff37f7d97c3804ad7 100644 --- a/examples/c/ADM_cancel_transfer.c +++ b/examples/c/ADM_cancel_transfer.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_connect_data_operation.c b/examples/c/ADM_connect_data_operation.c index d47ffa0a8d7a0144a1df735336df3327f723284e..f9bf1eb3662b41be5240dca4c3dd473b76139e77 100644 --- a/examples/c/ADM_connect_data_operation.c +++ b/examples/c/ADM_connect_data_operation.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_define_data_operation.c b/examples/c/ADM_define_data_operation.c index cc63b0912012913502a95b771962592297292284..19d2939e20e729b2349ab6366bba0151dc468130 100644 --- a/examples/c/ADM_define_data_operation.c +++ b/examples/c/ADM_define_data_operation.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_deploy_adhoc_storage.c b/examples/c/ADM_deploy_adhoc_storage.c index ef77fb0bd4ed2c958d0ca1647bdf6a31fb67644a..1cfd70b9a16a7cc6ae539df20ff60e667a3186fc 100644 --- a/examples/c/ADM_deploy_adhoc_storage.c +++ b/examples/c/ADM_deploy_adhoc_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include "common.h" #define NADHOC_NODES 25 diff --git a/examples/c/ADM_finalize_data_operation.c b/examples/c/ADM_finalize_data_operation.c index 62dd9c34994890f43ff3db65bf3faea84f6345c3..39b311553adb4458126de2f616c55d93368ac7e5 100644 --- a/examples/c/ADM_finalize_data_operation.c +++ b/examples/c/ADM_finalize_data_operation.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_get_pending_transfers.c b/examples/c/ADM_get_pending_transfers.c index 26ea286ad3959189aa9515bc654eac2091f1b7f7..7d4ba51c5d3675b30aff4ade11c7dedbe669bcc4 100644 --- a/examples/c/ADM_get_pending_transfers.c +++ b/examples/c/ADM_get_pending_transfers.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_get_qos_constraints.c b/examples/c/ADM_get_qos_constraints.c index f1b15b83f084cd950eeec661d5762dbda8a068a0..9bcb3abcb54b2b7a15071baeec52b81171286135 100644 --- a/examples/c/ADM_get_qos_constraints.c +++ b/examples/c/ADM_get_qos_constraints.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_get_statistics.c b/examples/c/ADM_get_statistics.c index fcec8a87f185240cf70ce96ad0051cd2bc6869d8..47b299681d74127c5dd2eabc2a0b3a588a3f43c3 100644 --- a/examples/c/ADM_get_statistics.c +++ b/examples/c/ADM_get_statistics.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_get_transfer_priority.c b/examples/c/ADM_get_transfer_priority.c index 3ed3b1aeaabebe7dc48ef4a7f552dd2ad66eea65..adad64834dd20356969206b2da01185572ea74e4 100644 --- a/examples/c/ADM_get_transfer_priority.c +++ b/examples/c/ADM_get_transfer_priority.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_link_transfer_to_data_operation.c b/examples/c/ADM_link_transfer_to_data_operation.c index 348d54ffe01fe3eba5ca75473580a225791ac77f..7595b926512fec676dd59ab177272f34fda109d5 100644 --- a/examples/c/ADM_link_transfer_to_data_operation.c +++ b/examples/c/ADM_link_transfer_to_data_operation.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_ping.c b/examples/c/ADM_ping.c index 0140a9d1df80af7cb9e71440843632570ae4a8e5..a197642f7dcf986d8844f701c1df73609ffee507 100644 --- a/examples/c/ADM_ping.c +++ b/examples/c/ADM_ping.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include int diff --git a/examples/c/ADM_register_adhoc_storage.c b/examples/c/ADM_register_adhoc_storage.c index 756f2f7c1baa2fd2f0cf40ba8b6454f75138801b..9ffef223046b4f9a7e09d921e4b0bb108e8dd3e0 100644 --- a/examples/c/ADM_register_adhoc_storage.c +++ b/examples/c/ADM_register_adhoc_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include "common.h" #define NADHOC_NODES 25 diff --git a/examples/c/ADM_register_job.c b/examples/c/ADM_register_job.c index 2ee75d15a294ec4df6b8424038e5b201bf724c9e..7105607a04be7009ca01bf8a6c108ddb3671ce67 100644 --- a/examples/c/ADM_register_job.c +++ b/examples/c/ADM_register_job.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include "common.h" #define NJOB_NODES 50 diff --git a/examples/c/ADM_register_pfs_storage.c b/examples/c/ADM_register_pfs_storage.c index 5b65a411c90761c9b4bc3fe577d6b5e9ea584805..8510bfc373e721776595a58525a68cee7e9d6962 100644 --- a/examples/c/ADM_register_pfs_storage.c +++ b/examples/c/ADM_register_pfs_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include int main(int argc, char* argv[]) { diff --git a/examples/c/ADM_remove_adhoc_storage.c b/examples/c/ADM_remove_adhoc_storage.c index d8c1bbce2d4b596c770e8a6a7894d0177cefd064..5d0834413b0b1b81167c0cd59c1bc6d16164421b 100644 --- a/examples/c/ADM_remove_adhoc_storage.c +++ b/examples/c/ADM_remove_adhoc_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include "common.h" #define NADHOC_NODES 25 diff --git a/examples/c/ADM_remove_job.c b/examples/c/ADM_remove_job.c index 826e950f7a2f205f61cd57b1a224e4d65914229f..e95aeb55072968d7429893077850635958072673 100644 --- a/examples/c/ADM_remove_job.c +++ b/examples/c/ADM_remove_job.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_remove_pfs_storage.c b/examples/c/ADM_remove_pfs_storage.c index 8f0ab302e1128ae72b44ff49c4febca99f97c454..d2bc0017e46b406062a4167a0c50c838c6df329b 100644 --- a/examples/c/ADM_remove_pfs_storage.c +++ b/examples/c/ADM_remove_pfs_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include int diff --git a/examples/c/ADM_set_dataset_information.c b/examples/c/ADM_set_dataset_information.c index a04735a7af1effc05f9b1218e0db13312b8b32de..21aa11c556603ed7ce3759d6ef6d5e50dac13838 100644 --- a/examples/c/ADM_set_dataset_information.c +++ b/examples/c/ADM_set_dataset_information.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_set_io_resources.c b/examples/c/ADM_set_io_resources.c index 6b6c6f48fc0200a14dac0db7e17d94081847e7bc..8161aa0bb5b0c7347776654df72c242fe672cd5b 100644 --- a/examples/c/ADM_set_io_resources.c +++ b/examples/c/ADM_set_io_resources.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_set_qos_constraints.c b/examples/c/ADM_set_qos_constraints.c index b82941e27194585f65e60dd0c73e23a917ca411a..f3b6a40f2f8420d3e55ef59eb22807fd059997d8 100644 --- a/examples/c/ADM_set_qos_constraints.c +++ b/examples/c/ADM_set_qos_constraints.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_set_transfer_priority.c b/examples/c/ADM_set_transfer_priority.c index dc13d14dbf6a847c9c9199232cfee9fafd340c75..fbb71729923ea91eea334c48450fe5e003f2da3f 100644 --- a/examples/c/ADM_set_transfer_priority.c +++ b/examples/c/ADM_set_transfer_priority.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_transfer_datasets.c b/examples/c/ADM_transfer_datasets.c index d0be9ed425dde7236d4cbd42bfd38bdad8c28cd9..6f08030235dbca220ef79ddbe7fcedffebb66fce 100644 --- a/examples/c/ADM_transfer_datasets.c +++ b/examples/c/ADM_transfer_datasets.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_update_adhoc_storage.c b/examples/c/ADM_update_adhoc_storage.c index 89bd47380fe070fc2a01037770c6edce2df93f97..ee74f4993c200d4e207bf8b8107d9ce6a27e83d5 100644 --- a/examples/c/ADM_update_adhoc_storage.c +++ b/examples/c/ADM_update_adhoc_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include "common.h" #define NADHOC_NODES 25 diff --git a/examples/c/ADM_update_job.c b/examples/c/ADM_update_job.c index 18fdb7d61968848debe39ffd1c24215011843e0d..5e7377be2f0379d4eaa638cfae0b37c4372306b2 100644 --- a/examples/c/ADM_update_job.c +++ b/examples/c/ADM_update_job.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include #include "common.h" diff --git a/examples/c/ADM_update_pfs_storage.c b/examples/c/ADM_update_pfs_storage.c index 55b369d641604fb1eebb772ec16b2d69cbe72287..95aea01cdf943cb98d4eb5e1cb51609896dba29d 100644 --- a/examples/c/ADM_update_pfs_storage.c +++ b/examples/c/ADM_update_pfs_storage.c @@ -24,7 +24,7 @@ #include #include -#include +#include #include int diff --git a/examples/c/CMakeLists.txt b/examples/c/CMakeLists.txt index 4db1d89d3c715e4162a7693f34742ca97037f8cb..d9c9d94868505964164bf63bf50b4c41e3abfdee 100644 --- a/examples/c/CMakeLists.txt +++ b/examples/c/CMakeLists.txt @@ -52,7 +52,7 @@ target_link_libraries(c_examples_common common::api::types) foreach(example IN LISTS examples_c) add_executable(${example}_c) target_sources(${example}_c PRIVATE ${example}.c) - target_link_libraries(${example}_c PUBLIC adm_iosched c_examples_common) + target_link_libraries(${example}_c PUBLIC libscord c_examples_common) set_target_properties(${example}_c PROPERTIES OUTPUT_NAME ${example}) endforeach() diff --git a/examples/c/common.c b/examples/c/common.c index 19c7ece29fb6b1b6ca769ff85826b92c53eb08a7..eaeae2b571d8495a574ad3ec57e5c321d2694dfb 100644 --- a/examples/c/common.c +++ b/examples/c/common.c @@ -3,7 +3,6 @@ #include #include "common.h" -#include "admire_types.h" ADM_node_t* prepare_nodes(size_t n) { diff --git a/examples/c/common.h b/examples/c/common.h index 92f0d9c1793a87fcbaa6dcb6ca719516816932ab..0aeab9c92e388c8e0c8fb52b176e413053a7b193 100644 --- a/examples/c/common.h +++ b/examples/c/common.h @@ -1,7 +1,7 @@ #ifndef SCORD_C_EXAMPLES_COMMON_H #define SCORD_C_EXAMPLES_COMMON_H -#include +#include ADM_node_t* prepare_nodes(size_t n); diff --git a/examples/cxx/ADM_cancel_transfer.cpp b/examples/cxx/ADM_cancel_transfer.cpp index 4543974f99bababf96c4014ba25d6a79bf9b783d..1abff9ca24d7511e339a18f477dac2b87b5cbe6e 100644 --- a/examples/cxx/ADM_cancel_transfer.cpp +++ b/examples/cxx/ADM_cancel_transfer.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -35,14 +35,14 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_transfer_t tx{}; ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::cancel_transfer(server, job, tx); + ret = scord::cancel_transfer(server, job, tx); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_cancel_transfer() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_connect_data_operation.cpp b/examples/cxx/ADM_connect_data_operation.cpp index 62614f9285521ce800c988fbe9917453ab09a648..5ff68267834cfa56691f29726ea60650ed96882b 100644 --- a/examples/cxx/ADM_connect_data_operation.cpp +++ b/examples/cxx/ADM_connect_data_operation.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int main(int argc, char* argv[]) { @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_t input{}; @@ -45,8 +45,8 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::connect_data_operation(server, job, input, output, - should_stream, args); + ret = scord::connect_data_operation(server, job, input, output, + should_stream, args); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_connect_data_operation() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_define_data_operation.cpp b/examples/cxx/ADM_define_data_operation.cpp index 1d2a0297363c79cd7ed894415039f0044663f22a..bf087508b244b9daa5de31b5512c954e6b8e8524 100644 --- a/examples/cxx/ADM_define_data_operation.cpp +++ b/examples/cxx/ADM_define_data_operation.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,7 +36,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; const char* path = "/tmpxxxxx"; @@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::define_data_operation(server, job, path, &op, args); + ret = scord::define_data_operation(server, job, path, &op, args); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_define_data_operation() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_deploy_adhoc_storage.cpp b/examples/cxx/ADM_deploy_adhoc_storage.cpp index ccfc76c14c5b4473d471d118eda75be9a4cc14c1..d7a34f302897497f77367e3ff15689f7ca76d788 100644 --- a/examples/cxx/ADM_deploy_adhoc_storage.cpp +++ b/examples/cxx/ADM_deploy_adhoc_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -41,28 +41,28 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); const auto inputs = prepare_datasets("input-dataset-{}", NINPUTS); const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::dataclay, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::dataclay, adhoc_storage_ctx); fmt::print(stdout, "ADM_register_adhoc_storage() remote procedure completed " "successfully\n"); - admire::deploy_adhoc_storage(server, adhoc_storage); + scord::deploy_adhoc_storage(server, adhoc_storage); } catch(const std::exception& e) { fmt::print(stderr, diff --git a/examples/cxx/ADM_finalize_data_operation.cpp b/examples/cxx/ADM_finalize_data_operation.cpp index c3eab90cb65330e23f348e2e4495751344695504..147ae68664c1ed78b57dc2b50dde2258181b125b 100644 --- a/examples/cxx/ADM_finalize_data_operation.cpp +++ b/examples/cxx/ADM_finalize_data_operation.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int main(int argc, char* argv[]) { @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_data_operation_t op{}; @@ -43,7 +43,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::finalize_data_operation(server, job, op, &status); + ret = scord::finalize_data_operation(server, job, op, &status); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_finalize_data_operation() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_get_pending_transfers.cpp b/examples/cxx/ADM_get_pending_transfers.cpp index 4d3c69f5fa7c6e054a42bec6ec92c5cd7fde0c7d..f60be4b2ead9e643624e7732564464c557417fce 100644 --- a/examples/cxx/ADM_get_pending_transfers.cpp +++ b/examples/cxx/ADM_get_pending_transfers.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,14 +36,14 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_transfer_t** tx = nullptr; ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::get_pending_transfers(server, job, tx); + ret = scord::get_pending_transfers(server, job, tx); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_get_pending_transfers() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_get_qos_constraints.cpp b/examples/cxx/ADM_get_qos_constraints.cpp index c1828aa46efcda74f096b04c911a4b5dc3139610..ba34766c8e117e37cf806888f8ebb16e25087f62 100644 --- a/examples/cxx/ADM_get_qos_constraints.cpp +++ b/examples/cxx/ADM_get_qos_constraints.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_qos_entity_t entity{}; @@ -43,7 +43,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::get_qos_constraints(server, job, entity, &limits); + ret = scord::get_qos_constraints(server, job, entity, &limits); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_cancel_transfer() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_get_statistics.cpp b/examples/cxx/ADM_get_statistics.cpp index b3c78675240aa188f7be55e7336b84e07c7c5f2b..cb8c0cdc720e1779afa9ad275f445cf00ea3d047 100644 --- a/examples/cxx/ADM_get_statistics.cpp +++ b/examples/cxx/ADM_get_statistics.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int main(int argc, char* argv[]) { @@ -34,14 +34,14 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_job_stats_t* stats = nullptr; ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::get_statistics(server, job, &stats); + ret = scord::get_statistics(server, job, &stats); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_cancel_transfer() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_get_transfer_priority.cpp b/examples/cxx/ADM_get_transfer_priority.cpp index 8fef9925adc2a3ac8c70b683fa31b7928c290aa2..7dbd585b91eb93b5f2dcbbed2e721b422debf71d 100644 --- a/examples/cxx/ADM_get_transfer_priority.cpp +++ b/examples/cxx/ADM_get_transfer_priority.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,7 +36,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_transfer_t tx{}; @@ -44,7 +44,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::get_transfer_priority(server, job, tx, &priority); + ret = scord::get_transfer_priority(server, job, tx, &priority); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_get_transfer_priority() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_link_transfer_to_data_operation.cpp b/examples/cxx/ADM_link_transfer_to_data_operation.cpp index 8ebb02c39d7007630583a4cabf0f61261eb0700b..9c993c08af15db4d4a986cac1df2001af5905381 100644 --- a/examples/cxx/ADM_link_transfer_to_data_operation.cpp +++ b/examples/cxx/ADM_link_transfer_to_data_operation.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int main(int argc, char* argv[]) { @@ -36,7 +36,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_data_operation_t op{}; @@ -46,8 +46,8 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::link_transfer_to_data_operation(server, job, op, transfer, - should_stream, args); + ret = scord::link_transfer_to_data_operation(server, job, op, transfer, + should_stream, args); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_cancel_transfer() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_ping.cpp b/examples/cxx/ADM_ping.cpp index d687e60f11c106be87507880964a163c7705916a..8570c17baadd6e4607098227f8d83841c0270e93 100644 --- a/examples/cxx/ADM_ping.cpp +++ b/examples/cxx/ADM_ping.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int main(int argc, char* argv[]) { @@ -34,10 +34,10 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; try { - admire::ping(server); + scord::ping(server); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_ping() failed: {}\n", e.what()); exit(EXIT_FAILURE); diff --git a/examples/cxx/ADM_register_adhoc_storage.cpp b/examples/cxx/ADM_register_adhoc_storage.cpp index 4b00c3d44f3d61c2ed9e06aeb2d2408bb887e0e3..894ccd92a4efd296ca53284730bf6d5698862252 100644 --- a/examples/cxx/ADM_register_adhoc_storage.cpp +++ b/examples/cxx/ADM_register_adhoc_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -41,21 +41,21 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); const auto inputs = prepare_datasets("input-dataset-{}", NINPUTS); const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); fmt::print(stdout, diff --git a/examples/cxx/ADM_register_job.cpp b/examples/cxx/ADM_register_job.cpp index a016ea2f6fa82fdf6ab9096f6945c04200f07d04..b9621752d956829568cdcab0b4f68f1a80e451e6 100644 --- a/examples/cxx/ADM_register_job.cpp +++ b/examples/cxx/ADM_register_job.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -40,7 +40,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto job_nodes = prepare_nodes(NJOB_NODES); const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); @@ -48,21 +48,21 @@ main(int argc, char* argv[]) { const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); - admire::job_requirements reqs(inputs, outputs, adhoc_storage); + scord::job_requirements reqs(inputs, outputs, adhoc_storage); - [[maybe_unused]] const auto job = admire::register_job( - server, admire::job::resources{job_nodes}, reqs, 0); + [[maybe_unused]] const auto job = scord::register_job( + server, scord::job::resources{job_nodes}, reqs, 0); // do something with job diff --git a/examples/cxx/ADM_register_pfs_storage.cpp b/examples/cxx/ADM_register_pfs_storage.cpp index b3ad5e47419ccbd3e01442b0378c0f3ab4bd720c..712409dc1d287ccbd438180da46365f27b0aaa39 100644 --- a/examples/cxx/ADM_register_pfs_storage.cpp +++ b/examples/cxx/ADM_register_pfs_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,15 +36,15 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; std::string pfs_name = "gpfs_scratch"; std::string pfs_mount = "/gpfs/scratch"; try { - admire::register_pfs_storage(server, pfs_name, - admire::pfs_storage::type::gpfs, - admire::pfs_storage::ctx{pfs_mount}); + scord::register_pfs_storage(server, pfs_name, + scord::pfs_storage::type::gpfs, + scord::pfs_storage::ctx{pfs_mount}); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_register_pfs_storage() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_remove_adhoc_storage.cpp b/examples/cxx/ADM_remove_adhoc_storage.cpp index a9714cc3b5be3017ce874beb76ba0454bc593009..a804e41812e65341a651e3276af35a6c93d8c284 100644 --- a/examples/cxx/ADM_remove_adhoc_storage.cpp +++ b/examples/cxx/ADM_remove_adhoc_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -41,23 +41,23 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); const auto inputs = prepare_datasets("input-dataset-{}", NINPUTS); const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); - admire::remove_adhoc_storage(server, adhoc_storage); + scord::remove_adhoc_storage(server, adhoc_storage); fmt::print(stdout, "ADM_remove_adhoc_storage() remote procedure completed " "successfully\n"); diff --git a/examples/cxx/ADM_remove_job.cpp b/examples/cxx/ADM_remove_job.cpp index 1320946fb85e081649a1c3233b0ace9310555783..f4f4100f273011b5fc641a67938d5ccc4302d30c 100644 --- a/examples/cxx/ADM_remove_job.cpp +++ b/examples/cxx/ADM_remove_job.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -40,7 +40,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto job_nodes = prepare_nodes(NJOB_NODES); const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); @@ -48,28 +48,28 @@ main(int argc, char* argv[]) { const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); - admire::job_requirements reqs(inputs, outputs, adhoc_storage); + scord::job_requirements reqs(inputs, outputs, adhoc_storage); - [[maybe_unused]] const auto job = admire::register_job( - server, admire::job::resources{job_nodes}, reqs, 0); + [[maybe_unused]] const auto job = scord::register_job( + server, scord::job::resources{job_nodes}, reqs, 0); // do something with job fmt::print(stdout, "ADM_register_job() remote procedure completed " "successfully\n"); - admire::remove_job(server, job); + scord::remove_job(server, job); fmt::print(stdout, "ADM_remove_job() remote procedure completed " "successfully\n"); diff --git a/examples/cxx/ADM_remove_pfs_storage.cpp b/examples/cxx/ADM_remove_pfs_storage.cpp index d03833a4c795f2ef9e21048b9c244e356ba3d3fd..c2cdaeec2247e8f13e387e05c18f3c6d7d5e73dc 100644 --- a/examples/cxx/ADM_remove_pfs_storage.cpp +++ b/examples/cxx/ADM_remove_pfs_storage.cpp @@ -22,8 +22,8 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#include "fmt/format.h" -#include "admire.hpp" +#include +#include int @@ -35,17 +35,17 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; std::string pfs_name = "gpfs_scratch"; std::string pfs_mount = "/gpfs/scratch"; try { - const auto pfs_storage = admire::register_pfs_storage( - server, pfs_name, admire::pfs_storage::type::gpfs, - admire::pfs_storage::ctx{pfs_mount}); + const auto pfs_storage = scord::register_pfs_storage( + server, pfs_name, scord::pfs_storage::type::gpfs, + scord::pfs_storage::ctx{pfs_mount}); - admire::remove_pfs_storage(server, pfs_storage); + scord::remove_pfs_storage(server, pfs_storage); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_register_pfs_storage() or " diff --git a/examples/cxx/ADM_set_dataset_information.cpp b/examples/cxx/ADM_set_dataset_information.cpp index 3d1ac5ba7df4e3e58b1761e335d355d64f8da67c..9f7b7d33f519a248ccffc4b0f2cfd415c18f62a1 100644 --- a/examples/cxx/ADM_set_dataset_information.cpp +++ b/examples/cxx/ADM_set_dataset_information.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,7 +36,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_t target{}; @@ -44,7 +44,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::set_dataset_information(server, job, target, info); + ret = scord::set_dataset_information(server, job, target, info); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_set_dataset_information() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_set_io_resources.cpp b/examples/cxx/ADM_set_io_resources.cpp index ab9108a4c80d3172028099bb066e94015ce06d43..c36f2c65c9739eb34fd05101170a6368a75a8ad1 100644 --- a/examples/cxx/ADM_set_io_resources.cpp +++ b/examples/cxx/ADM_set_io_resources.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_adhoc_storage_t tier{}; @@ -43,7 +43,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::set_io_resources(server, job, tier, resources); + ret = scord::set_io_resources(server, job, tier, resources); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_set_io_resources() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_set_qos_constraints.cpp b/examples/cxx/ADM_set_qos_constraints.cpp index 3b3f84fe44406033a5073fb3dcc98fd0690aacba..65b798f12fcb07996a744e8ad232d3762af8b8c5 100644 --- a/examples/cxx/ADM_set_qos_constraints.cpp +++ b/examples/cxx/ADM_set_qos_constraints.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_qos_entity_t entity{}; @@ -43,7 +43,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::set_qos_constraints(server, job, entity, limit); + ret = scord::set_qos_constraints(server, job, entity, limit); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_set_qos_constraints() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_set_transfer_priority.cpp b/examples/cxx/ADM_set_transfer_priority.cpp index f9fe2e69f714cfba409afa600e9be78c6d307b06..040cde0e5dc70d80290aaa604e3150406ef97705 100644 --- a/examples/cxx/ADM_set_transfer_priority.cpp +++ b/examples/cxx/ADM_set_transfer_priority.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -36,7 +36,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_transfer_t tx{}; @@ -44,7 +44,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { - ret = admire::set_transfer_priority(server, job, tx, incr); + ret = scord::set_transfer_priority(server, job, tx, incr); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_set_transfer_priority() failed: {}\n", e.what()); diff --git a/examples/cxx/ADM_transfer_datasets.cpp b/examples/cxx/ADM_transfer_datasets.cpp index efd6214497fc07435fc9d67a45dfacb281318972..393c3e390e0344121e5b0e2a997cca6ea03b424e 100644 --- a/examples/cxx/ADM_transfer_datasets.cpp +++ b/examples/cxx/ADM_transfer_datasets.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -43,7 +43,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto job_nodes = prepare_nodes(NJOB_NODES); const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); @@ -53,24 +53,24 @@ main(int argc, char* argv[]) { const auto sources = prepare_datasets("source-dataset-{}", NSOURCES); const auto targets = prepare_datasets("target-dataset-{}", NTARGETS); const auto qos_limits = prepare_qos_limits(NLIMITS); - const auto mapping = admire::transfer::mapping::n_to_n; + const auto mapping = scord::transfer::mapping::n_to_n; std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); - admire::job_requirements reqs(inputs, outputs, adhoc_storage); + scord::job_requirements reqs(inputs, outputs, adhoc_storage); - const auto job = admire::register_job( - server, admire::job::resources{job_nodes}, reqs, 0); - const auto transfer = admire::transfer_datasets( + const auto job = scord::register_job( + server, scord::job::resources{job_nodes}, reqs, 0); + const auto transfer = scord::transfer_datasets( server, job, sources, targets, qos_limits, mapping); fmt::print(stdout, "ADM_transfer_datasets() remote procedure completed " diff --git a/examples/cxx/ADM_update_adhoc_storage.cpp b/examples/cxx/ADM_update_adhoc_storage.cpp index 54b6033b7345cf0a1111b91dd698690116774fdb..62c3a93a39e94682dbc353894e322fd9960dce0c 100644 --- a/examples/cxx/ADM_update_adhoc_storage.cpp +++ b/examples/cxx/ADM_update_adhoc_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NADHOC_NODES 25 @@ -40,7 +40,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto adhoc_nodes = prepare_nodes(NADHOC_NODES); const auto new_adhoc_nodes = prepare_nodes(NADHOC_NODES * 2); @@ -48,23 +48,23 @@ main(int argc, char* argv[]) { const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); std::string name = "adhoc_storage_42"; - const auto adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}; + const auto adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}; - const auto new_adhoc_storage_ctx = admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{new_adhoc_nodes}, 200, false}; + const auto new_adhoc_storage_ctx = scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{new_adhoc_nodes}, 200, false}; try { - const auto adhoc_storage = admire::register_adhoc_storage( - server, name, admire::adhoc_storage::type::gekkofs, + const auto adhoc_storage = scord::register_adhoc_storage( + server, name, scord::adhoc_storage::type::gekkofs, adhoc_storage_ctx); - admire::update_adhoc_storage(server, adhoc_storage, - new_adhoc_storage_ctx); + scord::update_adhoc_storage(server, adhoc_storage, + new_adhoc_storage_ctx); fmt::print(stdout, "ADM_update_adhoc_storage() remote procedure completed " diff --git a/examples/cxx/ADM_update_job.cpp b/examples/cxx/ADM_update_job.cpp index 1d8152f69abe4a9a8da1cd475489b9fa62b73ca8..cf837e2bc32c2e97c4db98e7e9bf754a61120106 100644 --- a/examples/cxx/ADM_update_job.cpp +++ b/examples/cxx/ADM_update_job.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include "common.hpp" #define NJOB_NODES 50 @@ -40,7 +40,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; const auto job_nodes = prepare_nodes(NJOB_NODES); const auto new_job_nodes = prepare_nodes(NJOB_NODES * 2); @@ -48,24 +48,24 @@ main(int argc, char* argv[]) { const auto inputs = prepare_datasets("input-dataset-{}", NINPUTS); const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS); - const auto gkfs_storage = admire::register_adhoc_storage( - server, "foobar", admire::adhoc_storage::type::gekkofs, - admire::adhoc_storage::ctx{ - admire::adhoc_storage::execution_mode::separate_new, - admire::adhoc_storage::access_type::read_write, - admire::adhoc_storage::resources{adhoc_nodes}, 100, false}); + const auto gkfs_storage = scord::register_adhoc_storage( + server, "foobar", scord::adhoc_storage::type::gekkofs, + scord::adhoc_storage::ctx{ + scord::adhoc_storage::execution_mode::separate_new, + scord::adhoc_storage::access_type::read_write, + scord::adhoc_storage::resources{adhoc_nodes}, 100, false}); - admire::job_requirements reqs{inputs, outputs, gkfs_storage}; + scord::job_requirements reqs{inputs, outputs, gkfs_storage}; const auto new_inputs = prepare_datasets("input-new-dataset-{}", NINPUTS); const auto new_outputs = prepare_datasets("output-new-dataset-{}", NOUTPUTS); try { - [[maybe_unused]] const auto job = admire::register_job( - server, admire::job::resources{job_nodes}, reqs, 0); + [[maybe_unused]] const auto job = scord::register_job( + server, scord::job::resources{job_nodes}, reqs, 0); - admire::update_job(server, job, admire::job::resources{new_job_nodes}); + scord::update_job(server, job, scord::job::resources{new_job_nodes}); fmt::print( stdout, diff --git a/examples/cxx/ADM_update_pfs_storage.cpp b/examples/cxx/ADM_update_pfs_storage.cpp index 6a090a6c26d8fd6e6235dc055711de1903df075d..74fea88b54c0df55286dd25c28d7e0aaa3e1e5ff 100644 --- a/examples/cxx/ADM_update_pfs_storage.cpp +++ b/examples/cxx/ADM_update_pfs_storage.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include int @@ -35,7 +35,7 @@ main(int argc, char* argv[]) { exit(EXIT_FAILURE); } - admire::server server{"tcp", argv[1]}; + scord::server server{"tcp", argv[1]}; std::string pfs_name = "gpfs_scratch"; std::string pfs_mount = "/gpfs/scratch"; @@ -43,12 +43,12 @@ main(int argc, char* argv[]) { try { - const auto pfs_storage = admire::register_pfs_storage( - server, pfs_name, admire::pfs_storage::type::gpfs, - admire::pfs_storage::ctx{pfs_mount}); + const auto pfs_storage = scord::register_pfs_storage( + server, pfs_name, scord::pfs_storage::type::gpfs, + scord::pfs_storage::ctx{pfs_mount}); - admire::update_pfs_storage(server, pfs_storage, - admire::pfs_storage::ctx{new_pfs_mount}); + scord::update_pfs_storage(server, pfs_storage, + scord::pfs_storage::ctx{new_pfs_mount}); } catch(const std::exception& e) { fmt::print(stderr, "FATAL: ADM_update_pfs_storage() or " diff --git a/examples/cxx/CMakeLists.txt b/examples/cxx/CMakeLists.txt index 24d14c57b03db4b9f4a41c88b651b9b2a8cd2c4e..a06c06b3e4014fa966201144ed4b4e5d9727ff5c 100644 --- a/examples/cxx/CMakeLists.txt +++ b/examples/cxx/CMakeLists.txt @@ -53,7 +53,7 @@ foreach(example IN LISTS examples_cxx) add_executable(${example}_cxx) target_sources(${example}_cxx PRIVATE ${example}.cpp) target_link_libraries(${example}_cxx - PUBLIC fmt::fmt adm_iosched cxx_examples_common) + PUBLIC fmt::fmt libscord cxx_examples_common) set_target_properties(${example}_cxx PROPERTIES OUTPUT_NAME ${example}) endforeach() diff --git a/examples/cxx/common.cpp b/examples/cxx/common.cpp index 31c57c679c2d7f45b62b8e006476ef0198e1d13f..d0acaafcf4ed24949996f57ecf5f51dd30c28fa4 100644 --- a/examples/cxx/common.cpp +++ b/examples/cxx/common.cpp @@ -1,8 +1,8 @@ #include "common.hpp" -std::vector +std::vector prepare_nodes(size_t n) { - std::vector nodes; + std::vector nodes; nodes.reserve(n); for(size_t i = 0; i < n; ++i) { nodes.emplace_back(fmt::format("node-{:02d}", i)); @@ -11,9 +11,9 @@ prepare_nodes(size_t n) { return nodes; } -std::vector +std::vector prepare_datasets(const std::string& pattern, size_t n) { - std::vector datasets; + std::vector datasets; datasets.reserve(n); for(size_t i = 0; i < n; ++i) { datasets.emplace_back(fmt::format(fmt::runtime(pattern), i)); @@ -22,14 +22,14 @@ prepare_datasets(const std::string& pattern, size_t n) { return datasets; } -std::vector +std::vector prepare_qos_limits(size_t n) { - std::vector limits; + std::vector limits; limits.reserve(n); for(size_t i = 0; i < n; ++i) { - limits.emplace_back(admire::qos::subclass::bandwidth, 50); + limits.emplace_back(scord::qos::subclass::bandwidth, 50); } return limits; diff --git a/examples/cxx/common.hpp b/examples/cxx/common.hpp index ca08c7e514124d19a676d10ce741bd8f039dce66..ee76624c23f51dc0478600766950c045a31bc212 100644 --- a/examples/cxx/common.hpp +++ b/examples/cxx/common.hpp @@ -2,15 +2,15 @@ #define SCORD_CXX_EXAMPLES_COMMON_HPP #include -#include +#include -std::vector +std::vector prepare_nodes(size_t n); -std::vector +std::vector prepare_datasets(const std::string& pattern, size_t n); -std::vector +std::vector prepare_qos_limits(size_t n); #endif // SCORD_CXX_EXAMPLES_COMMON_HPP diff --git a/src/common/api/CMakeLists.txt b/src/common/api/CMakeLists.txt index e2eb4e98ca4b6cdd60d032a39bda543220daf3d2..99d81b70b73db3ac2c745b4510d3fde8716f3685 100644 --- a/src/common/api/CMakeLists.txt +++ b/src/common/api/CMakeLists.txt @@ -24,8 +24,8 @@ add_library(_api_types STATIC) -target_sources(_api_types PUBLIC admire_types.h admire_types.hpp PRIVATE - types.cpp convert.hpp convert.cpp internal_types.hpp errors.c) +target_sources(_api_types PUBLIC scord/types.h scord/types.hpp PRIVATE + types.cpp convert.hpp convert.cpp scord/internal_types.hpp errors.c) target_include_directories(_api_types PUBLIC ${CMAKE_CURRENT_SOURCE_DIR}) @@ -33,8 +33,3 @@ target_link_libraries(_api_types PRIVATE Margo::Margo common::logger PUBLIC fmt::fmt common::abt_cxx) set_property(TARGET _api_types PROPERTY POSITION_INDEPENDENT_CODE ON) - -install( - FILES admire_types.h admire_types.hpp - DESTINATION ${CMAKE_INSTALL_INCLUDEDIR} -) diff --git a/src/common/api/convert.cpp b/src/common/api/convert.cpp index 1822695f337b86d951869f5055f79e1d93412f97..ab24eb409813153d2d54029d7c3827468a90a653 100644 --- a/src/common/api/convert.cpp +++ b/src/common/api/convert.cpp @@ -35,35 +35,35 @@ ADM_transfer_create(uint64_t id); namespace { -admire::api::managed_ctype_array -as_ctype_array(const std::vector& nodes) { +scord::api::managed_ctype_array +as_ctype_array(const std::vector& nodes) { std::vector tmp; std::transform(nodes.cbegin(), nodes.cend(), std::back_inserter(tmp), - [](const admire::node& n) { + [](const scord::node& n) { return ADM_node_create(n.hostname().c_str()); }); - return admire::api::managed_ctype_array{std::move(tmp)}; + return scord::api::managed_ctype_array{std::move(tmp)}; } -admire::api::managed_ctype_array -as_ctype_array(const std::vector& datasets) { +scord::api::managed_ctype_array +as_ctype_array(const std::vector& datasets) { std::vector tmp; std::transform(datasets.cbegin(), datasets.cend(), std::back_inserter(tmp), - [](const admire::dataset& d) { + [](const scord::dataset& d) { return ADM_dataset_create(d.id().c_str()); }); - return admire::api::managed_ctype_array{std::move(tmp)}; + return scord::api::managed_ctype_array{std::move(tmp)}; } } // namespace -namespace admire::api { +namespace scord::api { managed_ctype convert(const node& node) { @@ -97,7 +97,7 @@ convert(const adhoc_storage::ctx& ctx) { } managed_ctype -convert(const std::optional& adhoc_storage) { +convert(const std::optional& adhoc_storage) { if(!adhoc_storage) { return managed_ctype{}; @@ -107,7 +107,7 @@ convert(const std::optional& adhoc_storage) { } managed_ctype -convert(const admire::adhoc_storage& st) { +convert(const scord::adhoc_storage& st) { auto managed_ctx = convert(st.context()); ADM_adhoc_storage_t c_st = ADM_adhoc_storage_create( @@ -124,7 +124,7 @@ convert(const pfs_storage::ctx& ctx) { } managed_ctype -convert(const std::optional& pfs_storage) { +convert(const std::optional& pfs_storage) { if(!pfs_storage) { return managed_ctype{}; @@ -134,7 +134,7 @@ convert(const std::optional& pfs_storage) { } managed_ctype -convert(const admire::pfs_storage& st) { +convert(const scord::pfs_storage& st) { auto managed_ctx = convert(st.context()); ADM_pfs_storage_t c_st = ADM_pfs_storage_create( @@ -145,18 +145,18 @@ convert(const admire::pfs_storage& st) { } managed_ctype -convert(const admire::dataset& dataset) { +convert(const scord::dataset& dataset) { return managed_ctype( ADM_dataset_create(dataset.id().c_str())); } managed_ctype -convert(const std::vector& datasets) { +convert(const std::vector& datasets) { std::vector tmp; std::transform(datasets.cbegin(), datasets.cend(), std::back_inserter(tmp), - [](const admire::dataset& d) { + [](const scord::dataset& d) { return ADM_dataset_create(d.id().c_str()); }); @@ -169,10 +169,10 @@ convert(const std::vector& datasets) { return rv; } -std::vector +std::vector convert(ADM_dataset_t datasets[], size_t datasets_len) { - std::vector rv; + std::vector rv; rv.reserve(datasets_len); for(size_t i = 0; i < datasets_len; ++i) { @@ -182,10 +182,10 @@ convert(ADM_dataset_t datasets[], size_t datasets_len) { return rv; } -std::vector +std::vector convert(ADM_dataset_list_t list) { - std::vector rv; + std::vector rv; rv.reserve(list->l_length); for(size_t i = 0; i < list->l_length; ++i) { @@ -207,7 +207,7 @@ convert(const job::resources& res) { } managed_ctype -convert(const admire::job_requirements& reqs) { +convert(const scord::job_requirements& reqs) { const auto& adhoc_storage = reqs.adhoc_storage(); @@ -233,7 +233,7 @@ convert(const job& j) { job convert(ADM_job_t j) { - return admire::job{j}; + return scord::job{j}; } managed_ctype @@ -253,7 +253,7 @@ convert(const std::vector& limits) { std::transform( limits.cbegin(), limits.cend(), std::back_inserter(tmp), - [](const admire::qos::limit& l) { + [](const scord::qos::limit& l) { ADM_qos_entity_t e = nullptr; if(l.entity()) { @@ -262,7 +262,7 @@ convert(const std::vector& limits) { case qos::scope::dataset: { e = ADM_qos_entity_create( static_cast(s), - convert(l.entity()->data()) + convert(l.entity()->data()) .release()); break; } @@ -270,7 +270,7 @@ convert(const std::vector& limits) { case qos::scope::node: { e = ADM_qos_entity_create( static_cast(s), - convert(l.entity()->data()) + convert(l.entity()->data()) .release()); break; } @@ -278,7 +278,7 @@ convert(const std::vector& limits) { case qos::scope::job: { e = ADM_qos_entity_create( static_cast(s), - convert(l.entity()->data()) + convert(l.entity()->data()) .release()); break; } @@ -286,8 +286,7 @@ convert(const std::vector& limits) { case qos::scope::transfer: { e = ADM_qos_entity_create( static_cast(s), - convert(l.entity() - ->data()) + convert(l.entity()->data()) .release()); break; } @@ -311,7 +310,7 @@ convert(const std::vector& limits) { std::vector convert(ADM_qos_limit_t limits[], size_t limits_len) { - std::vector rv; + std::vector rv; rv.reserve(limits_len); for(size_t i = 0; i < limits_len; ++i) { @@ -321,10 +320,10 @@ convert(ADM_qos_limit_t limits[], size_t limits_len) { return rv; } -std::vector +std::vector convert(ADM_qos_limit_list_t list) { - std::vector rv; + std::vector rv; rv.reserve(list->l_length); for(size_t i = 0; i < list->l_length; ++i) { @@ -335,4 +334,4 @@ convert(ADM_qos_limit_list_t list) { } -} // namespace admire::api +} // namespace scord::api diff --git a/src/common/api/convert.hpp b/src/common/api/convert.hpp index 7c95b6402069a466130ea2e442ec2f3690c25cd7..db9e92f445111a8f33bb65aaa5ed436e165504d0 100644 --- a/src/common/api/convert.hpp +++ b/src/common/api/convert.hpp @@ -25,10 +25,10 @@ #ifndef SCORD_CONVERT_HPP #define SCORD_CONVERT_HPP -#include "admire_types.h" -#include "admire_types.hpp" +#include "scord/types.h" +#include "scord/types.hpp" -namespace admire::api { +namespace scord::api { // convenience types for managing the types from the C API in a RAII fashion template @@ -49,31 +49,31 @@ managed_ctype convert(const adhoc_storage::ctx& ctx); managed_ctype -convert(const admire::adhoc_storage& st); +convert(const scord::adhoc_storage& st); managed_ctype convert(const pfs_storage::ctx& ctx); managed_ctype -convert(const admire::pfs_storage& st); +convert(const scord::pfs_storage& st); managed_ctype -convert(const admire::dataset& dataset); +convert(const scord::dataset& dataset); managed_ctype -convert(const std::vector& datasets); +convert(const std::vector& datasets); -std::vector +std::vector convert(ADM_dataset_t datasets[], size_t datasets_len); -std::vector +std::vector convert(ADM_dataset_list_t list); managed_ctype convert(const job::resources& res); managed_ctype -convert(const admire::job_requirements& reqs); +convert(const scord::job_requirements& reqs); managed_ctype convert(const job& j); @@ -93,10 +93,10 @@ convert(const std::vector& limits); std::vector convert(ADM_qos_limit_t limits[], size_t limits_len); -std::vector +std::vector convert(ADM_qos_limit_list_t list); -} // namespace admire::api +} // namespace scord::api //////////////////////////////////////////////////////////////////////////////// @@ -104,7 +104,7 @@ convert(ADM_qos_limit_list_t list); //////////////////////////////////////////////////////////////////////////////// template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_node_t node) : m_node(node) {} @@ -122,7 +122,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype_array { +struct scord::api::managed_ctype_array { managed_ctype_array() = default; @@ -156,7 +156,7 @@ struct admire::api::managed_ctype_array { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { managed_ctype() = default; @@ -181,7 +181,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { managed_ctype() = default; @@ -206,7 +206,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { managed_ctype() = default; @@ -231,7 +231,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { managed_ctype() = default; @@ -252,7 +252,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { managed_ctype() = default; @@ -277,7 +277,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_dataset_t dataset) : m_dataset(dataset) {} @@ -295,7 +295,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype_array { +struct scord::api::managed_ctype_array { explicit managed_ctype_array(ADM_dataset_t* data, size_t size) : m_datasets(data, size) {} @@ -328,7 +328,7 @@ struct admire::api::managed_ctype_array { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_dataset_list_t list) : m_list(list) {} @@ -347,7 +347,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_job_resources_t res, managed_ctype_array&& nodes) @@ -369,7 +369,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_job_requirements_t reqs, managed_ctype_array&& inputs, @@ -407,7 +407,7 @@ ADM_return_t ADM_transfer_destroy(ADM_transfer_t tx); template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_job_t job) : m_job(job) {} @@ -425,7 +425,7 @@ struct admire::api::managed_ctype { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_transfer_t tx) : m_transfer(tx) {} @@ -446,7 +446,7 @@ ADM_return_t ADM_qos_limit_destroy_all(ADM_qos_limit_t l); template <> -struct admire::api::managed_ctype_array { +struct scord::api::managed_ctype_array { explicit managed_ctype_array(ADM_qos_limit_t data[], size_t size) : m_qos_limits(data, size) {} @@ -479,7 +479,7 @@ struct admire::api::managed_ctype_array { }; template <> -struct admire::api::managed_ctype { +struct scord::api::managed_ctype { explicit managed_ctype(ADM_qos_limit_list_t list) : m_list(list) {} diff --git a/src/common/api/errors.c b/src/common/api/errors.c index 19cc00ea0972ef9c0790f8d88ecda75ead40b6f0..5c4b2bd82ebb493d97dd794c4694627372f40bac 100644 --- a/src/common/api/errors.c +++ b/src/common/api/errors.c @@ -22,7 +22,7 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#include +#include "scord/types.h" const char* const adm_errlist[ADM_ERR_MAX + 1] = { [ADM_SUCCESS] = "Success", diff --git a/src/common/api/internal_types.hpp b/src/common/api/scord/internal_types.hpp similarity index 69% rename from src/common/api/internal_types.hpp rename to src/common/api/scord/internal_types.hpp index 131b2eed38b8a62b339c79ec24247b0d1ac8ab87..8d41f34b72eeda88d54763c45771b64c6b0bee77 100644 --- a/src/common/api/internal_types.hpp +++ b/src/common/api/scord/internal_types.hpp @@ -28,58 +28,58 @@ #include -namespace admire::internal { +namespace scord::internal { struct job_info { - explicit job_info(admire::job job) : m_job(std::move(job)) {} + explicit job_info(scord::job job) : m_job(std::move(job)) {} - job_info(admire::job job, admire::job::resources resources, - admire::job_requirements requirements) + job_info(scord::job job, scord::job::resources resources, + scord::job_requirements requirements) : m_job(std::move(job)), m_resources(std::move(resources)), m_requirements(std::move(requirements)) {} - admire::job + scord::job job() const { return m_job; } - std::optional + std::optional resources() const { return m_resources; } - std::optional + std::optional requirements() const { return m_requirements; } void - update(admire::job::resources resources) { + update(scord::job::resources resources) { m_resources = std::move(resources); } - admire::job m_job; - std::optional m_resources; - std::optional m_requirements; + scord::job m_job; + std::optional m_resources; + std::optional m_requirements; }; struct adhoc_storage_info { - explicit adhoc_storage_info(admire::adhoc_storage adhoc_storage) + explicit adhoc_storage_info(scord::adhoc_storage adhoc_storage) : m_adhoc_storage(std::move(adhoc_storage)) {} - admire::adhoc_storage + scord::adhoc_storage adhoc_storage() const { return m_adhoc_storage; } void - update(admire::adhoc_storage::ctx adhoc_context) { + update(scord::adhoc_storage::ctx adhoc_context) { m_adhoc_storage.update(std::move(adhoc_context)); } - admire::error_code - add_client_info(std::shared_ptr job_info) { + scord::error_code + add_client_info(std::shared_ptr job_info) { scord::abt::unique_lock lock(m_info_mutex); @@ -100,36 +100,36 @@ struct adhoc_storage_info { m_client_info.reset(); } - std::shared_ptr + std::shared_ptr client_info() const { scord::abt::shared_lock lock(m_info_mutex); return m_client_info; } - admire::adhoc_storage m_adhoc_storage; - std::shared_ptr m_client_info; + scord::adhoc_storage m_adhoc_storage; + std::shared_ptr m_client_info; mutable scord::abt::shared_mutex m_info_mutex; }; struct pfs_storage_info { - explicit pfs_storage_info(admire::pfs_storage pfs_storage) + explicit pfs_storage_info(scord::pfs_storage pfs_storage) : m_pfs_storage(std::move(pfs_storage)) {} - admire::pfs_storage + scord::pfs_storage pfs_storage() const { return m_pfs_storage; } void - update(admire::pfs_storage::ctx pfs_context) { + update(scord::pfs_storage::ctx pfs_context) { m_pfs_storage.update(std::move(pfs_context)); } - admire::pfs_storage m_pfs_storage; - std::shared_ptr m_client_info; + scord::pfs_storage m_pfs_storage; + std::shared_ptr m_client_info; }; -} // namespace admire::internal +} // namespace scord::internal #endif // SCORD_INTERNAL_TYPES_HPP diff --git a/src/common/api/admire_types.h b/src/common/api/scord/types.h similarity index 99% rename from src/common/api/admire_types.h rename to src/common/api/scord/types.h index 197780d716b69c30a91569ab178f45c99004a477..f369cc9073d2abcb416f6ffc202b957f5d91c6a8 100644 --- a/src/common/api/admire_types.h +++ b/src/common/api/scord/types.h @@ -22,8 +22,8 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#ifndef SCORD_ADMIRE_TYPES_H -#define SCORD_ADMIRE_TYPES_H +#ifndef SCORD_TYPES_H +#define SCORD_TYPES_H #include #include @@ -652,4 +652,4 @@ ADM_data_operation_destroy(ADM_data_operation_t op); } // extern "C" #endif -#endif // SCORD_ADMIRE_TYPES_H +#endif // SCORD_TYPES_H diff --git a/src/common/api/admire_types.hpp b/src/common/api/scord/types.hpp similarity index 82% rename from src/common/api/admire_types.hpp rename to src/common/api/scord/types.hpp index 9719690fc1e6494385064c6529eb7e406d9491f3..26a3381bcfeeb6a6bec14954ff3bb6ac2a2c44da 100644 --- a/src/common/api/admire_types.hpp +++ b/src/common/api/scord/types.hpp @@ -22,8 +22,8 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#ifndef SCORD_ADMIRE_TYPES_HPP -#define SCORD_ADMIRE_TYPES_HPP +#ifndef SCORD_TYPES_HPP +#define SCORD_TYPES_HPP #include #include @@ -33,9 +33,9 @@ #include #include #include -#include "admire_types.h" +#include -namespace admire { +namespace scord { struct error_code { @@ -173,10 +173,10 @@ struct job { struct resources { resources(); - explicit resources(std::vector nodes); + explicit resources(std::vector nodes); explicit resources(ADM_job_resources_t res); - std::vector + std::vector nodes() const; template @@ -186,7 +186,7 @@ struct job { } private: - std::vector m_nodes; + std::vector m_nodes; }; job(); @@ -269,7 +269,7 @@ struct entity { entity(); template - entity(admire::qos::scope s, T&& data); + entity(scord::qos::scope s, T&& data); explicit entity(ADM_qos_entity_t entity); entity(const entity&) noexcept; @@ -281,7 +281,7 @@ struct entity { ~entity(); - admire::qos::scope + scord::qos::scope scope() const; template @@ -302,9 +302,9 @@ private: struct limit { limit(); - limit(admire::qos::subclass cls, uint64_t value); - limit(admire::qos::subclass cls, uint64_t value, - const admire::qos::entity& e); + limit(scord::qos::subclass cls, uint64_t value); + limit(scord::qos::subclass cls, uint64_t value, + const scord::qos::entity& e); explicit limit(ADM_qos_limit_t l); limit(const limit&) noexcept; @@ -316,10 +316,10 @@ struct limit { ~limit(); - std::optional + std::optional entity() const; - admire::qos::subclass + scord::qos::subclass subclass() const; uint64_t @@ -389,10 +389,10 @@ struct adhoc_storage { struct resources { resources() = default; - explicit resources(std::vector nodes); + explicit resources(std::vector nodes); explicit resources(ADM_adhoc_resources_t res); - std::vector + std::vector nodes() const; template @@ -402,7 +402,7 @@ struct adhoc_storage { } private: - std::vector m_nodes; + std::vector m_nodes; }; struct ctx { @@ -451,7 +451,7 @@ struct adhoc_storage { std::uint32_t walltime, bool should_flush); explicit adhoc_storage(ADM_adhoc_storage_t storage); adhoc_storage(enum adhoc_storage::type type, std::string name, - std::uint64_t id, const admire::adhoc_storage::ctx& ctx); + std::uint64_t id, const scord::adhoc_storage::ctx& ctx); adhoc_storage(const adhoc_storage& other) noexcept; adhoc_storage(adhoc_storage&&) noexcept; @@ -471,7 +471,7 @@ struct adhoc_storage { context() const; void - update(admire::adhoc_storage::ctx new_ctx); + update(scord::adhoc_storage::ctx new_ctx); // The implementation for this must be deferred until // after the declaration of the PIMPL class @@ -540,7 +540,7 @@ struct pfs_storage { context() const; void - update(admire::pfs_storage::ctx new_ctx); + update(scord::pfs_storage::ctx new_ctx); // The implementation for this must be deferred until // after the declaration of the PIMPL class @@ -557,12 +557,12 @@ struct job_requirements { job_requirements(); - job_requirements(std::vector inputs, - std::vector outputs); + job_requirements(std::vector inputs, + std::vector outputs); - job_requirements(std::vector inputs, - std::vector outputs, - admire::adhoc_storage adhoc_storage); + job_requirements(std::vector inputs, + std::vector outputs, + scord::adhoc_storage adhoc_storage); explicit job_requirements(ADM_job_requirements_t reqs); @@ -575,11 +575,11 @@ struct job_requirements { ~job_requirements(); - std::vector + std::vector inputs() const; - std::vector + std::vector outputs() const; - std::optional + std::optional adhoc_storage() const; // The implementation for this must be deferred until @@ -601,21 +601,21 @@ private: //////////////////////////////////////////////////////////////////////////////// template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::error_code& ec, FormatContext& ctx) const { + format(const scord::error_code& ec, FormatContext& ctx) const { return formatter::format(ec.name(), ctx); } }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::job& j, FormatContext& ctx) const { + format(const scord::job& j, FormatContext& ctx) const { return formatter::format( fmt::format("{{id: {}, slurm_id: {}}}", j.id(), j.slurm_id()), ctx); @@ -623,22 +623,22 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::dataset& d, FormatContext& ctx) const { + format(const scord::dataset& d, FormatContext& ctx) const { const auto str = fmt::format("{{id: {}}}", std::quoted(d.id())); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::node& n, FormatContext& ctx) const { + format(const scord::node& n, FormatContext& ctx) const { const auto str = fmt::format("{{hostname: {}}}", std::quoted(n.hostname())); return formatter::format(str, ctx); @@ -646,15 +646,15 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const enum admire::adhoc_storage::type& t, + format(const enum scord::adhoc_storage::type& t, FormatContext& ctx) const { - using admire::adhoc_storage; + using scord::adhoc_storage; std::string_view name = "unknown"; switch(t) { @@ -677,15 +677,15 @@ struct fmt::formatter }; template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::adhoc_storage::execution_mode& exec_mode, + format(const scord::adhoc_storage::execution_mode& exec_mode, FormatContext& ctx) const { - using execution_mode = admire::adhoc_storage::execution_mode; + using execution_mode = scord::adhoc_storage::execution_mode; std::string_view name = "unknown"; @@ -709,15 +709,15 @@ struct fmt::formatter }; template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::adhoc_storage::access_type& type, + format(const scord::adhoc_storage::access_type& type, FormatContext& ctx) const { - using access_type = admire::adhoc_storage::access_type; + using access_type = scord::adhoc_storage::access_type; std::string_view name = "unknown"; @@ -750,11 +750,11 @@ struct fmt::formatter> : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::adhoc_storage& s, FormatContext& ctx) const { + format(const scord::adhoc_storage& s, FormatContext& ctx) const { const auto str = fmt::format( "{{type: {}, id: {}, name: {}, context: {}}}", s.type(), s.id(), std::quoted(s.name()), s.context()); @@ -763,12 +763,12 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::adhoc_storage::resources& r, + format(const scord::adhoc_storage::resources& r, FormatContext& ctx) const { const auto str = fmt::format("{{nodes: {}}}", r.nodes()); @@ -779,12 +779,12 @@ struct fmt::formatter template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::adhoc_storage::ctx& c, FormatContext& ctx) const { + format(const scord::adhoc_storage::ctx& c, FormatContext& ctx) const { const auto str = fmt::format("{{execution_mode: {}, access_type: {}, " @@ -797,14 +797,14 @@ struct fmt::formatter }; template <> -struct fmt::formatter +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const enum admire::pfs_storage::type& t, FormatContext& ctx) const { + format(const enum scord::pfs_storage::type& t, FormatContext& ctx) const { - using admire::pfs_storage; + using scord::pfs_storage; std::string_view name = "unknown"; switch(t) { @@ -821,44 +821,44 @@ struct fmt::formatter }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::pfs_storage& s, FormatContext& ctx) const { + format(const scord::pfs_storage& s, FormatContext& ctx) const { const auto str = fmt::format("{{context: {}}}", s.context()); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::pfs_storage::ctx& c, FormatContext& ctx) const { + format(const scord::pfs_storage::ctx& c, FormatContext& ctx) const { const auto str = fmt::format("{{mount_point: {}}}", c.mount_point()); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::job::resources& r, FormatContext& ctx) const { + format(const scord::job::resources& r, FormatContext& ctx) const { const auto str = fmt::format("{{nodes: {}}}", r.nodes()); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::job_requirements& r, FormatContext& ctx) const { + format(const scord::job_requirements& r, FormatContext& ctx) const { return formatter::format( fmt::format("{{inputs: {}, outputs: {}, adhoc_storage: {}}}", r.inputs(), r.outputs(), r.adhoc_storage()), @@ -867,13 +867,13 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::qos::scope& s, FormatContext& ctx) const { + format(const scord::qos::scope& s, FormatContext& ctx) const { - using scope = admire::qos::scope; + using scope = scord::qos::scope; std::string_view name = "unknown"; @@ -897,12 +897,12 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter> +struct fmt::formatter> : formatter { // parse is inherited from formatter. template auto - format(const std::optional& e, + format(const std::optional& e, FormatContext& ctx) const { if(!e) { @@ -912,17 +912,17 @@ struct fmt::formatter> std::string_view data = "unknown"; switch(e->scope()) { - case admire::qos::scope::dataset: - data = fmt::format("{}", e->data()); + case scord::qos::scope::dataset: + data = fmt::format("{}", e->data()); break; - case admire::qos::scope::node: - data = fmt::format("{}", e->data()); + case scord::qos::scope::node: + data = fmt::format("{}", e->data()); break; - case admire::qos::scope::job: - data = fmt::format("{}", e->data()); + case scord::qos::scope::job: + data = fmt::format("{}", e->data()); break; - case admire::qos::scope::transfer: - data = fmt::format("{}", e->data()); + case scord::qos::scope::transfer: + data = fmt::format("{}", e->data()); break; } @@ -933,13 +933,13 @@ struct fmt::formatter> }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::qos::subclass& sc, FormatContext& ctx) const { + format(const scord::qos::subclass& sc, FormatContext& ctx) const { - using subclass = admire::qos::subclass; + using subclass = scord::qos::subclass; std::string_view name = "unknown"; @@ -957,11 +957,11 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::qos::limit& l, FormatContext& ctx) const { + format(const scord::qos::limit& l, FormatContext& ctx) const { const auto str = fmt::format("{{entity: {}, subclass: {}, value: {}}}", l.entity(), l.subclass(), l.value()); return formatter::format(str, ctx); @@ -969,13 +969,13 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::transfer::mapping& m, FormatContext& ctx) const { + format(const scord::transfer::mapping& m, FormatContext& ctx) const { - using mapping = admire::transfer::mapping; + using mapping = scord::transfer::mapping; std::string_view name = "unknown"; @@ -996,49 +996,49 @@ struct fmt::formatter : formatter { }; template <> -struct fmt::formatter : formatter { +struct fmt::formatter : formatter { // parse is inherited from formatter. template auto - format(const admire::transfer& tx, FormatContext& ctx) const { + format(const scord::transfer& tx, FormatContext& ctx) const { const auto str = fmt::format("{{id: {}}}", tx.id()); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter> : formatter { +struct fmt::formatter> : formatter { // parse is inherited from formatter. template auto - format(const std::vector& v, FormatContext& ctx) const { + format(const std::vector& v, FormatContext& ctx) const { const auto str = fmt::format("[{}]", fmt::join(v, ", ")); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter> +struct fmt::formatter> : formatter { // parse is inherited from formatter. template auto - format(const std::vector& v, FormatContext& ctx) const { + format(const std::vector& v, FormatContext& ctx) const { const auto str = fmt::format("[{}]", fmt::join(v, ", ")); return formatter::format(str, ctx); } }; template <> -struct fmt::formatter> +struct fmt::formatter> : formatter { // parse is inherited from formatter. template auto - format(const std::vector& l, FormatContext& ctx) const { + format(const std::vector& l, FormatContext& ctx) const { const auto str = fmt::format("[{}]", fmt::join(l, ", ")); return formatter::format(str, ctx); } }; -#endif // SCORD_ADMIRE_TYPES_HPP +#endif // SCORD_TYPES_HPP diff --git a/src/common/api/types.cpp b/src/common/api/types.cpp index 56f2a124ab29906d715c66e611c3dfe9bbd79ebe..e2b18014a1ee6e01141dc005de81656f3163972f 100644 --- a/src/common/api/types.cpp +++ b/src/common/api/types.cpp @@ -28,8 +28,8 @@ #include #include #include -#include "admire_types.hpp" -#include "internal_types.hpp" +#include "scord/types.hpp" +#include "scord/internal_types.hpp" /******************************************************************************/ /* C Type definitions and related functions */ @@ -1060,7 +1060,7 @@ const char* ADM_strerror(ADM_return_t errnum); }; -namespace admire { +namespace scord { std::string_view error_code::message() const { @@ -1237,7 +1237,7 @@ private: job::resources::resources() = default; -job::resources::resources(std::vector nodes) +job::resources::resources(std::vector nodes) : m_nodes(std::move(nodes)) {} job::resources::resources(ADM_job_resources_t res) { @@ -1249,7 +1249,7 @@ job::resources::resources(ADM_job_resources_t res) { } } -std::vector +std::vector job::resources::nodes() const { return m_nodes; } @@ -1476,7 +1476,7 @@ template void dataset::serialize( scord::network::serialization::input_archive&); -adhoc_storage::resources::resources(std::vector nodes) +adhoc_storage::resources::resources(std::vector nodes) : m_nodes(std::move(nodes)) {} adhoc_storage::resources::resources(ADM_adhoc_resources_t res) { @@ -1488,7 +1488,7 @@ adhoc_storage::resources::resources(ADM_adhoc_resources_t res) { } } -std::vector +std::vector adhoc_storage::resources::nodes() const { return m_nodes; } @@ -1655,7 +1655,7 @@ adhoc_storage::context() const { } void -adhoc_storage::update(admire::adhoc_storage::ctx new_ctx) { +adhoc_storage::update(scord::adhoc_storage::ctx new_ctx) { return m_pimpl->update(std::move(new_ctx)); } @@ -1817,7 +1817,7 @@ pfs_storage::context() const { } void -pfs_storage::update(admire::pfs_storage::ctx new_ctx) { +pfs_storage::update(scord::pfs_storage::ctx new_ctx) { return m_pimpl->update(std::move(new_ctx)); } @@ -1851,13 +1851,13 @@ class job_requirements::impl { public: impl() = default; - impl(std::vector inputs, - std::vector outputs) + impl(std::vector inputs, + std::vector outputs) : m_inputs(std::move(inputs)), m_outputs(std::move(outputs)) {} - impl(std::vector inputs, - std::vector outputs, - admire::adhoc_storage adhoc_storage) + impl(std::vector inputs, + std::vector outputs, + scord::adhoc_storage adhoc_storage) : m_inputs(std::move(inputs)), m_outputs(std::move(outputs)), m_adhoc_storage(std::move(adhoc_storage)) {} @@ -1876,7 +1876,7 @@ public: } if(reqs->r_adhoc_storage) { - m_adhoc_storage = admire::adhoc_storage(reqs->r_adhoc_storage); + m_adhoc_storage = scord::adhoc_storage(reqs->r_adhoc_storage); } } @@ -1887,17 +1887,17 @@ public: impl& operator=(impl&&) noexcept = default; - std::vector + std::vector inputs() const { return m_inputs; } - std::vector + std::vector outputs() const { return m_outputs; } - std::optional + std::optional adhoc_storage() const { return m_adhoc_storage; } @@ -1919,21 +1919,21 @@ public: } private: - std::vector m_inputs; - std::vector m_outputs; - std::optional m_adhoc_storage; + std::vector m_inputs; + std::vector m_outputs; + std::optional m_adhoc_storage; }; job_requirements::job_requirements() = default; -job_requirements::job_requirements(std::vector inputs, - std::vector outputs) +job_requirements::job_requirements(std::vector inputs, + std::vector outputs) : m_pimpl(std::make_unique(std::move(inputs), std::move(outputs))) {} -job_requirements::job_requirements(std::vector inputs, - std::vector outputs, - admire::adhoc_storage adhoc_storage) +job_requirements::job_requirements(std::vector inputs, + std::vector outputs, + scord::adhoc_storage adhoc_storage) : m_pimpl(std::make_unique(std::move(inputs), std::move(outputs), std::move(adhoc_storage))) {} @@ -1956,17 +1956,17 @@ job_requirements::operator=(job_requirements&&) noexcept = default; job_requirements::~job_requirements() = default; -std::vector +std::vector job_requirements::inputs() const { return m_pimpl->inputs(); } -std::vector +std::vector job_requirements::outputs() const { return m_pimpl->outputs(); } -std::optional +std::optional job_requirements::adhoc_storage() const { return m_pimpl->adhoc_storage(); } @@ -2004,7 +2004,7 @@ public: impl() = default; template - impl(const admire::qos::scope& s, T&& data) : m_scope(s), m_data(data) {} + impl(const scord::qos::scope& s, T&& data) : m_scope(s), m_data(data) {} explicit impl(ADM_qos_entity_t entity) : m_scope(static_cast(entity->e_scope)), @@ -2017,7 +2017,7 @@ public: impl& operator=(impl&&) noexcept = default; - admire::qos::scope + scord::qos::scope scope() const { return m_scope; } @@ -2047,13 +2047,13 @@ private: init_helper(ADM_qos_entity_t entity) { switch(entity->e_scope) { case ADM_QOS_SCOPE_DATASET: - return admire::dataset(entity->e_dataset); + return scord::dataset(entity->e_dataset); case ADM_QOS_SCOPE_NODE: - return admire::node(entity->e_node); + return scord::node(entity->e_node); case ADM_QOS_SCOPE_JOB: - return admire::job(entity->e_job); + return scord::job(entity->e_job); case ADM_QOS_SCOPE_TRANSFER: - return admire::transfer(entity->e_transfer); + return scord::transfer(entity->e_transfer); default: throw std::runtime_error(fmt::format( "Unexpected scope value: {}", entity->e_scope)); @@ -2062,14 +2062,14 @@ private: private: - admire::qos::scope m_scope; + scord::qos::scope m_scope; std::variant m_data; }; entity::entity() = default; template -entity::entity(admire::qos::scope s, T&& data) +entity::entity(scord::qos::scope s, T&& data) : m_pimpl(std::make_unique(s, std::forward(data))) {} entity::entity(ADM_qos_entity_t entity) @@ -2091,33 +2091,33 @@ entity::operator=(entity&&) noexcept = default; entity::~entity() = default; -admire::qos::scope +scord::qos::scope entity::scope() const { return m_pimpl->scope(); } template <> -admire::node -entity::data() const { - return m_pimpl->data(); +scord::node +entity::data() const { + return m_pimpl->data(); } template <> -admire::job -entity::data() const { - return m_pimpl->data(); +scord::job +entity::data() const { + return m_pimpl->data(); } template <> -admire::dataset -entity::data() const { - return m_pimpl->data(); +scord::dataset +entity::data() const { + return m_pimpl->data(); } template <> -admire::transfer -entity::data() const { - return m_pimpl->data(); +scord::transfer +entity::data() const { + return m_pimpl->data(); } // since the PIMPL class is fully defined at this point, we can now @@ -2150,16 +2150,16 @@ class limit::impl { public: impl() = default; - impl(admire::qos::subclass cls, uint64_t value, admire::qos::entity e) + impl(scord::qos::subclass cls, uint64_t value, scord::qos::entity e) : m_subclass(cls), m_value(value), m_entity(std::move(e)) {} - impl(admire::qos::subclass cls, uint64_t value) + impl(scord::qos::subclass cls, uint64_t value) : m_subclass(cls), m_value(value) {} explicit impl(ADM_qos_limit_t l) : m_subclass(static_cast(l->l_class)), m_value(l->l_value), - m_entity(l->l_entity ? std::optional(admire::qos::entity(l->l_entity)) + m_entity(l->l_entity ? std::optional(scord::qos::entity(l->l_entity)) : std::nullopt) {} impl(const impl& rhs) = default; @@ -2169,12 +2169,12 @@ public: impl& operator=(impl&&) noexcept = default; - std::optional + std::optional entity() const { return m_entity; } - admire::qos::subclass + scord::qos::subclass subclass() const { return m_subclass; } @@ -2201,18 +2201,18 @@ public: } private: - admire::qos::subclass m_subclass; + scord::qos::subclass m_subclass; uint64_t m_value; - std::optional m_entity; + std::optional m_entity; }; limit::limit() = default; -limit::limit(admire::qos::subclass cls, uint64_t value) +limit::limit(scord::qos::subclass cls, uint64_t value) : m_pimpl(std::make_unique(cls, value)) {} -limit::limit(admire::qos::subclass cls, uint64_t value, - const admire::qos::entity& e) +limit::limit(scord::qos::subclass cls, uint64_t value, + const scord::qos::entity& e) : m_pimpl(std::make_unique(cls, value, e)) {} limit::limit(ADM_qos_limit_t l) : m_pimpl(std::make_unique(l)) {} @@ -2233,12 +2233,12 @@ limit::operator=(limit&&) noexcept = default; limit::~limit() = default; -std::optional +std::optional limit::entity() const { return m_pimpl->entity(); } -admire::qos::subclass +scord::qos::subclass limit::subclass() const { return m_pimpl->subclass(); } @@ -2276,4 +2276,4 @@ limit::serialize( } // namespace qos -} // namespace admire +} // namespace scord diff --git a/src/common/net/proto/CMakeLists.txt b/src/common/net/proto/CMakeLists.txt index 10702cb0e6b872b04e3175b6841f2a63886700b4..32681285c4f6a8989bceb04a9e706683f742b217 100644 --- a/src/common/net/proto/CMakeLists.txt +++ b/src/common/net/proto/CMakeLists.txt @@ -29,7 +29,7 @@ set_property(TARGET _rpc_types PROPERTY POSITION_INDEPENDENT_CODE ON) target_include_directories(_rpc_types PUBLIC ${CMAKE_SOURCE_DIR}/src/lib) target_sources( _rpc_types - PRIVATE rpc_types.h rpc_types.c ${CMAKE_SOURCE_DIR}/src/lib/admire.h + PRIVATE rpc_types.h rpc_types.c ) target_link_libraries(_rpc_types PRIVATE common::api::types Mercury::Mercury diff --git a/src/common/net/proto/rpc_types.h b/src/common/net/proto/rpc_types.h index cf9b51873c193867f6771f2ec856f3e2e7eebabb..8fbd581fde6f84af5e4918ef424d04de815db481 100644 --- a/src/common/net/proto/rpc_types.h +++ b/src/common/net/proto/rpc_types.h @@ -28,7 +28,7 @@ #include // NOLINT #include #include -#include +#include #ifdef __cplusplus extern "C" { diff --git a/src/common/net/request.hpp b/src/common/net/request.hpp index 5c36cb8804b2628c2563559f0e9fa355525a74d2..0f4ad7c52cdd1920b6ccb10ef245268bca961f88 100644 --- a/src/common/net/request.hpp +++ b/src/common/net/request.hpp @@ -26,7 +26,7 @@ #define SCORD_NET_REQUEST_HPP #include -#include "admire_types.hpp" +#include namespace scord::network { @@ -43,7 +43,7 @@ class generic_response { public: constexpr generic_response() noexcept = default; constexpr generic_response(std::uint64_t op_id, - admire::error_code ec) noexcept + scord::error_code ec) noexcept : m_op_id(op_id), m_error_code(ec) {} constexpr std::uint64_t @@ -51,7 +51,7 @@ public: return m_op_id; } - constexpr admire::error_code + constexpr scord::error_code error_code() const noexcept { return m_error_code; } @@ -65,7 +65,7 @@ public: private: std::uint64_t m_op_id; - admire::error_code m_error_code; + scord::error_code m_error_code; }; template @@ -74,7 +74,7 @@ class response_with_value : public generic_response { public: constexpr response_with_value() noexcept = default; - constexpr response_with_value(std::uint64_t op_id, admire::error_code ec, + constexpr response_with_value(std::uint64_t op_id, scord::error_code ec, std::optional value) noexcept : generic_response(op_id, ec), m_value(std::move(value)) {} diff --git a/src/lib/CMakeLists.txt b/src/lib/CMakeLists.txt index e3817f51ef67220440017eece802eb1344def03c..cae7695205b365035be4bd2c9a8129c258b7e0e8 100644 --- a/src/lib/CMakeLists.txt +++ b/src/lib/CMakeLists.txt @@ -22,24 +22,37 @@ # SPDX-License-Identifier: GPL-3.0-or-later # ################################################################################ -add_library(adm_iosched SHARED) +add_library(libscord SHARED) -target_sources(adm_iosched - PUBLIC admire.h admire.hpp - PRIVATE admire.cpp c_wrapper.cpp detail/impl.hpp detail/impl.cpp env.hpp) +target_sources( + libscord + PUBLIC scord/scord.h scord/scord.hpp + PRIVATE libscord.cpp c_wrapper.cpp detail/impl.hpp detail/impl.cpp env.hpp +) + +list(APPEND public_headers "scord/scord.h" + "${CMAKE_SOURCE_DIR}/src/common/api/scord/types.h" "scord/scord.hpp" + "${CMAKE_SOURCE_DIR}/src/common/api/scord/types.hpp" +) -set_target_properties(adm_iosched PROPERTIES PUBLIC_HEADER "admire.h;admire.hpp") +set_target_properties(libscord PROPERTIES PUBLIC_HEADER "${public_headers}") -target_include_directories(adm_iosched PUBLIC ${CMAKE_CURRENT_SOURCE_DIR}) +target_include_directories( + libscord PUBLIC $ + $ +) + +target_link_libraries( + libscord + PRIVATE common::network::rpc_client common::network::rpc_types + PUBLIC tl::expected common::api::types +) -target_link_libraries(adm_iosched PRIVATE - common::network::rpc_client - common::network::rpc_types PUBLIC - tl::expected common::api::types) +set_target_properties(libscord PROPERTIES OUTPUT_NAME "scord") install( - TARGETS adm_iosched + TARGETS libscord LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR} ARCHIVE DESTINATION ${CMAKE_INSTALL_LIBDIR} - PUBLIC_HEADER DESTINATION ${CMAKE_INSTALL_INCLUDEDIR} + PUBLIC_HEADER DESTINATION ${CMAKE_INSTALL_INCLUDEDIR}/${PROJECT_NAME} ) diff --git a/src/lib/c_wrapper.cpp b/src/lib/c_wrapper.cpp index c608ae475e4f46065904406e41a0329d4b76536a..8a31f996c20f7882e5be29c9d7600861021be133 100644 --- a/src/lib/c_wrapper.cpp +++ b/src/lib/c_wrapper.cpp @@ -22,13 +22,13 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#include -#include +#include +#include #include #include #include -#include -#include +#include +#include #include #include "detail/impl.hpp" @@ -38,8 +38,8 @@ /******************************************************************************/ ADM_return_t ADM_ping(ADM_server_t server) { - const admire::server srv{server}; - return admire::detail::ping(srv); + const scord::server srv{server}; + return scord::detail::ping(srv); } ADM_return_t @@ -47,17 +47,17 @@ ADM_register_job(ADM_server_t server, ADM_job_resources_t res, ADM_job_requirements_t reqs, uint64_t slurm_id, ADM_job_t* job) { - const admire::server srv{server}; + const scord::server srv{server}; - const auto rv = admire::detail::register_job( - srv, admire::job::resources{res}, admire::job_requirements{reqs}, - slurm_id); + const auto rv = scord::detail::register_job(srv, scord::job::resources{res}, + scord::job_requirements{reqs}, + slurm_id); if(!rv) { return rv.error(); } - *job = admire::api::convert(*rv).release(); + *job = scord::api::convert(*rv).release(); return ADM_SUCCESS; } @@ -66,18 +66,18 @@ ADM_return_t ADM_update_job(ADM_server_t server, ADM_job_t job, ADM_job_resources_t job_resources) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::detail::update_job(srv, admire::job{job}, - admire::job::resources{job_resources}); + return scord::detail::update_job(srv, scord::job{job}, + scord::job::resources{job_resources}); } ADM_return_t ADM_remove_job(ADM_server_t server, ADM_job_t job) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::detail::remove_job(srv, admire::job{job}); + return scord::detail::remove_job(srv, scord::job{job}); } ADM_return_t @@ -86,17 +86,17 @@ ADM_register_adhoc_storage(ADM_server_t server, const char* name, ADM_adhoc_context_t ctx, ADM_adhoc_storage_t* adhoc_storage) { - const admire::server srv{server}; + const scord::server srv{server}; - const auto cxx_type = static_cast(type); - const auto rv = admire::detail::register_adhoc_storage( - srv, name, cxx_type, admire::adhoc_storage::ctx{ctx}); + const auto cxx_type = static_cast(type); + const auto rv = scord::detail::register_adhoc_storage( + srv, name, cxx_type, scord::adhoc_storage::ctx{ctx}); if(!rv) { return rv.error(); } - *adhoc_storage = admire::api::convert(*rv).release(); + *adhoc_storage = scord::api::convert(*rv).release(); return ADM_SUCCESS; } @@ -105,31 +105,31 @@ ADM_return_t ADM_update_adhoc_storage(ADM_server_t server, ADM_adhoc_storage_t adhoc_storage, ADM_adhoc_context_t ctx) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::detail::update_adhoc_storage( - srv, admire::adhoc_storage::ctx{ctx}, - admire::adhoc_storage{adhoc_storage}); + return scord::detail::update_adhoc_storage( + srv, scord::adhoc_storage::ctx{ctx}, + scord::adhoc_storage{adhoc_storage}); } ADM_return_t ADM_remove_adhoc_storage(ADM_server_t server, ADM_adhoc_storage_t adhoc_storage) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::detail::remove_adhoc_storage( - srv, admire::adhoc_storage{adhoc_storage}); + return scord::detail::remove_adhoc_storage( + srv, scord::adhoc_storage{adhoc_storage}); } ADM_return_t ADM_deploy_adhoc_storage(ADM_server_t server, ADM_adhoc_storage_t adhoc_storage) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::detail::deploy_adhoc_storage( - srv, admire::adhoc_storage{adhoc_storage}); + return scord::detail::deploy_adhoc_storage( + srv, scord::adhoc_storage{adhoc_storage}); } ADM_return_t @@ -137,16 +137,16 @@ ADM_register_pfs_storage(ADM_server_t server, const char* name, ADM_pfs_storage_type_t type, ADM_pfs_context_t ctx, ADM_pfs_storage_t* pfs_storage) { - const auto rv = admire::detail::register_pfs_storage( - admire::server{server}, name, - static_cast(type), - admire::pfs_storage::ctx{ctx}); + const auto rv = scord::detail::register_pfs_storage( + scord::server{server}, name, + static_cast(type), + scord::pfs_storage::ctx{ctx}); if(!rv) { return rv.error(); } - *pfs_storage = admire::api::convert(rv.value()).release(); + *pfs_storage = scord::api::convert(rv.value()).release(); return ADM_SUCCESS; } @@ -155,15 +155,15 @@ ADM_return_t ADM_update_pfs_storage(ADM_server_t server, ADM_pfs_storage_t pfs_storage, ADM_pfs_context_t ctx) { - return admire::detail::update_pfs_storage(admire::server{server}, - admire::pfs_storage{pfs_storage}, - admire::pfs_storage::ctx{ctx}); + return scord::detail::update_pfs_storage(scord::server{server}, + scord::pfs_storage{pfs_storage}, + scord::pfs_storage::ctx{ctx}); } ADM_return_t ADM_remove_pfs_storage(ADM_server_t server, ADM_pfs_storage_t pfs_storage) { - return admire::detail::remove_pfs_storage(admire::server{server}, - admire::pfs_storage{pfs_storage}); + return scord::detail::remove_pfs_storage(scord::server{server}, + scord::pfs_storage{pfs_storage}); } ADM_return_t @@ -174,18 +174,18 @@ ADM_transfer_datasets(ADM_server_t server, ADM_job_t job, ADM_transfer_mapping_t mapping, ADM_transfer_t* transfer) { - const auto rv = admire::detail::transfer_datasets( - admire::server{server}, admire::job{job}, - admire::api::convert(sources, sources_len), - admire::api::convert(targets, targets_len), - admire::api::convert(limits, limits_len), - static_cast(mapping)); + const auto rv = scord::detail::transfer_datasets( + scord::server{server}, scord::job{job}, + scord::api::convert(sources, sources_len), + scord::api::convert(targets, targets_len), + scord::api::convert(limits, limits_len), + static_cast(mapping)); if(!rv) { return rv.error(); } - *transfer = admire::api::convert(*rv).release(); + *transfer = scord::api::convert(*rv).release(); return ADM_SUCCESS; } @@ -194,9 +194,9 @@ ADM_return_t ADM_set_dataset_information(ADM_server_t server, ADM_job_t job, ADM_dataset_t target, ADM_dataset_info_t info) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::set_dataset_information(srv, job, target, info); + return scord::set_dataset_information(srv, job, target, info); } ADM_return_t @@ -204,9 +204,9 @@ ADM_set_io_resources(ADM_server_t server, ADM_job_t job, ADM_adhoc_storage_t tier, ADM_adhoc_resources_t resources) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::set_io_resources(srv, job, tier, resources); + return scord::set_io_resources(srv, job, tier, resources); } ADM_return_t @@ -214,65 +214,65 @@ ADM_get_transfer_priority(ADM_server_t server, ADM_job_t job, ADM_transfer_t transfer, ADM_transfer_priority_t* priority) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::get_transfer_priority(srv, job, transfer, priority); + return scord::get_transfer_priority(srv, job, transfer, priority); } ADM_return_t ADM_set_transfer_priority(ADM_server_t server, ADM_job_t job, ADM_transfer_t transfer, int incr) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::set_transfer_priority(srv, job, transfer, incr); + return scord::set_transfer_priority(srv, job, transfer, incr); } ADM_return_t ADM_cancel_transfer(ADM_server_t server, ADM_job_t job, ADM_transfer_t transfer) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::cancel_transfer(srv, job, transfer); + return scord::cancel_transfer(srv, job, transfer); } ADM_return_t ADM_get_pending_transfers(ADM_server_t server, ADM_job_t job, ADM_transfer_t** pending_transfers) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::get_pending_transfers(srv, job, pending_transfers); + return scord::get_pending_transfers(srv, job, pending_transfers); } ADM_return_t ADM_set_qos_constraints(ADM_server_t server, ADM_job_t job, ADM_qos_entity_t entity, ADM_qos_limit_t limit) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::set_qos_constraints(srv, job, entity, limit); + return scord::set_qos_constraints(srv, job, entity, limit); } ADM_return_t ADM_get_qos_constraints(ADM_server_t server, ADM_job_t job, ADM_qos_entity_t entity, ADM_qos_limit_t** limits) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::get_qos_constraints(srv, job, entity, limits); + return scord::get_qos_constraints(srv, job, entity, limits); } ADM_return_t ADM_define_data_operation(ADM_server_t server, ADM_job_t job, const char* path, ADM_data_operation_t* op, ...) { - const admire::server srv{server}; + const scord::server srv{server}; va_list args; va_start(args, op); - auto ret = admire::define_data_operation(srv, job, path, op, args); + auto ret = scord::define_data_operation(srv, job, path, op, args); va_end(args); return ret; @@ -283,12 +283,12 @@ ADM_connect_data_operation(ADM_server_t server, ADM_job_t job, ADM_dataset_t input, ADM_dataset_t output, bool should_stream, ...) { - const admire::server srv{server}; + const scord::server srv{server}; va_list args; va_start(args, should_stream); - auto ret = admire::connect_data_operation(srv, job, input, output, - should_stream, args); + auto ret = scord::connect_data_operation(srv, job, input, output, + should_stream, args); va_end(args); return ret; @@ -299,9 +299,9 @@ ADM_finalize_data_operation(ADM_server_t server, ADM_job_t job, ADM_data_operation_t op, ADM_data_operation_status_t* status) { - const admire::server srv{server}; + const scord::server srv{server}; - return admire::finalize_data_operation(srv, job, op, status); + return scord::finalize_data_operation(srv, job, op, status); } @@ -311,12 +311,12 @@ ADM_link_transfer_to_data_operation(ADM_server_t server, ADM_job_t job, ADM_transfer_t transfer, bool should_stream, ...) { - const admire::server srv{server}; + const scord::server srv{server}; va_list args; va_start(args, should_stream); - auto ret = admire::link_transfer_to_data_operation(srv, job, op, transfer, - should_stream, args); + auto ret = scord::link_transfer_to_data_operation(srv, job, op, transfer, + should_stream, args); va_end(args); return ret; @@ -325,6 +325,6 @@ ADM_link_transfer_to_data_operation(ADM_server_t server, ADM_job_t job, ADM_return_t ADM_get_statistics(ADM_server_t server, ADM_job_t job, ADM_job_stats_t** stats) { - const admire::server srv{server}; - return admire::get_statistics(srv, job, stats); + const scord::server srv{server}; + return scord::get_statistics(srv, job, stats); } diff --git a/src/lib/detail/impl.cpp b/src/lib/detail/impl.cpp index 67ab4a703747743a5797e4310fbc430c5e949776..2eaf848fa373d8c42be45cd48a93c3b58c4e6601 100644 --- a/src/lib/detail/impl.cpp +++ b/src/lib/detail/impl.cpp @@ -27,7 +27,7 @@ #include #include #include -#include +#include #include "impl.hpp" using namespace std::literals; @@ -44,9 +44,9 @@ struct remote_procedure { } // namespace api -namespace admire::detail { +namespace scord::detail { -admire::error_code +scord::error_code ping(const server& srv) { scord::network::client rpc_client{srv.protocol()}; @@ -79,13 +79,13 @@ ping(const server& srv) { } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -tl::expected +tl::expected register_job(const server& srv, const job::resources& job_resources, const job_requirements& job_requirements, - admire::slurm_job_id slurm_id) { + scord::slurm_job_id slurm_id) { scord::network::client rpc_client{srv.protocol()}; @@ -120,15 +120,15 @@ register_job(const server& srv, const job::resources& job_resources, return tl::make_unexpected(resp.error_code()); } - return admire::job{resp.value(), slurm_id}; + return scord::job{resp.value(), slurm_id}; } } LOGGER_ERROR("rpc call failed"); - return tl::make_unexpected(admire::error_code::other); + return tl::make_unexpected(scord::error_code::other); } -admire::error_code +scord::error_code update_job(const server& srv, const job& job, const job::resources& new_resources) { @@ -163,10 +163,10 @@ update_job(const server& srv, const job& job, } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -admire::error_code +scord::error_code remove_job(const server& srv, const job& job) { scord::network::client rpc_client{srv.protocol()}; @@ -198,10 +198,10 @@ remove_job(const server& srv, const job& job) { } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -tl::expected +tl::expected register_adhoc_storage(const server& srv, const std::string& name, enum adhoc_storage::type type, const adhoc_storage::ctx& ctx) { @@ -236,15 +236,15 @@ register_adhoc_storage(const server& srv, const std::string& name, return tl::make_unexpected(ec); } - return admire::adhoc_storage{type, name, resp.value(), ctx}; + return scord::adhoc_storage{type, name, resp.value(), ctx}; } } LOGGER_ERROR("rpc call failed"); - return tl::make_unexpected(admire::error_code::other); + return tl::make_unexpected(scord::error_code::other); } -admire::error_code +scord::error_code update_adhoc_storage(const server& srv, const adhoc_storage::ctx& new_ctx, const adhoc_storage& adhoc_storage) { @@ -280,10 +280,10 @@ update_adhoc_storage(const server& srv, const adhoc_storage::ctx& new_ctx, } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -admire::error_code +scord::error_code remove_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage) { scord::network::client rpc_client{srv.protocol()}; @@ -317,10 +317,10 @@ remove_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage) { } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -tl::expected +tl::expected register_pfs_storage(const server& srv, const std::string& name, enum pfs_storage::type type, const pfs_storage::ctx& ctx) { @@ -354,17 +354,17 @@ register_pfs_storage(const server& srv, const std::string& name, return tl::make_unexpected(ec); } - return admire::pfs_storage{type, name, resp.value(), ctx}; + return scord::pfs_storage{type, name, resp.value(), ctx}; } } LOGGER_ERROR("rpc call failed"); - return tl::make_unexpected(admire::error_code::other); + return tl::make_unexpected(scord::error_code::other); } -admire::error_code +scord::error_code update_pfs_storage(const server& srv, const pfs_storage& pfs_storage, - const admire::pfs_storage::ctx& new_ctx) { + const scord::pfs_storage::ctx& new_ctx) { scord::network::client rpc_client{srv.protocol()}; @@ -398,10 +398,10 @@ update_pfs_storage(const server& srv, const pfs_storage& pfs_storage, } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -admire::error_code +scord::error_code remove_pfs_storage(const server& srv, const pfs_storage& pfs_storage) { scord::network::client rpc_client{srv.protocol()}; @@ -435,10 +435,10 @@ remove_pfs_storage(const server& srv, const pfs_storage& pfs_storage) { } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } -admire::error_code +scord::error_code deploy_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage) { scord::network::client rpc_client{srv.protocol()}; @@ -472,7 +472,7 @@ deploy_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage) { } LOGGER_ERROR("rpc call failed"); - return admire::error_code::other; + return scord::error_code::other; } tl::expected @@ -514,12 +514,12 @@ transfer_datasets(const server& srv, const job& job, return tl::make_unexpected(ec); } - return admire::transfer{resp.value()}; + return scord::transfer{resp.value()}; } } LOGGER_ERROR("rpc call failed"); - return tl::make_unexpected(admire::error_code::other); + return tl::make_unexpected(scord::error_code::other); } -} // namespace admire::detail +} // namespace scord::detail diff --git a/src/lib/detail/impl.hpp b/src/lib/detail/impl.hpp index bb24d14eed84045e3c0aebaaf61b4932629432d3..369b083653d7300743d7d309831154a265014222 100644 --- a/src/lib/detail/impl.hpp +++ b/src/lib/detail/impl.hpp @@ -26,50 +26,50 @@ #ifndef SCORD_ADMIRE_IMPL_HPP #define SCORD_ADMIRE_IMPL_HPP -#include +#include #include -namespace admire::detail { +namespace scord::detail { -admire::error_code +scord::error_code ping(const server& srv); -tl::expected +tl::expected register_job(const server& srv, const job::resources& job_resources, const job_requirements& job_requirements, - admire::slurm_job_id slurm_id); + scord::slurm_job_id slurm_id); -admire::error_code +scord::error_code update_job(const server& srv, const job& job, const job::resources& new_resources); -admire::error_code +scord::error_code remove_job(const server& srv, const job& job); -tl::expected +tl::expected register_adhoc_storage(const server& srv, const std::string& name, enum adhoc_storage::type type, const adhoc_storage::ctx& ctx); -admire::error_code +scord::error_code update_adhoc_storage(const server& srv, const adhoc_storage::ctx& new_ctx, const adhoc_storage& adhoc_storage); -admire::error_code +scord::error_code remove_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage); -admire::error_code +scord::error_code deploy_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage); -tl::expected +tl::expected register_pfs_storage(const server& srv, const std::string& name, enum pfs_storage::type type, const pfs_storage::ctx& ctx); -admire::error_code +scord::error_code update_pfs_storage(const server& srv, const pfs_storage& pfs_storage, - const admire::pfs_storage::ctx& new_ctx); + const scord::pfs_storage::ctx& new_ctx); -admire::error_code +scord::error_code remove_pfs_storage(const server& srv, const pfs_storage& pfs_storage); tl::expected @@ -79,6 +79,6 @@ transfer_datasets(const server& srv, const job& job, const std::vector& limits, transfer::mapping mapping); -} // namespace admire::detail +} // namespace scord::detail #endif // SCORD_ADMIRE_IMPL_HPP diff --git a/src/lib/env.hpp b/src/lib/env.hpp index 5329efdc5867df6168d0bc62930a13970f56fde8..7eab24df93267c6b02934355d07eeeefc9fe3c8a 100644 --- a/src/lib/env.hpp +++ b/src/lib/env.hpp @@ -28,12 +28,12 @@ #define LIBSCORD_ENV_PREFIX "LIBSCORD_" #define ADD_PREFIX(str) LIBSCORD_ENV_PREFIX str -namespace admire::env { +namespace scord::env { static constexpr auto LOG = ADD_PREFIX("LOG"); static constexpr auto LOG_OUTPUT = ADD_PREFIX("LOG_OUTPUT"); -} // namespace admire::env +} // namespace scord::env #endif // LIBSCORD_ENV_HPP diff --git a/src/lib/admire.cpp b/src/lib/libscord.cpp similarity index 97% rename from src/lib/admire.cpp rename to src/lib/libscord.cpp index e94384b93dae969540de1aa9292f6e9c2a85533e..b0ef7163fbab015bcdd99ed7c9c954c7ec294512 100644 --- a/src/lib/admire.cpp +++ b/src/lib/libscord.cpp @@ -22,7 +22,7 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#include +#include #include #include #include @@ -51,13 +51,13 @@ init_logger() { try { - if(const auto p = std::getenv(admire::env::LOG); + if(const auto p = std::getenv(scord::env::LOG); p && !std::string{p}.empty() && std::string{p} != "0") { - if(const auto log_file = std::getenv(admire::env::LOG_OUTPUT)) { - scord::logger::create_global_logger("libadm_iosched", "file", + if(const auto log_file = std::getenv(scord::env::LOG_OUTPUT)) { + scord::logger::create_global_logger("libscord", "file", log_file); } else { - scord::logger::create_global_logger("libadm_iosched", + scord::logger::create_global_logger("libscord", "console color"); } } @@ -198,7 +198,7 @@ rpc_registration_cb(scord::network::rpc_client* client) { } // namespace -namespace admire { +namespace scord { void ping(const server& srv) { @@ -209,9 +209,9 @@ ping(const server& srv) { } -admire::job +scord::job register_job(const server& srv, const job::resources& resources, - const job_requirements& reqs, admire::slurm_job_id slurm_job_id) { + const job_requirements& reqs, scord::slurm_job_id slurm_job_id) { const auto rv = detail::register_job(srv, resources, reqs, slurm_job_id); @@ -246,7 +246,7 @@ remove_job(const server& srv, const job& job) { } } -admire::adhoc_storage +scord::adhoc_storage register_adhoc_storage(const server& srv, const std::string& name, enum adhoc_storage::type type, const adhoc_storage::ctx& ctx) { @@ -296,7 +296,7 @@ deploy_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage) { } } -admire::pfs_storage +scord::pfs_storage register_pfs_storage(const server& srv, const std::string& name, enum pfs_storage::type type, const pfs_storage::ctx& ctx) { @@ -313,7 +313,7 @@ register_pfs_storage(const server& srv, const std::string& name, void update_pfs_storage(const server& srv, const pfs_storage& pfs_storage, - const admire::pfs_storage::ctx& pfs_storage_ctx) { + const scord::pfs_storage::ctx& pfs_storage_ctx) { const auto ec = detail::update_pfs_storage(srv, pfs_storage, pfs_storage_ctx); @@ -335,7 +335,7 @@ remove_pfs_storage(const server& srv, const pfs_storage& pfs_storage) { } } -admire::transfer +scord::transfer transfer_datasets(const server& srv, const job& job, const std::vector& sources, const std::vector& targets, @@ -776,4 +776,4 @@ get_statistics(const server& srv, ADM_job_t job, ADM_job_stats_t** stats) { return ADM_SUCCESS; } -} // namespace admire +} // namespace scord diff --git a/src/lib/admire.h b/src/lib/scord/scord.h similarity index 98% rename from src/lib/admire.h rename to src/lib/scord/scord.h index 186b8329b3556ebf90e92a1950ecefb490387bb2..fcfe881599569f5d7e1a6949e911089a929e66d4 100644 --- a/src/lib/admire.h +++ b/src/lib/scord/scord.h @@ -22,29 +22,29 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#ifndef SCORD_ADMIRE_H -#define SCORD_ADMIRE_H +#ifndef SCORD_H +#define SCORD_H #include #include #include -#include "admire_types.h" +#include #ifdef __cplusplus extern "C" { #endif -#define ADM_IOSCHED_API_VERSION "0.1.0" -#define ADM_IOSCHED_API_VERSION_MAJOR 0 -#define ADM_IOSCHED_API_VERSION_MINOR 1 -#define ADM_IOSCHED_API_VERSION_PATCH 0 +#define SCORD_API_VERSION "0.1.0" +#define SCORD_API_VERSION_MAJOR 0 +#define SCORD_API_VERSION_MINOR 1 +#define SCORD_API_VERSION_PATCH 0 /******************************************************************************/ /* Public type definitions and type-related functions */ /******************************************************************************/ -// See admire_types.h +// See scord/types.h /******************************************************************************/ @@ -473,4 +473,4 @@ ADM_strerror(ADM_return_t errnum); } // extern "C" #endif -#endif // SCORD_ADMIRE_H +#endif // SCORD_H diff --git a/src/lib/admire.hpp b/src/lib/scord/scord.hpp similarity index 90% rename from src/lib/admire.hpp rename to src/lib/scord/scord.hpp index a7106a9d71ec179b11e65de68c65d8a6b0722976..254b46c6a966204ceee0a52d7890f1c687d63656 100644 --- a/src/lib/admire.hpp +++ b/src/lib/scord/scord.hpp @@ -22,34 +22,34 @@ * SPDX-License-Identifier: GPL-3.0-or-later *****************************************************************************/ -#include +#include #include #include -#include "admire_types.hpp" +#include "scord/types.hpp" #include "net/proto/rpc_types.h" -#ifndef SCORD_ADMIRE_HPP -#define SCORD_ADMIRE_HPP +#ifndef SCORD_HPP +#define SCORD_HPP /******************************************************************************/ /* Public type definitions and type-related functions */ /******************************************************************************/ -// See admire_types.hpp +// See scord/types.hpp /******************************************************************************/ /* Public prototypes */ /******************************************************************************/ -namespace admire { +namespace scord { void ping(const server& srv); -admire::job +scord::job register_job(const server& srv, const job::resources& job_resources, - const job_requirements& reqs, admire::slurm_job_id slurm_id); + const job_requirements& reqs, scord::slurm_job_id slurm_id); void update_job(const server& srv, const job&, const job::resources& job_resources); @@ -57,7 +57,7 @@ update_job(const server& srv, const job&, const job::resources& job_resources); void remove_job(const server& srv, const job& job); -admire::adhoc_storage +scord::adhoc_storage register_adhoc_storage(const server& srv, const std::string& name, enum adhoc_storage::type type, const adhoc_storage::ctx& ctx); @@ -72,19 +72,19 @@ remove_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage); void deploy_adhoc_storage(const server& srv, const adhoc_storage& adhoc_storage); -admire::pfs_storage +scord::pfs_storage register_pfs_storage(const server& srv, const std::string& name, - enum admire::pfs_storage::type type, - const admire::pfs_storage::ctx& ctx); + enum scord::pfs_storage::type type, + const scord::pfs_storage::ctx& ctx); void update_pfs_storage(const server& srv, const pfs_storage& pfs_storage, - const admire::pfs_storage::ctx& pfs_storage_ctx); + const scord::pfs_storage::ctx& pfs_storage_ctx); void remove_pfs_storage(const server& srv, const pfs_storage& pfs_storage); -admire::transfer +scord::transfer transfer_datasets(const server& srv, const job& job, const std::vector& sources, const std::vector& targets, @@ -144,6 +144,6 @@ link_transfer_to_data_operation(const server& srv, ADM_job_t job, ADM_return_t get_statistics(const server& srv, ADM_job_t job, ADM_job_stats_t** stats); -} // namespace admire +} // namespace scord -#endif // SCORD_ADMIRE_HPP +#endif // SCORD_HPP diff --git a/src/scord-ctl/rpc_handlers.cpp b/src/scord-ctl/rpc_handlers.cpp index 274623dfb738f84a98f81b285d7e95bde892ed64..c021a46615f5f99885d3ea71d4b1ec55396bf5e6 100644 --- a/src/scord-ctl/rpc_handlers.cpp +++ b/src/scord-ctl/rpc_handlers.cpp @@ -49,12 +49,12 @@ ping(const scord::network::request& req) { rpc_id, std::quoted(__FUNCTION__), std::quoted(get_address(req))); - const auto resp = generic_response{rpc_id, admire::error_code::success}; + const auto resp = generic_response{rpc_id, scord::error_code::success}; LOGGER_INFO("rpc id: {} name: {} to: {} <= " "body: {{retval: {}}}", rpc_id, std::quoted(__FUNCTION__), - std::quoted(get_address(req)), admire::error_code::success); + std::quoted(get_address(req)), scord::error_code::success); req.respond(resp); } diff --git a/src/scord-ctl/rpc_handlers.hpp b/src/scord-ctl/rpc_handlers.hpp index 199ca912eee7b954645dc6698d18352750d46e41..a896d794450e89ad51687f839c48bf2a89b893cf 100644 --- a/src/scord-ctl/rpc_handlers.hpp +++ b/src/scord-ctl/rpc_handlers.hpp @@ -27,7 +27,7 @@ #include #include -#include +#include namespace scord::network::handlers { diff --git a/src/scord/adhoc_storage_manager.hpp b/src/scord/adhoc_storage_manager.hpp index 65d0a1f782d868bd67e0a330f1310e0ae7b9a62e..5ff62a507505c0f9a07e1051fd9c9a968b307ed4 100644 --- a/src/scord/adhoc_storage_manager.hpp +++ b/src/scord/adhoc_storage_manager.hpp @@ -26,8 +26,8 @@ #ifndef SCORD_ADHOC_STORAGE_MANAGER_HPP #define SCORD_ADHOC_STORAGE_MANAGER_HPP -#include -#include +#include +#include #include #include #include @@ -40,10 +40,10 @@ namespace scord { struct adhoc_storage_manager : scord::utils::singleton { - tl::expected, - admire::error_code> - create(enum admire::adhoc_storage::type type, const std::string& name, - const admire::adhoc_storage::ctx& ctx) { + tl::expected, + scord::error_code> + create(enum scord::adhoc_storage::type type, const std::string& name, + const scord::adhoc_storage::ctx& ctx) { static std::atomic_uint64_t current_id; std::uint64_t id = current_id++; @@ -53,23 +53,23 @@ struct adhoc_storage_manager : scord::utils::singleton { if(const auto it = m_adhoc_storages.find(id); it == m_adhoc_storages.end()) { const auto& [it_adhoc, inserted] = m_adhoc_storages.emplace( - id, std::make_shared( - admire::adhoc_storage{type, name, id, ctx})); + id, std::make_shared( + scord::adhoc_storage{type, name, id, ctx})); if(!inserted) { LOGGER_ERROR("{}: Emplace failed", __FUNCTION__); - return tl::make_unexpected(admire::error_code::snafu); + return tl::make_unexpected(scord::error_code::snafu); } return it_adhoc->second; } LOGGER_ERROR("{}: Adhoc storage '{}' already exists", __FUNCTION__, id); - return tl::make_unexpected(admire::error_code::entity_exists); + return tl::make_unexpected(scord::error_code::entity_exists); } - admire::error_code - update(std::uint64_t id, admire::adhoc_storage::ctx new_ctx) { + scord::error_code + update(std::uint64_t id, scord::adhoc_storage::ctx new_ctx) { abt::unique_lock lock(m_adhoc_storages_mutex); @@ -77,15 +77,15 @@ struct adhoc_storage_manager : scord::utils::singleton { it != m_adhoc_storages.end()) { const auto current_adhoc_info = it->second; current_adhoc_info->update(std::move(new_ctx)); - return admire::error_code::success; + return scord::error_code::success; } LOGGER_ERROR("{}: Adhoc storage '{}' does not exist", __FUNCTION__, id); - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } - tl::expected, - admire::error_code> + tl::expected, + scord::error_code> find(std::uint64_t id) { abt::shared_lock lock(m_adhoc_storages_mutex); @@ -97,47 +97,47 @@ struct adhoc_storage_manager : scord::utils::singleton { LOGGER_ERROR("Adhoc storage '{}' was not registered or was already " "deleted", id); - return tl::make_unexpected(admire::error_code::no_such_entity); + return tl::make_unexpected(scord::error_code::no_such_entity); } - admire::error_code + scord::error_code remove(std::uint64_t id) { abt::unique_lock lock(m_adhoc_storages_mutex); if(m_adhoc_storages.count(id) != 0) { m_adhoc_storages.erase(id); - return admire::error_code::success; + return scord::error_code::success; } LOGGER_ERROR("Adhoc storage '{}' was not registered or was already " "deleted", id); - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } - admire::error_code + scord::error_code add_client_info(std::uint64_t adhoc_id, - std::shared_ptr job_info) { + std::shared_ptr job_info) { if(auto am_result = find(adhoc_id); am_result.has_value()) { const auto adhoc_storage_info = am_result.value(); return adhoc_storage_info->add_client_info(std::move(job_info)); } - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } - admire::error_code + scord::error_code remove_client_info(std::uint64_t adhoc_id) { if(auto am_result = find(adhoc_id); am_result.has_value()) { const auto adhoc_storage_info = *am_result; adhoc_storage_info->remove_client_info(); - return admire::error_code::success; + return scord::error_code::success; } - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } @@ -147,7 +147,7 @@ private: mutable abt::shared_mutex m_adhoc_storages_mutex; std::unordered_map> + std::shared_ptr> m_adhoc_storages; }; diff --git a/src/scord/job_manager.hpp b/src/scord/job_manager.hpp index 2c8ead059d1067800d83bbb993940e2956ef1053..70dbb0aaac949a211780625fae5555cdc2aaa2cf 100644 --- a/src/scord/job_manager.hpp +++ b/src/scord/job_manager.hpp @@ -25,8 +25,8 @@ #ifndef SCORD_JOB_MANAGER_HPP #define SCORD_JOB_MANAGER_HPP -#include -#include +#include +#include #include #include #include @@ -40,53 +40,51 @@ namespace scord { struct job_manager : scord::utils::singleton { - tl::expected, - admire::error_code> - create(admire::slurm_job_id slurm_id, admire::job::resources job_resources, - admire::job_requirements job_requirements) { + tl::expected, scord::error_code> + create(scord::slurm_job_id slurm_id, scord::job::resources job_resources, + scord::job_requirements job_requirements) { static std::atomic_uint64_t current_id; - admire::job_id id = current_id++; + scord::job_id id = current_id++; abt::unique_lock lock(m_jobs_mutex); if(const auto it = m_jobs.find(id); it == m_jobs.end()) { const auto& [it_job, inserted] = m_jobs.emplace( id, - std::make_shared( - admire::job{id, slurm_id}, std::move(job_resources), + std::make_shared( + scord::job{id, slurm_id}, std::move(job_resources), std::move(job_requirements))); if(!inserted) { LOGGER_ERROR("{}: Emplace failed", __FUNCTION__); - return tl::make_unexpected(admire::error_code::snafu); + return tl::make_unexpected(scord::error_code::snafu); } return it_job->second; } LOGGER_ERROR("{}: Job '{}' already exists", __FUNCTION__, id); - return tl::make_unexpected(admire::error_code::entity_exists); + return tl::make_unexpected(scord::error_code::entity_exists); } - admire::error_code - update(admire::job_id id, admire::job::resources job_resources) { + scord::error_code + update(scord::job_id id, scord::job::resources job_resources) { abt::unique_lock lock(m_jobs_mutex); if(const auto it = m_jobs.find(id); it != m_jobs.end()) { const auto& current_job_info = it->second; current_job_info->update(std::move(job_resources)); - return admire::error_code::success; + return scord::error_code::success; } LOGGER_ERROR("{}: Job '{}' does not exist", __FUNCTION__, id); - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } - tl::expected, - admire::error_code> - find(admire::job_id id) { + tl::expected, scord::error_code> + find(scord::job_id id) { abt::shared_lock lock(m_jobs_mutex); @@ -95,12 +93,11 @@ struct job_manager : scord::utils::singleton { } LOGGER_ERROR("Job '{}' was not registered or was already deleted", id); - return tl::make_unexpected(admire::error_code::no_such_entity); + return tl::make_unexpected(scord::error_code::no_such_entity); } - tl::expected, - admire::error_code> - remove(admire::job_id id) { + tl::expected, scord::error_code> + remove(scord::job_id id) { abt::unique_lock lock(m_jobs_mutex); @@ -111,7 +108,7 @@ struct job_manager : scord::utils::singleton { LOGGER_ERROR("Job '{}' was not registered or was already deleted", id); - return tl::make_unexpected(admire::error_code::no_such_entity); + return tl::make_unexpected(scord::error_code::no_such_entity); } private: @@ -119,8 +116,8 @@ private: job_manager() = default; mutable abt::shared_mutex m_jobs_mutex; - std::unordered_map> + std::unordered_map> m_jobs; }; diff --git a/src/scord/pfs_storage_manager.hpp b/src/scord/pfs_storage_manager.hpp index 48b31037c274a3bdb401fab1f2825ccab2610263..de02184829f3397ac74a0ce961eff491321078cd 100644 --- a/src/scord/pfs_storage_manager.hpp +++ b/src/scord/pfs_storage_manager.hpp @@ -25,8 +25,8 @@ #ifndef SCORD_PFS_STORAGE_MANAGER_HPP #define SCORD_PFS_STORAGE_MANAGER_HPP -#include -#include +#include +#include #include #include #include @@ -39,10 +39,10 @@ namespace scord { struct pfs_storage_manager : scord::utils::singleton { - tl::expected, - admire::error_code> - create(enum admire::pfs_storage::type type, const std::string& name, - const admire::pfs_storage::ctx& ctx) { + tl::expected, + scord::error_code> + create(enum scord::pfs_storage::type type, const std::string& name, + const scord::pfs_storage::ctx& ctx) { static std::atomic_uint64_t current_id; std::uint64_t id = current_id++; @@ -52,23 +52,23 @@ struct pfs_storage_manager : scord::utils::singleton { if(const auto it = m_pfs_storages.find(id); it == m_pfs_storages.end()) { const auto& [it_pfs, inserted] = m_pfs_storages.emplace( - id, std::make_shared( - admire::pfs_storage{type, name, id, ctx})); + id, std::make_shared( + scord::pfs_storage{type, name, id, ctx})); if(!inserted) { LOGGER_ERROR("{}: Emplace failed", __FUNCTION__); - return tl::make_unexpected(admire::error_code::snafu); + return tl::make_unexpected(scord::error_code::snafu); } return it_pfs->second; } LOGGER_ERROR("{}: PFS storage '{}' already exists", __FUNCTION__, id); - return tl::make_unexpected(admire::error_code::entity_exists); + return tl::make_unexpected(scord::error_code::entity_exists); } - admire::error_code - update(std::uint64_t id, admire::pfs_storage::ctx new_ctx) { + scord::error_code + update(std::uint64_t id, scord::pfs_storage::ctx new_ctx) { abt::unique_lock lock(m_pfs_storages_mutex); @@ -76,15 +76,15 @@ struct pfs_storage_manager : scord::utils::singleton { it != m_pfs_storages.end()) { const auto current_pfs_info = it->second; current_pfs_info->update(std::move(new_ctx)); - return admire::error_code::success; + return scord::error_code::success; } LOGGER_ERROR("{}: Adhoc storage '{}' does not exist", __FUNCTION__, id); - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } - tl::expected, - admire::error_code> + tl::expected, + scord::error_code> find(std::uint64_t id) { abt::shared_lock lock(m_pfs_storages_mutex); @@ -96,24 +96,24 @@ struct pfs_storage_manager : scord::utils::singleton { LOGGER_ERROR("PFS storage '{}' was not registered or was already " "deleted", id); - return tl::make_unexpected(admire::error_code::no_such_entity); + return tl::make_unexpected(scord::error_code::no_such_entity); } - admire::error_code + scord::error_code remove(std::uint64_t id) { abt::unique_lock lock(m_pfs_storages_mutex); if(m_pfs_storages.count(id) != 0) { m_pfs_storages.erase(id); - return admire::error_code::success; + return scord::error_code::success; } LOGGER_ERROR("PFS storage '{}' was not registered or was already " "deleted", id); - return admire::error_code::no_such_entity; + return scord::error_code::no_such_entity; } private: @@ -122,7 +122,7 @@ private: mutable abt::shared_mutex m_pfs_storages_mutex; std::unordered_map> + std::shared_ptr> m_pfs_storages; }; diff --git a/src/scord/rpc_handlers.cpp b/src/scord/rpc_handlers.cpp index b128cb266dd3750b18c480b720170d3d37bec6b4..9ffe06467639f5c24119237ab71a18af183193e5 100644 --- a/src/scord/rpc_handlers.cpp +++ b/src/scord/rpc_handlers.cpp @@ -58,21 +58,21 @@ ping(const scord::network::request& req) { "body: {{}}", rpc_id, std::quoted(rpc_name), std::quoted(get_address(req))); - const auto resp = generic_response{rpc_id, admire::error_code::success}; + const auto resp = generic_response{rpc_id, scord::error_code::success}; LOGGER_INFO("rpc id: {} name: {} to: {} <= " "body: {{retval: {}}}", rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), - admire::error_code::success); + scord::error_code::success); req.respond(resp); } void register_job(const scord::network::request& req, - const admire::job::resources& job_resources, - const admire::job_requirements& job_requirements, - admire::slurm_job_id slurm_id) { + const scord::job::resources& job_resources, + const scord::job_requirements& job_requirements, + scord::slurm_job_id slurm_id) { using scord::network::get_address; @@ -85,8 +85,8 @@ register_job(const scord::network::request& req, rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), job_resources, job_requirements, slurm_id); - admire::error_code ec; - std::optional job_id; + scord::error_code ec; + std::optional job_id; auto& jm = scord::job_manager::instance(); if(const auto jm_result = @@ -121,8 +121,8 @@ register_job(const scord::network::request& req, } void -update_job(const request& req, admire::job_id job_id, - const admire::job::resources& new_resources) { +update_job(const request& req, scord::job_id job_id, + const scord::job::resources& new_resources) { using scord::network::get_address; @@ -153,7 +153,7 @@ update_job(const request& req, admire::job_id job_id, } void -remove_job(const request& req, admire::job_id job_id) { +remove_job(const request& req, scord::job_id job_id) { using scord::network::get_address; @@ -165,7 +165,7 @@ remove_job(const request& req, admire::job_id job_id) { rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), job_id); - admire::error_code ec; + scord::error_code ec; auto& jm = scord::job_manager::instance(); const auto jm_result = jm.remove(job_id); @@ -197,8 +197,8 @@ remove_job(const request& req, admire::job_id job_id) { void register_adhoc_storage(const request& req, const std::string& name, - enum admire::adhoc_storage::type type, - const admire::adhoc_storage::ctx& ctx) { + enum scord::adhoc_storage::type type, + const scord::adhoc_storage::ctx& ctx) { using scord::network::get_address; @@ -210,7 +210,7 @@ register_adhoc_storage(const request& req, const std::string& name, rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), name, type, ctx); - admire::error_code ec; + scord::error_code ec; std::optional adhoc_id; auto& adhoc_manager = scord::adhoc_storage_manager::instance(); @@ -237,7 +237,7 @@ register_adhoc_storage(const request& req, const std::string& name, void update_adhoc_storage(const request& req, std::uint64_t adhoc_id, - const admire::adhoc_storage::ctx& new_ctx) { + const scord::adhoc_storage::ctx& new_ctx) { using scord::network::get_address; @@ -282,7 +282,7 @@ remove_adhoc_storage(const request& req, std::uint64_t adhoc_id) { adhoc_id); auto& adhoc_manager = scord::adhoc_storage_manager::instance(); - admire::error_code ec = adhoc_manager.remove(adhoc_id); + scord::error_code ec = adhoc_manager.remove(adhoc_id); if(!ec) { LOGGER_ERROR("rpc id: {} error_msg: \"Error removing job: {}\"", rpc_id, @@ -312,7 +312,7 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id) { rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), adhoc_id); - auto ec = admire::error_code::success; + auto ec = scord::error_code::success; auto& adhoc_manager = scord::adhoc_storage_manager::instance(); if(const auto am_result = adhoc_manager.find(adhoc_id); @@ -320,7 +320,7 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id) { const auto& storage_info = am_result.value(); const auto adhoc_storage = storage_info->adhoc_storage(); - if(adhoc_storage.type() == admire::adhoc_storage::type::gekkofs) { + if(adhoc_storage.type() == scord::adhoc_storage::type::gekkofs) { const auto adhoc_ctx = adhoc_storage.context(); /* Number of nodes */ const std::string nodes = @@ -354,7 +354,7 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id) { break; } case -1: { - ec = admire::error_code::other; + ec = scord::error_code::other; LOGGER_ERROR("rpc id: {} name: {} to: {} <= " "body: {{retval: {}}}", rpc_id, std::quoted(rpc_name), @@ -368,12 +368,12 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id) { LOGGER_ERROR( "rpc id: {} error_msg: \"Error waitpid code: {}\"", rpc_id, retwait); - ec = admire::error_code::other; + ec = scord::error_code::other; } else { if(WEXITSTATUS(wstatus) != 0) { - ec = admire::error_code::other; + ec = scord::error_code::other; } else { - ec = admire::error_code::success; + ec = scord::error_code::success; } } break; @@ -401,8 +401,8 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id) { void register_pfs_storage(const request& req, const std::string& name, - enum admire::pfs_storage::type type, - const admire::pfs_storage::ctx& ctx) { + enum scord::pfs_storage::type type, + const scord::pfs_storage::ctx& ctx) { using scord::network::get_address; @@ -414,7 +414,7 @@ register_pfs_storage(const request& req, const std::string& name, rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), name, type, ctx); - admire::error_code ec; + scord::error_code ec; std::optional pfs_id = 0; auto& pfs_manager = scord::pfs_storage_manager::instance(); @@ -440,7 +440,7 @@ register_pfs_storage(const request& req, const std::string& name, void update_pfs_storage(const request& req, std::uint64_t pfs_id, - const admire::pfs_storage::ctx& new_ctx) { + const scord::pfs_storage::ctx& new_ctx) { using scord::network::get_address; @@ -484,7 +484,7 @@ remove_pfs_storage(const request& req, std::uint64_t pfs_id) { pfs_id); auto& pfs_manager = scord::pfs_storage_manager::instance(); - admire::error_code ec = pfs_manager.remove(pfs_id); + scord::error_code ec = pfs_manager.remove(pfs_id); if(!ec) { LOGGER_ERROR("rpc id: {} error_msg: \"Error removing pfs storage: {}\"", @@ -502,11 +502,11 @@ remove_pfs_storage(const request& req, std::uint64_t pfs_id) { } void -transfer_datasets(const request& req, admire::job_id job_id, - const std::vector& sources, - const std::vector& targets, - const std::vector& limits, - enum admire::transfer::mapping mapping) { +transfer_datasets(const request& req, scord::job_id job_id, + const std::vector& sources, + const std::vector& targets, + const std::vector& limits, + enum scord::transfer::mapping mapping) { using scord::network::get_address; @@ -519,7 +519,7 @@ transfer_datasets(const request& req, admire::job_id job_id, rpc_id, std::quoted(rpc_name), std::quoted(get_address(req)), job_id, sources, targets, limits, mapping); - admire::error_code ec; + scord::error_code ec; std::optional tx_id; diff --git a/src/scord/rpc_handlers.hpp b/src/scord/rpc_handlers.hpp index d901fb3917f4f8b82cb9fad0d253783c183e27a5..285bb962ec9245d592ca4eed503e319470bd4658 100644 --- a/src/scord/rpc_handlers.hpp +++ b/src/scord/rpc_handlers.hpp @@ -27,7 +27,7 @@ #include #include -#include +#include namespace scord::network::handlers { @@ -36,24 +36,24 @@ ping(const scord::network::request& req); void register_job(const scord::network::request& req, - const admire::job::resources& job_resources, - const admire::job_requirements& job_requirements, - admire::slurm_job_id slurm_id); + const scord::job::resources& job_resources, + const scord::job_requirements& job_requirements, + scord::slurm_job_id slurm_id); void -update_job(const request& req, admire::job_id job_id, - const admire::job::resources& new_resources); +update_job(const request& req, scord::job_id job_id, + const scord::job::resources& new_resources); void -remove_job(const request& req, admire::job_id job_id); +remove_job(const request& req, scord::job_id job_id); void register_adhoc_storage(const request& req, const std::string& name, - enum admire::adhoc_storage::type type, - const admire::adhoc_storage::ctx& ctx); + enum scord::adhoc_storage::type type, + const scord::adhoc_storage::ctx& ctx); void update_adhoc_storage(const request& req, std::uint64_t adhoc_id, - const admire::adhoc_storage::ctx& new_ctx); + const scord::adhoc_storage::ctx& new_ctx); void remove_adhoc_storage(const request& req, std::uint64_t adhoc_id); @@ -63,22 +63,22 @@ deploy_adhoc_storage(const request& req, std::uint64_t adhoc_id); void register_pfs_storage(const request& req, const std::string& name, - enum admire::pfs_storage::type type, - const admire::pfs_storage::ctx& ctx); + enum scord::pfs_storage::type type, + const scord::pfs_storage::ctx& ctx); void update_pfs_storage(const request& req, std::uint64_t pfs_id, - const admire::pfs_storage::ctx& new_ctx); + const scord::pfs_storage::ctx& new_ctx); void remove_pfs_storage(const request& req, std::uint64_t pfs_id); void -transfer_datasets(const request& req, admire::job_id job_id, - const std::vector& sources, - const std::vector& targets, - const std::vector& limits, - enum admire::transfer::mapping mapping); +transfer_datasets(const request& req, scord::job_id job_id, + const std::vector& sources, + const std::vector& targets, + const std::vector& limits, + enum scord::transfer::mapping mapping); } // namespace scord::network::handlers diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt index 679503c670b6c50a9532cc857b2885659f9a5b40..62f61732978fb4d896edc7b2629b79a26d51e4a9 100644 --- a/tests/CMakeLists.txt +++ b/tests/CMakeLists.txt @@ -25,7 +25,7 @@ add_executable(tests) target_sources(tests PRIVATE test.cpp) -target_link_libraries(tests PRIVATE Catch2::Catch2WithMain adm_iosched) +target_link_libraries(tests PRIVATE Catch2::Catch2WithMain libscord) include(Catch) catch_discover_tests(tests) diff --git a/tests/test.cpp b/tests/test.cpp index f7830dc8a912daf27ffda8a7b7af38fa7cf16833..31cdd319e82d4b8c9d082a665b97f3879598f5c6 100644 --- a/tests/test.cpp +++ b/tests/test.cpp @@ -23,7 +23,7 @@ *****************************************************************************/ #include -#include +#include #include SCENARIO("Error messages can be printed", "[lib][ADM_strerror]") {