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

Minor changes

parent 625fd0d2
Loading
Loading
Loading
Loading
+2 −8
Original line number Diff line number Diff line
@@ -88,17 +88,11 @@ main(int argc, char* argv[]) {
    ADM_qos_limit_t** limits = NULL;
    ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
    ADM_transfer_t tx;
    ADM_return_t ret_tx = ADM_transfer_dataset(server, job, sources, targets,
    ADM_return_t ret = ADM_transfer_dataset(server, job, sources, targets,
                                            limits, mapping, &tx);

    if(ret_tx != ADM_SUCCESS) {
        fprintf(stdout, "ADM_transfer_dataset() remote procedure not completed "
                        "successfully\n");
        exit_status = EXIT_FAILURE;
        goto cleanup;
    }
    int incr = 42;
    ADM_return_t ret = ADM_set_transfer_priority(server, job, tx, incr);
    ret = ADM_set_transfer_priority(server, job, tx, incr);

    if(ret != ADM_SUCCESS) {
        fprintf(stdout,
+7 −1
Original line number Diff line number Diff line
@@ -71,7 +71,13 @@ main(int argc, char* argv[]) {
        new_outputs.emplace_back(fmt::format("output-new-dataset-{}", i));
    }

    admire::job_requirements new_reqs{new_inputs, new_outputs, std::move(p)};
    auto p2 = std::make_unique<admire::adhoc_storage>(
            admire::storage::type::gekkofs, "foobar",
            admire::adhoc_storage::execution_mode::separate_new,
            admire::adhoc_storage::access_type::read_write, 42, 100, false);

    admire::job_requirements new_reqs{new_inputs, new_outputs, std::move(p2)};


    ADM_return_t ret = ADM_SUCCESS;