Commit 27279c27 authored by Ramon Nou's avatar Ramon Nou
Browse files

WIP 

WIP tests

Lock and scheduling output

Updated Thread

Move scheduling to processing thread (one shot)

Thallium threading

Updated stager_address

Stager logger

Added stager contact point in scord log

remove stager_address

remove stager_addrss from cpp
parent b5b4680e

examples/c/ADM_cancel_transfer.c

+1 −0
Original line number Diff line number Diff line
@@ -69,6 +69,7 @@ main(int argc, char* argv[]) { 
            ADM_adhoc_resources_create(adhoc_nodes, NADHOC_NODES);

    assert(adhoc_resources);



    

    ADM_adhoc_context_t 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);

examples/c/ADM_finalize_data_operation.c

+1 −0
Original line number Diff line number Diff line
@@ -65,6 +65,7 @@ main(int argc, char* argv[]) { 
            ADM_adhoc_resources_create(adhoc_nodes, NADHOC_NODES);

    assert(adhoc_resources);



    

    ADM_adhoc_context_t 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);

examples/c/ADM_register_adhoc_storage.c

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


    // adhoc information

    const char* adhoc_name = "adhoc_storage_42";

    

    ADM_node_t* adhoc_nodes = NULL;

    ADM_adhoc_resources_t adhoc_resources = NULL;

    ADM_adhoc_context_t adhoc_ctx = NULL;

examples/c/ADM_register_job.c

+2 −0
Original line number Diff line number Diff line
@@ -63,6 +63,8 @@ main(int argc, char* argv[]) { 
    ADM_dataset_route_t* outputs = NULL;

    ADM_dataset_route_t* expected_outputs = NULL;



    // stager information

    

    // Let's prepare all the information required by the API calls.

    // ADM_register_job() often requires an adhoc storage to have been

    // registered onto the system, so let's prepare first the data required

examples/c/ADM_remove_job.c

+3 −0
Original line number Diff line number Diff line
@@ -69,6 +69,9 @@ main(int argc, char* argv[]) { 
            ADM_adhoc_resources_create(adhoc_nodes, NADHOC_NODES);

    assert(adhoc_resources);





    



    ADM_adhoc_context_t 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);