Update examples (bffc01fe) · Commits · eu / ADMIRE / scord

examples/c/ADM_update_adhoc_storage.c

+17 −3

Original line number	Diff line number	Diff line
		@@ -78,12 +78,12 @@ main(int argc, char* argv[]) {
		fprintf(stdout, "ADM_register_adhoc_storage() remote procedure completed "
		"successfully\n");

		ADM_adhoc_context_t ctx_updated = ADM_adhoc_context_create(
		ADM_adhoc_context_t new_ctx = ADM_adhoc_context_create(
		ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, adhoc_resources,
		200, false);
		assert(ctx_updated);
		assert(new_ctx);

		ret = ADM_update_adhoc_storage(server, ctx_updated, adhoc_storage);
		ret = ADM_update_adhoc_storage(server, new_ctx, adhoc_storage);

		if(ret != ADM_SUCCESS) {
		fprintf(stderr,
		@@ -98,6 +98,20 @@ main(int argc, char* argv[]) {
		"successfully\n");

		cleanup:
		for(int i = 0; i < NINPUTS; ++i) {
		ADM_dataset_destroy(inputs[i]);
		}

		for(int i = 0; i < NOUTPUTS; ++i) {
		ADM_dataset_destroy(outputs[i]);
		}

		ADM_storage_destroy(adhoc_storage);

		ADM_adhoc_context_destroy(ctx);

		ADM_adhoc_context_destroy(new_ctx);

		ADM_server_destroy(server);
		exit(exit_status);
		}

examples/cxx/ADM_update_adhoc_storage.cpp

+15 −14

Original line number	Diff line number	Diff line
		@@ -43,6 +43,7 @@ main(int argc, char* argv[]) {
		admire::server server{"tcp", argv[1]};

		const auto adhoc_nodes = prepare_nodes(NADHOC_NODES);
		const auto new_adhoc_nodes = prepare_nodes(NADHOC_NODES * 2);
		const auto inputs = prepare_datasets("input-dataset-{}", NINPUTS);
		const auto outputs = prepare_datasets("output-dataset-{}", NOUTPUTS);

		@@ -52,32 +53,32 @@ main(int argc, char* argv[]) {
		admire::adhoc_storage::access_type::read_write,
		admire::adhoc_storage::resources{adhoc_nodes}, 100, false};

		const auto adhoc_storage_ctx_updated = admire::adhoc_storage::ctx{
		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{adhoc_nodes}, 200, false};

		ADM_return_t ret = ADM_SUCCESS;
		admire::adhoc_storage::resources{new_adhoc_nodes}, 200, false};

		try {
		const auto adhoc_storage = admire::register_adhoc_storage(
		server, name, admire::storage::type::gekkofs,
		adhoc_storage_ctx);
		ret = admire::update_adhoc_storage(server, adhoc_storage_ctx_updated,
		adhoc_storage);
		fmt::print(stdout,
		"ADM_update_adhoc_storage() remote procedure completed "
		"successfully\n");
		} catch(const std::exception& e) {

		const auto ret = admire::update_adhoc_storage(
		server, new_adhoc_storage_ctx, adhoc_storage);

		if(!ret) {
		fmt::print(stderr, "FATAL: ADM_update_adhoc_storage() failed: {}\n",
		e.what());
		ret.message());
		exit(EXIT_FAILURE);
		}

		if(ret != ADM_SUCCESS) {
		fmt::print(stdout,
		"ADM_update_adhoc_storage() remote procedure not completed "
		"ADM_update_adhoc_storage() remote procedure completed "
		"successfully\n");
		exit(EXIT_SUCCESS);
		} catch(const std::exception& e) {
		fmt::print(stderr, "FATAL: ADM_register_adhoc_storage() failed: {}\n",
		e.what());
		exit(EXIT_FAILURE);
		}
		}

src/lib/c_wrapper.cpp

+2 −3

Original line number	Diff line number	Diff line
		@@ -101,14 +101,13 @@ ADM_register_adhoc_storage(ADM_server_t server, const char* name,
		}

		ADM_return_t
		ADM_update_adhoc_storage(ADM_server_t server,
		ADM_adhoc_context_t adhoc_storage_ctx,
		ADM_update_adhoc_storage(ADM_server_t server, ADM_adhoc_context_t ctx,
		ADM_storage_t adhoc_storage) {

		const admire::server srv{server};

		return admire::detail::update_adhoc_storage(
		srv, admire::adhoc_storage::ctx{adhoc_storage_ctx},
		srv, admire::adhoc_storage::ctx{ctx},
		admire::adhoc_storage{adhoc_storage});
		}