ADM_connect_data_operation.c updated

#define NINPUTS  10

#define NOUTPUTS 5

bool

string_to_convert(s) {

    if(s == "true" || s == "TRUE" || s == "True") {

        return true;

    } else if(s == "false" || s == "FALSE" || s == "False") {

        return false;

    } else {

        fprintf(stderr,

                "ERROR: Incorrect input value. Please try again.\n");

        exit(EXIT_FAILURE);

    }

}

int

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

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

    ADM_job_t job;

    ADM_dataset_t input;

    ADM_dataset_t output;

    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*) malloc(n + 1);

        snprintf(id, n, 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*) malloc(n + 1);

        snprintf(id, n, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }

    bool should_stream = false;

    va_list args; // FIXME placeholder

    ADM_return_t ret = ADM_SUCCESS;

    ADM_return_t ret = ADM_connect_data_operation( server,  job,

                            inputs,  outputs,

                            should_stream);

    if(ret != ADM_SUCCESS) {

cleanup:

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

        ADM_dataset_destroy(inputs[i]);

    }

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

        ADM_dataset_destroy(outputs[i]);

    }

    ADM_server_destroy(server);

    exit(exit_status);

}

 No newline at end of file