Verified Commit 7f583b6c authored by ANA MANZANO RODRIGUEZ's avatar ANA MANZANO RODRIGUEZ Committed by Alberto Miranda
Browse files

c examples updated

parent 0a53bb0a

examples/c/ADM_deploy_adhoc_storage.c

+25 −1
Original line number Diff line number Diff line
@@ -26,6 +26,10 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5



int

main(int argc, char* argv[]) {
@@ -39,6 +43,12 @@ main(int argc, char* argv[]) { 
    int exit_status = EXIT_SUCCESS;

    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t* inputs = prepare_datasets("input-dataset-%d", NINPUTS);

    assert(inputs);

    ADM_dataset_t* outputs = prepare_datasets("output-dataset-%d", NOUTPUTS);

    assert(outputs);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 42, 100, false);

    assert(ctx);
@@ -46,9 +56,23 @@ main(int argc, char* argv[]) { 
    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);



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



    if(ret != ADM_SUCCESS) {

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

                        "successfully\n");

        exit_status = EXIT_FAILURE;

    }



    const char* id = "id"; 



    ADM_storage_t adhoc_storage;



    ADM_return_t ret = ADM_register_adhoc_storage(server, ctx, &adhoc_storage);

    ret = ADM_register_adhoc_storage(server, job, id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

examples/c/ADM_register_adhoc_storage.c

+12 −1
Original line number Diff line number Diff line
@@ -43,6 +43,7 @@ main(int argc, char* argv[]) { 
    int exit_status = EXIT_SUCCESS;

    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t* inputs = prepare_datasets("input-dataset-%d", NINPUTS);

    assert(inputs);

    ADM_dataset_t* outputs = prepare_datasets("output-dataset-%d", NOUTPUTS);
@@ -59,9 +60,19 @@ main(int argc, char* argv[]) { 
            ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);

    assert(reqs);



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



    if(ret != ADM_SUCCESS) {

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

                        "successfully\n");

        exit_status = EXIT_FAILURE;

    }



    const char* id = "id";    



    ADM_storage_t adhoc_storage;



    ADM_return_t ret = ADM_register_adhoc_storage(server, ctx, &adhoc_storage);

    ret = ADM_register_adhoc_storage(server, job, id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

examples/c/ADM_remove_adhoc_storage.c

+25 −1
Original line number Diff line number Diff line
@@ -26,6 +26,10 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5



int

main(int argc, char* argv[]) {
@@ -39,6 +43,12 @@ main(int argc, char* argv[]) { 
    int exit_status = EXIT_SUCCESS;

    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t* inputs = prepare_datasets("input-dataset-%d", NINPUTS);

    assert(inputs);

    ADM_dataset_t* outputs = prepare_datasets("output-dataset-%d", NOUTPUTS);

    assert(outputs);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 42, 100, false);

    assert(ctx);
@@ -46,8 +56,22 @@ main(int argc, char* argv[]) { 
    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);



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



    if(ret != ADM_SUCCESS) {

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

                        "successfully\n");

        exit_status = EXIT_FAILURE;

    }



    const char* id = "id"; 



    ADM_storage_t adhoc_storage;

    ADM_return_t ret = ADM_register_adhoc_storage(server, ctx, &adhoc_storage);

    ret = ADM_register_adhoc_storage(server, job, id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

examples/c/ADM_update_adhoc_storage.c

+25 −1
Original line number Diff line number Diff line
@@ -26,6 +26,10 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5



int

main(int argc, char* argv[]) {
@@ -39,6 +43,12 @@ main(int argc, char* argv[]) { 
    int exit_status = EXIT_SUCCESS;

    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t* inputs = prepare_datasets("input-dataset-%d", NINPUTS);

    assert(inputs);

    ADM_dataset_t* outputs = prepare_datasets("output-dataset-%d", NOUTPUTS);

    assert(outputs);



    ADM_adhoc_context_t ctx = ADM_adhoc_context_create(

            ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 42, 100, false);

    assert(ctx);
@@ -46,8 +56,22 @@ main(int argc, char* argv[]) { 
    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);



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



    if(ret != ADM_SUCCESS) {

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

                        "successfully\n");

        exit_status = EXIT_FAILURE;

    }



    const char* id = "id";    



    ADM_storage_t adhoc_storage;

    ADM_return_t ret = ADM_register_adhoc_storage(server, ctx, &adhoc_storage);

    ret = ADM_register_adhoc_storage(server, job, id, ctx, &adhoc_storage);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,