Loading examples/c/ADM_register_job.c +2 −2 Original line number Diff line number Diff line Loading @@ -19,7 +19,7 @@ main(int argc, char* argv[]) { ADM_job_t job; ADM_dataset_handle_t inputs[NINPUTS]; ADM_dataset_t inputs[NINPUTS]; for(int i = 0; i < NINPUTS; ++i) { const char* pattern = "input-dataset-%d"; Loading @@ -29,7 +29,7 @@ main(int argc, char* argv[]) { inputs[i] = ADM_dataset_create(id); } ADM_dataset_handle_t outputs[NOUTPUTS]; ADM_dataset_t outputs[NOUTPUTS]; for(int i = 0; i < NOUTPUTS; ++i) { const char* pattern = "output-dataset-%d"; Loading examples/cxx/ADM_connect_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -27,8 +27,8 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t input{}; ADM_dataset_handle_t output{}; ADM_dataset_t input{}; ADM_dataset_t output{}; bool should_stream = false; va_list args; // FIXME placeholder ADM_return_t ret = ADM_SUCCESS; Loading examples/cxx/ADM_set_dataset_information.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t target{}; ADM_dataset_t target{}; ADM_dataset_info_t info{}; ADM_return_t ret = ADM_SUCCESS; Loading examples/cxx/ADM_transfer_dataset.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -17,8 +17,8 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t** sources = nullptr; ADM_dataset_handle_t** targets = nullptr; ADM_dataset_t** sources = nullptr; ADM_dataset_t** targets = nullptr; ADM_limit_t** limits = nullptr; ADM_tx_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE; ADM_transfer_handle_t tx_handle{}; Loading src/lib/admire.cpp +7 −9 Original line number Diff line number Diff line Loading @@ -363,10 +363,9 @@ deploy_adhoc_storage(const server& srv, ADM_job_t job, } ADM_return_t transfer_dataset(const server& srv, ADM_job_t job, ADM_dataset_handle_t** sources, ADM_dataset_handle_t** targets, ADM_limit_t** limits, ADM_tx_mapping_t mapping, ADM_transfer_handle_t* tx_handle) { transfer_dataset(const server& srv, ADM_job_t job, ADM_dataset_t** sources, ADM_dataset_t** targets, ADM_limit_t** limits, ADM_tx_mapping_t mapping, ADM_transfer_handle_t* tx_handle) { (void) srv; (void) job; (void) sources; Loading Loading @@ -396,8 +395,8 @@ transfer_dataset(const server& srv, ADM_job_t job, } ADM_return_t set_dataset_information(const server& srv, ADM_job_t job, ADM_dataset_handle_t target, ADM_dataset_info_t info) { set_dataset_information(const server& srv, ADM_job_t job, ADM_dataset_t target, ADM_dataset_info_t info) { (void) srv; (void) job; (void) target; Loading Loading @@ -652,9 +651,8 @@ define_data_operation(const server& srv, ADM_job_t job, const char* path, } ADM_return_t connect_data_operation(const server& srv, ADM_job_t job, ADM_dataset_handle_t input, ADM_dataset_handle_t output, bool should_stream, va_list args) { connect_data_operation(const server& srv, ADM_job_t job, ADM_dataset_t input, ADM_dataset_t output, bool should_stream, va_list args) { (void) srv; (void) job; (void) input; Loading Loading
examples/c/ADM_register_job.c +2 −2 Original line number Diff line number Diff line Loading @@ -19,7 +19,7 @@ main(int argc, char* argv[]) { ADM_job_t job; ADM_dataset_handle_t inputs[NINPUTS]; ADM_dataset_t inputs[NINPUTS]; for(int i = 0; i < NINPUTS; ++i) { const char* pattern = "input-dataset-%d"; Loading @@ -29,7 +29,7 @@ main(int argc, char* argv[]) { inputs[i] = ADM_dataset_create(id); } ADM_dataset_handle_t outputs[NOUTPUTS]; ADM_dataset_t outputs[NOUTPUTS]; for(int i = 0; i < NOUTPUTS; ++i) { const char* pattern = "output-dataset-%d"; Loading
examples/cxx/ADM_connect_data_operation.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -27,8 +27,8 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t input{}; ADM_dataset_handle_t output{}; ADM_dataset_t input{}; ADM_dataset_t output{}; bool should_stream = false; va_list args; // FIXME placeholder ADM_return_t ret = ADM_SUCCESS; Loading
examples/cxx/ADM_set_dataset_information.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t target{}; ADM_dataset_t target{}; ADM_dataset_info_t info{}; ADM_return_t ret = ADM_SUCCESS; Loading
examples/cxx/ADM_transfer_dataset.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -17,8 +17,8 @@ main(int argc, char* argv[]) { admire::server server{"tcp", argv[1]}; ADM_job_t job{}; ADM_dataset_handle_t** sources = nullptr; ADM_dataset_handle_t** targets = nullptr; ADM_dataset_t** sources = nullptr; ADM_dataset_t** targets = nullptr; ADM_limit_t** limits = nullptr; ADM_tx_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE; ADM_transfer_handle_t tx_handle{}; Loading
src/lib/admire.cpp +7 −9 Original line number Diff line number Diff line Loading @@ -363,10 +363,9 @@ deploy_adhoc_storage(const server& srv, ADM_job_t job, } ADM_return_t transfer_dataset(const server& srv, ADM_job_t job, ADM_dataset_handle_t** sources, ADM_dataset_handle_t** targets, ADM_limit_t** limits, ADM_tx_mapping_t mapping, ADM_transfer_handle_t* tx_handle) { transfer_dataset(const server& srv, ADM_job_t job, ADM_dataset_t** sources, ADM_dataset_t** targets, ADM_limit_t** limits, ADM_tx_mapping_t mapping, ADM_transfer_handle_t* tx_handle) { (void) srv; (void) job; (void) sources; Loading Loading @@ -396,8 +395,8 @@ transfer_dataset(const server& srv, ADM_job_t job, } ADM_return_t set_dataset_information(const server& srv, ADM_job_t job, ADM_dataset_handle_t target, ADM_dataset_info_t info) { set_dataset_information(const server& srv, ADM_job_t job, ADM_dataset_t target, ADM_dataset_info_t info) { (void) srv; (void) job; (void) target; Loading Loading @@ -652,9 +651,8 @@ define_data_operation(const server& srv, ADM_job_t job, const char* path, } ADM_return_t connect_data_operation(const server& srv, ADM_job_t job, ADM_dataset_handle_t input, ADM_dataset_handle_t output, bool should_stream, va_list args) { connect_data_operation(const server& srv, ADM_job_t job, ADM_dataset_t input, ADM_dataset_t output, bool should_stream, va_list args) { (void) srv; (void) job; (void) input; Loading