Skip to content
Snippets Groups Projects

Resolve "ADM_register_*_storage APIs should not require an `ADM_job_t` argument"

15 files
+ 63
201
Compare changes
  • Side-by-side
  • Inline
Files
15
@@ -42,28 +42,6 @@ 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[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_adhoc_context_t ctx = ADM_adhoc_context_create(
ADM_ADHOC_MODE_SEPARATE_NEW, ADM_ADHOC_ACCESS_RDWR, 42, 100, false);
assert(ctx);
@@ -71,21 +49,9 @@ 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;
}
ADM_storage_t adhoc_storage;
ret = ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
ADM_return_t ret = ADM_register_adhoc_storage(server, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
@@ -98,7 +64,7 @@ main(int argc, char* argv[]) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure completed "
"successfully\n");
ret = ADM_deploy_adhoc_storage(server, job, adhoc_storage);
ret = ADM_deploy_adhoc_storage(server, adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
Loading