From eac32e2e150147c8c7322243012f2f4b8aee2184 Mon Sep 17 00:00:00 2001
From: Alberto Miranda <alberto.miranda@bsc.es>
Date: Tue, 5 Jul 2022 12:33:02 +0200
Subject: [PATCH] Register missing RPC definitions

---
 src/lib/admire.cpp      | 23 +++++++++++++++++++++++
 src/lib/detail/impl.cpp | 23 +++++++++++++++++++++++
 src/scord/scord.cpp     | 26 ++++++++++++++++++++++++++
 3 files changed, 72 insertions(+)

diff --git a/src/lib/admire.cpp b/src/lib/admire.cpp
index ebc64a8a..5ed6f1fc 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 116d2112..4b286642 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 b1430ff9..1d07fd50 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);
 
-- 
GitLab