Verified Commit 4d6a60e9 authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

examples: Remove calls to ADM_storage_create()

parent f6afefcb

examples/c/ADM_cancel_transfer.c

+15 −5
Original line number Diff line number Diff line
@@ -68,14 +68,24 @@ main(int argc, char* argv[]) { 
            100, false);

    assert(ctx);



    ADM_storage_t st = ADM_storage_create("foobar", ADM_STORAGE_GEKKOFS, ctx);

    assert(st);

    const char* user_id = "adhoc_storage_42";



    ADM_job_requirements_t reqs =

            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    ADM_storage_t adhoc_storage;

    ADM_return_t ret =

            ADM_register_adhoc_storage(server, user_id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout, "ADM_register_adhoc_storage() remote procedure not "

                        "completed successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    ADM_job_requirements_t reqs = ADM_job_requirements_create(

            inputs, NINPUTS, outputs, NOUTPUTS, adhoc_storage);

    assert(reqs);



    ADM_return_t ret = ADM_register_job(server, job_resources, reqs, &job);

    ret = ADM_register_job(server, job_resources, reqs, &job);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout, "ADM_register_job() remote procedure not completed "

examples/c/ADM_connect_data_operation.c

+16 −5
Original line number Diff line number Diff line
@@ -64,18 +64,29 @@ main(int argc, char* argv[]) { 
            100, false);

    assert(ctx);



    ADM_storage_t st = ADM_storage_create("foobar", ADM_STORAGE_GEKKOFS, ctx);

    assert(st);

    const char* user_id = "adhoc_storage_42";



    ADM_storage_t adhoc_storage;

    ADM_return_t ret =

            ADM_register_adhoc_storage(server, user_id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

                "ADM_register_adhoc_storage() remote procedure not completed "

                "successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    ADM_job_resources_t job_resources =

            ADM_job_resources_create(job_nodes, NJOB_NODES);

    assert(job_resources);



    ADM_job_requirements_t reqs =

            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    ADM_job_requirements_t reqs = ADM_job_requirements_create(

            inputs, NINPUTS, outputs, NOUTPUTS, adhoc_storage);

    assert(reqs);



    ADM_return_t ret = ADM_register_job(server, job_resources, reqs, &job);

    ret = ADM_register_job(server, job_resources, reqs, &job);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout, "ADM_register_job() remote procedure not completed "

examples/c/ADM_define_data_operation.c

+16 −5
Original line number Diff line number Diff line
@@ -69,14 +69,25 @@ main(int argc, char* argv[]) { 
            100, false);

    assert(ctx);



    ADM_storage_t st = ADM_storage_create("foobar", ADM_STORAGE_GEKKOFS, ctx);

    assert(st);

    const char* user_id = "adhoc_storage_42";



    ADM_job_requirements_t reqs =

            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    ADM_storage_t adhoc_storage;

    ADM_return_t ret =

            ADM_register_adhoc_storage(server, user_id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

                "ADM_register_adhoc_storage() remote procedure not completed "

                "successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    ADM_job_requirements_t reqs = ADM_job_requirements_create(

            inputs, NINPUTS, outputs, NOUTPUTS, adhoc_storage);

    assert(reqs);



    ADM_return_t ret = ADM_register_job(server, job_resources, reqs, &job);

    ret = ADM_register_job(server, job_resources, reqs, &job);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout, "ADM_register_job() remote procedure not completed "

examples/c/ADM_deploy_adhoc_storage.c

+0 −7
Original line number Diff line number Diff line
@@ -60,13 +60,6 @@ main(int argc, char* argv[]) { 
            100, false);

    assert(ctx);



    ADM_storage_t st = ADM_storage_create("foobar", ADM_STORAGE_GEKKOFS, ctx);

    assert(st);



    ADM_job_requirements_t reqs =

            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    assert(reqs);



    const char* user_id = "adhoc_storage_42";



    ADM_storage_t adhoc_storage;

examples/c/ADM_finalize_data_operation.c

+16 −5
Original line number Diff line number Diff line
@@ -65,18 +65,29 @@ main(int argc, char* argv[]) { 
            100, false);

    assert(ctx);



    ADM_storage_t st = ADM_storage_create("foobar", ADM_STORAGE_GEKKOFS, ctx);

    assert(st);

    const char* user_id = "adhoc_storage_42";



    ADM_storage_t adhoc_storage;

    ADM_return_t ret =

            ADM_register_adhoc_storage(server, user_id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

                "ADM_register_adhoc_storage() remote procedure not completed "

                "successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    ADM_job_resources_t job_resources =

            ADM_job_resources_create(job_nodes, NJOB_NODES);

    assert(job_resources);



    ADM_job_requirements_t reqs =

            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    ADM_job_requirements_t reqs = ADM_job_requirements_create(

            inputs, NINPUTS, outputs, NOUTPUTS, adhoc_storage);

    assert(reqs);



    ADM_return_t ret = ADM_register_job(server, job_resources, reqs, &job);

    ret = ADM_register_job(server, job_resources, reqs, &job);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout, "ADM_register_job() remote procedure not completed "