Verified Commit 7bb21ecc authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

Refactor common code from C tests into library

parent 18a00376

examples/c/ADM_cancel_transfer.c

+7 −20
Original line number Diff line number Diff line
@@ -26,6 +26,7 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5
@@ -43,25 +44,10 @@ main(int argc, char* argv[]) { 
    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t inputs[NINPUTS];



    for(int i = 0; i < NINPUTS; ++i) {

        const char* pattern = "input-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        inputs[i] = ADM_dataset_create(id);

    }



    ADM_dataset_t outputs[NOUTPUTS];



    for(int i = 0; i < NOUTPUTS; ++i) {

        const char* pattern = "output-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }

    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);
@@ -109,7 +95,8 @@ main(int argc, char* argv[]) { 
                    "successfully\n");



cleanup:



    ADM_server_destroy(server);

    destroy_datasets(inputs, NINPUTS);

    destroy_datasets(outputs, NOUTPUTS);

    exit(exit_status);

}

examples/c/ADM_connect_data_operation.c

+5 −20
Original line number Diff line number Diff line
@@ -26,6 +26,7 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5
@@ -43,26 +44,10 @@ main(int argc, char* argv[]) { 
    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;



    ADM_dataset_t inputs[NINPUTS];



    for(int i = 0; i < NINPUTS; ++i) {

        const char* pattern = "input-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        inputs[i] = ADM_dataset_create(id);

    }



    ADM_dataset_t outputs[NOUTPUTS];



    for(int i = 0; i < NOUTPUTS; ++i) {

        const char* pattern = "output-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }

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

examples/c/ADM_define_data_operation.c

+5 −19
Original line number Diff line number Diff line
@@ -26,6 +26,7 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5
@@ -44,25 +45,10 @@ main(int argc, char* argv[]) { 
    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t inputs[NINPUTS];



    for(int i = 0; i < NINPUTS; ++i) {

        const char* pattern = "input-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        inputs[i] = ADM_dataset_create(id);

    }



    ADM_dataset_t outputs[NOUTPUTS];



    for(int i = 0; i < NOUTPUTS; ++i) {

        const char* pattern = "output-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }

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

examples/c/ADM_deploy_adhoc_storage.c

+0 −3
Original line number Diff line number Diff line
@@ -27,9 +27,6 @@ 
#include <admire.h>

#include <assert.h>



#define NINPUTS  10

#define NOUTPUTS 5



int

main(int argc, char* argv[]) {

examples/c/ADM_finalize_data_operation.c

+5 −19
Original line number Diff line number Diff line
@@ -26,6 +26,7 @@ 
#include <stdio.h>

#include <admire.h>

#include <assert.h>

#include "common.h"



#define NINPUTS  10

#define NOUTPUTS 5
@@ -44,25 +45,10 @@ main(int argc, char* argv[]) { 
    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;

    ADM_dataset_t inputs[NINPUTS];



    for(int i = 0; i < NINPUTS; ++i) {

        const char* pattern = "input-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        inputs[i] = ADM_dataset_create(id);

    }



    ADM_dataset_t outputs[NOUTPUTS];



    for(int i = 0; i < NOUTPUTS; ++i) {

        const char* pattern = "output-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) alloca(n + 1);

        snprintf(id, n + 1, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }

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