Commit d3e171ad authored by Ramon Nou's avatar Ramon Nou
Browse files

remove GekkoFS daemon from testing

parent 30ed3913

examples/c/ADM_deploy_adhoc_storage.c

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



    // 2. Register the adhoc storage

    if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_GEKKOFS,

    if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_DATACLAY,

                                  adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) {

        fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n",

                ADM_strerror(ret));

examples/cxx/ADM_register_adhoc_storage.cpp

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


    try {

        const auto adhoc_storage = admire::register_adhoc_storage(

                server, name, admire::storage::type::gekkofs,

                server, name, admire::storage::type::dataclay,

                adhoc_storage_ctx);



        fmt::print(stdout,

src/scord/rpc_handlers.cpp

+9 −9
Original line number Diff line number Diff line
@@ -448,12 +448,12 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 
 

    const auto rpc_id = remote_procedure::new_id();

    LOGGER_INFO("rpc id: {} name: {} from: {} => "

                "body: {{adhoc_ctx: {}}}",

                "body: {{adhoc_storage: {}}}",

                rpc_id, std::quoted(__FUNCTION__), std::quoted(get_address(h)),

                ctx);

                admire::adhoc_storage(adhoc_storage));



    admire::error_code ec;

    ec = admire::error_code::other;

    ec = admire::error_code::success;



    out.retval = ec;
@@ -502,16 +502,16 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 
            }

            default: {

                ec = ec.success;

                LOGGER_INFO("rpc id: {} name: {} to: {} <= "

                "body: {{retval: {}}}",

                rpc_id, std::quoted(__FUNCTION__), std::quoted(get_address(h)),

                ec);

               

                break;

            }

        }

    }

    

    out.retval = ec;

    LOGGER_INFO("rpc id: {} name: {} to: {} <= "

        "body: {{retval: {}}}",

        rpc_id, std::quoted(__FUNCTION__), std::quoted(get_address(h)),

        ec);

        

    ret = margo_respond(h, &out);

    assert(ret == HG_SUCCESS);