Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • eu/admire/io-scheduler
1 result
Show changes
Commits on Source (26)
Hide whitespace changes
Inline Side-by-side
Showing
with 41 additions and 40 deletions
examples/c/ADM_cancel_transfer.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_connect_data_operation.c
View file @ 721d0eb0
...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) { ...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_define_data_operation.c
View file @ 721d0eb0
...@@ -71,9 +71,9 @@ main(int argc, char* argv[]) { ...@@ -71,9 +71,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_deploy_adhoc_storage.c
View file @ 721d0eb0
...@@ -51,7 +51,7 @@ main(int argc, char* argv[]) { ...@@ -51,7 +51,7 @@ main(int argc, char* argv[]) {
ADM_adhoc_resources_t adhoc_resources = NULL; ADM_adhoc_resources_t adhoc_resources = NULL;
ADM_adhoc_context_t adhoc_ctx = NULL; ADM_adhoc_context_t adhoc_ctx = NULL;
ADM_adhoc_context_t new_adhoc_ctx = NULL; ADM_adhoc_context_t new_adhoc_ctx = NULL;
ADM_storage_t adhoc_storage = NULL; ADM_adhoc_storage_t adhoc_storage = NULL;
// Let's prepare all the information required by the API calls. // Let's prepare all the information required by the API calls.
...@@ -96,8 +96,9 @@ main(int argc, char* argv[]) { ...@@ -96,8 +96,9 @@ main(int argc, char* argv[]) {
} }
// 2. Register the adhoc storage // 2. Register the adhoc storage
if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_GEKKOFS, if(ADM_register_adhoc_storage(server, adhoc_name,
adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) { ADM_ADHOC_STORAGE_DATACLAY, adhoc_ctx,
&adhoc_storage) != ADM_SUCCESS) {
fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n", fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n",
ADM_strerror(ret)); ADM_strerror(ret));
goto cleanup; goto cleanup;
......
examples/c/ADM_finalize_data_operation.c
View file @ 721d0eb0
...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_get_pending_transfers.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_get_qos_constraints.c
View file @ 721d0eb0
...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) { ...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_get_statistics.c
View file @ 721d0eb0
...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) { ...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_get_transfer_priority.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_link_transfer_to_data_operation.c
View file @ 721d0eb0
...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_register_adhoc_storage.c
View file @ 721d0eb0
...@@ -49,7 +49,7 @@ main(int argc, char* argv[]) { ...@@ -49,7 +49,7 @@ main(int argc, char* argv[]) {
ADM_node_t* adhoc_nodes = NULL; ADM_node_t* adhoc_nodes = NULL;
ADM_adhoc_resources_t adhoc_resources = NULL; ADM_adhoc_resources_t adhoc_resources = NULL;
ADM_adhoc_context_t adhoc_ctx = NULL; ADM_adhoc_context_t adhoc_ctx = NULL;
ADM_storage_t adhoc_storage = NULL; ADM_adhoc_storage_t adhoc_storage = NULL;
// Let's prepare all the information required by the API calls. // Let's prepare all the information required by the API calls.
// ADM_register_adhoc_storage() requires a set of nodes for the adhoc // ADM_register_adhoc_storage() requires a set of nodes for the adhoc
...@@ -92,7 +92,7 @@ main(int argc, char* argv[]) { ...@@ -92,7 +92,7 @@ main(int argc, char* argv[]) {
} }
// 2. Register the adhoc storage // 2. Register the adhoc storage
if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_GEKKOFS, if(ADM_register_adhoc_storage(server, adhoc_name, ADM_ADHOC_STORAGE_GEKKOFS,
adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) { adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) {
fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n", fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n",
ADM_strerror(ret)); ADM_strerror(ret));
......
examples/c/ADM_register_job.c
View file @ 721d0eb0
...@@ -50,7 +50,7 @@ main(int argc, char* argv[]) { ...@@ -50,7 +50,7 @@ main(int argc, char* argv[]) {
ADM_node_t* adhoc_nodes = NULL; ADM_node_t* adhoc_nodes = NULL;
ADM_adhoc_resources_t adhoc_resources = NULL; ADM_adhoc_resources_t adhoc_resources = NULL;
ADM_adhoc_context_t adhoc_ctx = NULL; ADM_adhoc_context_t adhoc_ctx = NULL;
ADM_storage_t adhoc_storage = NULL; ADM_adhoc_storage_t adhoc_storage = NULL;
// job information // job information
ADM_node_t* job_nodes = NULL; ADM_node_t* job_nodes = NULL;
...@@ -103,7 +103,7 @@ main(int argc, char* argv[]) { ...@@ -103,7 +103,7 @@ main(int argc, char* argv[]) {
} }
// 2. Register the adhoc storage // 2. Register the adhoc storage
if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_GEKKOFS, if(ADM_register_adhoc_storage(server, adhoc_name, ADM_ADHOC_STORAGE_GEKKOFS,
adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) { adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) {
fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n", fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n",
ADM_strerror(ret)); ADM_strerror(ret));
......
examples/c/ADM_register_pfs_storage.c
View file @ 721d0eb0
...@@ -43,7 +43,7 @@ main(int argc, char* argv[]) { ...@@ -43,7 +43,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); ADM_server_t server = ADM_server_create("tcp", argv[1]);
ADM_storage_t pfs_storage; ADM_pfs_storage_t pfs_storage;
ADM_pfs_context_t ctx = ADM_pfs_context_create("/gpfs"); ADM_pfs_context_t ctx = ADM_pfs_context_create("/gpfs");
assert(ctx); assert(ctx);
......
examples/c/ADM_remove_adhoc_storage.c
View file @ 721d0eb0
...@@ -50,7 +50,7 @@ main(int argc, char* argv[]) { ...@@ -50,7 +50,7 @@ main(int argc, char* argv[]) {
ADM_node_t* adhoc_nodes = NULL; ADM_node_t* adhoc_nodes = NULL;
ADM_adhoc_resources_t adhoc_resources = NULL; ADM_adhoc_resources_t adhoc_resources = NULL;
ADM_adhoc_context_t adhoc_ctx = NULL; ADM_adhoc_context_t adhoc_ctx = NULL;
ADM_storage_t adhoc_storage = NULL; ADM_adhoc_storage_t adhoc_storage = NULL;
// Let's prepare all the information required by the API calls. // Let's prepare all the information required by the API calls.
...@@ -95,7 +95,7 @@ main(int argc, char* argv[]) { ...@@ -95,7 +95,7 @@ main(int argc, char* argv[]) {
} }
// 2. Register the adhoc storage // 2. Register the adhoc storage
if(ADM_register_adhoc_storage(server, adhoc_name, ADM_STORAGE_GEKKOFS, if(ADM_register_adhoc_storage(server, adhoc_name, ADM_ADHOC_STORAGE_GEKKOFS,
adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) { adhoc_ctx, &adhoc_storage) != ADM_SUCCESS) {
fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n", fprintf(stderr, "ADM_register_adhoc_storage() failed: %s\n",
ADM_strerror(ret)); ADM_strerror(ret));
......
examples/c/ADM_remove_job.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_remove_pfs_storage.c
View file @ 721d0eb0
...@@ -42,7 +42,7 @@ main(int argc, char* argv[]) { ...@@ -42,7 +42,7 @@ main(int argc, char* argv[]) {
ADM_pfs_context_t ctx = ADM_pfs_context_create("/gpfs"); ADM_pfs_context_t ctx = ADM_pfs_context_create("/gpfs");
assert(ctx); assert(ctx);
ADM_storage_t pfs_storage; ADM_pfs_storage_t pfs_storage;
ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage); ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
......
examples/c/ADM_set_dataset_information.c
View file @ 721d0eb0
...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_set_io_resources.c
View file @ 721d0eb0
...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) { ...@@ -66,9 +66,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
...@@ -99,7 +99,7 @@ main(int argc, char* argv[]) { ...@@ -99,7 +99,7 @@ main(int argc, char* argv[]) {
goto cleanup; goto cleanup;
} }
ADM_storage_t tier = NULL; ADM_adhoc_storage_t tier = NULL;
ADM_adhoc_resources_t resources = NULL; ADM_adhoc_resources_t resources = NULL;
ret = ADM_set_io_resources(server, job, tier, resources); ret = ADM_set_io_resources(server, job, tier, resources);
......
examples/c/ADM_set_qos_constraints.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......
examples/c/ADM_set_transfer_priority.c
View file @ 721d0eb0
...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) { ...@@ -70,9 +70,9 @@ main(int argc, char* argv[]) {
const char* name = "adhoc_storage_42"; const char* name = "adhoc_storage_42";
ADM_storage_t adhoc_storage; ADM_adhoc_storage_t adhoc_storage;
ADM_return_t ret = ADM_register_adhoc_storage( ADM_return_t ret = ADM_register_adhoc_storage(
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_ADHOC_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stderr, fprintf(stderr,
......