Verified Commit e81cbdaa authored by ANA MANZANO RODRIGUEZ's avatar ANA MANZANO RODRIGUEZ Committed by Alberto Miranda
Browse files

ADM_update_adhoc_storage examples updated

parent 71b2a557

examples/c/ADM_update_adhoc_storage.c

+3 −4
Original line number Diff line number Diff line
@@ -79,12 +79,11 @@ main(int argc, char* argv[]) { 
                    "successfully\n");



    ADM_adhoc_context_t ctx_updated = ADM_adhoc_context_create(

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 42, 200, false);

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, adhoc_resources,

            200, false);

    assert(ctx_updated);



    const auto adhoc_storage_id = "id";



    ret = ADM_update_adhoc_storage(server, ctx_updated, adhoc_storage_id);

    ret = ADM_update_adhoc_storage(server, ctx_updated, adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stderr,

examples/cxx/ADM_update_adhoc_storage.cpp

+18 −22
Original line number Diff line number Diff line
@@ -24,7 +24,9 @@ 


#include <fmt/format.h>

#include <admire.hpp>

#include "common.hpp"



#define NADHOC_NODES 25

#define NINPUTS      10

#define NOUTPUTS     5
@@ -40,35 +42,32 @@ main(int argc, char* argv[]) { 


    admire::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);



    auto p = std::make_unique<admire::adhoc_storage>(

            admire::storage::type::gekkofs, "foobar",

            admire::adhoc_storage::execution_mode::separate_new,

            admire::adhoc_storage::access_type::read_write, 42, 100, false);



    admire::job_requirements reqs(inputs, outputs, std::move(p));



    std::string user_id = "adhoc_storage_42";



    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, 42, 100, false};

            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{

            admire::adhoc_storage::execution_mode::separate_new,

            admire::adhoc_storage::access_type::read_write, 42, 200, false};

            admire::adhoc_storage::access_type::read_write,

            admire::adhoc_storage::resources{adhoc_nodes}, 200, false};



    ADM_return_t ret = ADM_SUCCESS;



    try {

        const auto job = admire::register_job(server, reqs);



        const auto adhoc_storage = admire::register_adhoc_storage(

                server, job, user_id, adhoc_storage_ctx);



        /*const auto adhoc_storage_updated = admire::update_adhoc_storage(

                server, adhoc_storage_ctx_updated, 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) {

        fmt::print(stderr, "FATAL: ADM_update_adhoc_storage() failed: {}\n",

                   e.what());
@@ -81,7 +80,4 @@ main(int argc, char* argv[]) { 
                   "successfully\n");

        exit(EXIT_FAILURE);

    }



    fmt::print(stdout, "ADM_update_adhoc_storage() remote procedure completed "

                       "successfully\n");

}