Loading examples/cxx/ADM_cancel_transfer.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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()); Loading examples/cxx/ADM_connect_data_operation.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -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{}; Loading @@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { ret = admire::connect_data_operation(server, job, input, output, 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", Loading examples/cxx/ADM_define_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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"; Loading @@ -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()); Loading examples/cxx/ADM_deploy_adhoc_storage.cpp +8 −8 Original line number Diff line number Diff line Loading @@ -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, Loading examples/cxx/ADM_finalize_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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{}; Loading @@ -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()); Loading Loading
examples/cxx/ADM_cancel_transfer.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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()); Loading
examples/cxx/ADM_connect_data_operation.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -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{}; Loading @@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ADM_return_t ret = ADM_SUCCESS; try { ret = admire::connect_data_operation(server, job, input, output, 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", Loading
examples/cxx/ADM_define_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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"; Loading @@ -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()); Loading
examples/cxx/ADM_deploy_adhoc_storage.cpp +8 −8 Original line number Diff line number Diff line Loading @@ -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, Loading
examples/cxx/ADM_finalize_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -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{}; Loading @@ -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()); Loading