Verified Commit 11f5a5a5 authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

[API] Add data stager info to ADM_adhoc_context_t

parent 4f4e601c

examples/c/ADM_cancel_transfer.c

+2 −2
Original line number Diff line number Diff line
@@ -69,8 +69,8 @@ main(int argc, char* argv[]) { 
    assert(adhoc_resources);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            cli_args.controller_address, ADM_ADHOC_MODE_SEPARATE_NEW,

            ADM_ADHOC_ACCESS_RDWR, 100, false);

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 100, false);

    assert(ctx);



    const char* name = "adhoc_storage_42";

examples/c/ADM_connect_data_operation.c

+2 −2
Original line number Diff line number Diff line
@@ -65,8 +65,8 @@ main(int argc, char* argv[]) { 
    assert(adhoc_resources);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            cli_args.controller_address, ADM_ADHOC_MODE_SEPARATE_NEW,

            ADM_ADHOC_ACCESS_RDWR, 100, false);

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 100, false);

    assert(ctx);



    const char* name = "adhoc_storage_42";

examples/c/ADM_define_data_operation.c

+2 −2
Original line number Diff line number Diff line
@@ -70,8 +70,8 @@ main(int argc, char* argv[]) { 
    assert(adhoc_resources);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            cli_args.controller_address, ADM_ADHOC_MODE_SEPARATE_NEW,

            ADM_ADHOC_ACCESS_RDWR, 100, false);

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 100, false);

    assert(ctx);



    const char* name = "adhoc_storage_42";

examples/c/ADM_deploy_adhoc_storage.c

+6 −6
Original line number Diff line number Diff line
@@ -82,9 +82,9 @@ main(int argc, char* argv[]) { 
    }



    // 3. the adhoc storage execution context

    adhoc_ctx = ADM_adhoc_context_create(cli_args.controller_address,

                                         ADM_ADHOC_MODE_SEPARATE_NEW,

                                         ADM_ADHOC_ACCESS_RDWR, 100, false);

    adhoc_ctx = ADM_adhoc_context_create(

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 100, false);



    if(adhoc_ctx == NULL) {

        fprintf(stderr, "Fatal error preparing adhoc context\n");
@@ -115,9 +115,9 @@ main(int argc, char* argv[]) { 
    // system, let's prepare a new execution context for the adhoc

    // storage system



    new_adhoc_ctx = ADM_adhoc_context_create(cli_args.controller_address,

                                             ADM_ADHOC_MODE_SEPARATE_NEW,

                                             ADM_ADHOC_ACCESS_RDWR, 200, false);

    new_adhoc_ctx = ADM_adhoc_context_create(

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 200, false);



    if(new_adhoc_ctx == NULL) {

        fprintf(stderr, "Fatal error preparing new adhoc context\n");

examples/c/ADM_finalize_data_operation.c

+2 −2
Original line number Diff line number Diff line
@@ -65,8 +65,8 @@ main(int argc, char* argv[]) { 
    assert(adhoc_resources);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            cli_args.controller_address, ADM_ADHOC_MODE_SEPARATE_NEW,

            ADM_ADHOC_ACCESS_RDWR, 100, false);

            cli_args.controller_address, cli_args.data_stager_address,

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 100, false);

    assert(ctx);



    const char* name = "adhoc_storage_42";