Commit 03a981c5 authored by Ramon Nou's avatar Ramon Nou Committed by Ramon Nou
Browse files

Updated deploy test

parent dc9aef79

examples/cxx/ADM_deploy_adhoc_storage.cpp

+5 −1
Original line number Diff line number Diff line
@@ -38,7 +38,11 @@ main(int argc, char* argv[]) { 


    admire::server server{"tcp", argv[1]};



    ADM_storage_t adhoc_storage{};

    admire::adhoc_storage adhoc_storage(

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

        admire::adhoc_storage::execution_mode::separate_new,

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



    ADM_return_t ret = ADM_SUCCESS;



    try {

src/common/net/proto/rpc_types.h

+1 −1
Original line number Diff line number Diff line
@@ -374,7 +374,7 @@ MERCURY_GEN_PROC( 
);



/// ADM_deploy_adhoc_storage

MERCURY_GEN_PROC(ADM_deploy_adhoc_storage_in_t, ((ADM_storage_t) (reqs)))

MERCURY_GEN_PROC(ADM_deploy_adhoc_storage_in_t, ((ADM_storage_t) (adhoc_storage)))



MERCURY_GEN_PROC(ADM_deploy_adhoc_storage_out_t, ((int32_t) (retval)))

src/scord/rpc_handlers.cpp

+15 −1
Original line number Diff line number Diff line
@@ -437,13 +437,27 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 
    [[maybe_unused]] margo_instance_id mid = margo_hg_handle_get_instance(h);



    ret = margo_get_input(h, &in);



    auto adhoc_storage = in.adhoc_storage;



    assert(ret == HG_SUCCESS);



    out.retval = -1;



    LOGGER_INFO("ADM_deploy_adhoc_storage()");



    /* Look inside adhoc_storage and launch gkfs script */



    if (adhoc_storage->s_type == ADM_STORAGE_GEKKOFS)

    {

    /* Extract Job ID -> SLURM_JOB_ID */



    /* Extract paths */



    /* Launch script */



        out.retval = 0;

    }

    

    ret = margo_respond(h, &out);

    assert(ret == HG_SUCCESS);