diff --git a/src/lib/admire.cpp b/src/lib/admire.cpp index ebc64a8ae54289ab172dbd9ba78b89b68025ca5a..5ed6f1fc8375c42ef6a8ddb9c924b752142e1b6a 100644 --- a/src/lib/admire.cpp +++ b/src/lib/admire.cpp @@ -53,6 +53,29 @@ void rpc_registration_cb(scord::network::rpc_client* client) { REGISTER_RPC(client, "ADM_ping", void, void, ADM_ping, false); + + REGISTER_RPC(client, "ADM_register_job", ADM_register_job_in_t, + ADM_register_job_out_t, ADM_register_job, true); + REGISTER_RPC(client, "ADM_update_job", ADM_update_job_in_t, + ADM_update_job_out_t, ADM_update_job, true); + REGISTER_RPC(client, "ADM_remove_job", ADM_remove_job_in_t, + ADM_remove_job_out_t, ADM_remove_job, true); + + REGISTER_RPC(client, "ADM_register_adhoc_storage", + ADM_register_adhoc_storage_in_t, + ADM_register_adhoc_storage_out_t, ADM_register_adhoc_storage, + true); + REGISTER_RPC(client, "ADM_update_adhoc_storage", + ADM_update_adhoc_storage_in_t, ADM_update_adhoc_storage_out_t, + ADM_update_adhoc_storage, true); + REGISTER_RPC(client, "ADM_remove_adhoc_storage", + ADM_remove_adhoc_storage_in_t, ADM_remove_adhoc_storage_out_t, + ADM_remove_adhoc_storage, true); + + REGISTER_RPC(client, "ADM_deploy_adhoc_storage", + ADM_deploy_adhoc_storage_in_t, ADM_deploy_adhoc_storage_out_t, + ADM_deploy_adhoc_storage, true); + REGISTER_RPC(client, "ADM_input", ADM_input_in_t, ADM_input_out_t, ADM_input, true); diff --git a/src/lib/detail/impl.cpp b/src/lib/detail/impl.cpp index 116d2112ab9190a50f0f212d9e7030c2ec15dcd1..4b28664256709245f3f978fd80be59ccd64dd65f 100644 --- a/src/lib/detail/impl.cpp +++ b/src/lib/detail/impl.cpp @@ -31,6 +31,29 @@ void rpc_registration_cb(scord::network::rpc_client* client) { REGISTER_RPC(client, "ADM_ping", void, void, ADM_ping, false); + + REGISTER_RPC(client, "ADM_register_job", ADM_register_job_in_t, + ADM_register_job_out_t, ADM_register_job, true); + REGISTER_RPC(client, "ADM_update_job", ADM_update_job_in_t, + ADM_update_job_out_t, ADM_update_job, true); + REGISTER_RPC(client, "ADM_remove_job", ADM_remove_job_in_t, + ADM_remove_job_out_t, ADM_remove_job, true); + + REGISTER_RPC(client, "ADM_register_adhoc_storage", + ADM_register_adhoc_storage_in_t, + ADM_register_adhoc_storage_out_t, ADM_register_adhoc_storage, + true); + REGISTER_RPC(client, "ADM_update_adhoc_storage", + ADM_update_adhoc_storage_in_t, ADM_update_adhoc_storage_out_t, + ADM_update_adhoc_storage, true); + REGISTER_RPC(client, "ADM_remove_adhoc_storage", + ADM_remove_adhoc_storage_in_t, ADM_remove_adhoc_storage_out_t, + ADM_remove_adhoc_storage, true); + + REGISTER_RPC(client, "ADM_deploy_adhoc_storage", + ADM_deploy_adhoc_storage_in_t, ADM_deploy_adhoc_storage_out_t, + ADM_deploy_adhoc_storage, true); + REGISTER_RPC(client, "ADM_input", ADM_input_in_t, ADM_input_out_t, ADM_input, true); diff --git a/src/scord/scord.cpp b/src/scord/scord.cpp index b1430ff99f678572c7f5a49a434a0627e448e52a..1d07fd506ae26ea6702614e090ca7ee0139ec84c 100644 --- a/src/scord/scord.cpp +++ b/src/scord/scord.cpp @@ -157,6 +157,32 @@ main(int argc, char* argv[]) { LOGGER_INFO(" * Registering RPCs handlers..."); REGISTER_RPC(ctx, "ADM_ping", void, void, ADM_ping, false); + + REGISTER_RPC(ctx, "ADM_register_job", ADM_register_job_in_t, + ADM_register_job_out_t, ADM_register_job, true); + REGISTER_RPC(ctx, "ADM_update_job", ADM_update_job_in_t, + ADM_update_job_out_t, ADM_update_job, true); + REGISTER_RPC(ctx, "ADM_remove_job", ADM_remove_job_in_t, + ADM_remove_job_out_t, ADM_remove_job, true); + + REGISTER_RPC(ctx, "ADM_register_adhoc_storage", + ADM_register_adhoc_storage_in_t, + ADM_register_adhoc_storage_out_t, + ADM_register_adhoc_storage, true); + REGISTER_RPC(ctx, "ADM_update_adhoc_storage", + ADM_update_adhoc_storage_in_t, + ADM_update_adhoc_storage_out_t, + ADM_update_adhoc_storage, true); + REGISTER_RPC(ctx, "ADM_remove_adhoc_storage", + ADM_remove_adhoc_storage_in_t, + ADM_remove_adhoc_storage_out_t, + ADM_remove_adhoc_storage, true); + + REGISTER_RPC(ctx, "ADM_deploy_adhoc_storage", + ADM_deploy_adhoc_storage_in_t, + ADM_deploy_adhoc_storage_out_t, + ADM_deploy_adhoc_storage, true); + REGISTER_RPC(ctx, "ADM_input", ADM_input_in_t, ADM_input_out_t, ADM_input, true);