summaryrefslogtreecommitdiffstats
path: root/src/plugins
diff options
context:
space:
mode:
Diffstat (limited to 'src/plugins')
-rw-r--r--src/plugins/CMakeLists.txt1
-rw-r--r--src/plugins/openconfig/openconfig_plugin.c265
-rw-r--r--src/plugins/openconfig/openconfig_plugin.h70
3 files changed, 336 insertions, 0 deletions
diff --git a/src/plugins/CMakeLists.txt b/src/plugins/CMakeLists.txt
index 6a4dc32..8f248c5 100644
--- a/src/plugins/CMakeLists.txt
+++ b/src/plugins/CMakeLists.txt
@@ -46,6 +46,7 @@ set(PLUGINS_SOURCES
sc_plugins.c
openconfig/openconfig_interfaces.c
openconfig/openconfig_local_routing.c
+ openconfig/openconfig_plugin.c
openconfig/sys_util.c
)
diff --git a/src/plugins/openconfig/openconfig_plugin.c b/src/plugins/openconfig/openconfig_plugin.c
new file mode 100644
index 0000000..5d5582a
--- /dev/null
+++ b/src/plugins/openconfig/openconfig_plugin.c
@@ -0,0 +1,265 @@
+/*
+ * Copyright (c) 2018 PANTHEON.tech.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "openconfig_plugin.h"
+#include "sys_util.h"
+#include "openconfig_interfaces.h"
+#include "openconfig_local_routing.h"
+#include "sc_vpp_operation.h"
+
+#include <assert.h>
+#include <string.h>
+#include <sysrepo/xpath.h>
+#include <sysrepo/values.h>
+
+#define XPATH_SIZE 2000
+
+static struct _sys_repo_call sysrepo_callback[] = {
+ {
+ .xpath = "openconfig-interfaces",
+ .method = MODULE,
+ .datastore = RUNNING,
+ .cb.mcb = openconfig_interface_mod_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_EV_ENABLED | SR_SUBSCR_APPLY_ONLY
+ },
+ {
+ .xpath = "openconfig-local-routing",
+ .method = MODULE,
+ .datastore = RUNNING,
+ .cb.mcb = openconfig_local_routing_mod_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_EV_ENABLED | SR_SUBSCR_APPLY_ONLY
+ },
+ {
+ .xpath = "/openconfig-interfaces:interfaces/interface/config",
+ .method = XPATH,
+ .datastore = RUNNING,
+ .cb.scb = openconfig_interfaces_interfaces_interface_config_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_DEFAULT
+ },
+ {
+ .xpath = "/openconfig-interfaces:interfaces/interface/state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_interfaces_interfaces_interface_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+ {
+ .xpath = "/openconfig-interfaces:interfaces/interface/subinterfaces/subinterface/state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_interfaces_interfaces_interface_subinterfaces_subinterface_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+ {
+ .xpath = "/openconfig-interfaces:interfaces/interface/subinterfaces/subinterface/openconfig-if-ip:ipv4/openconfig-if-ip:addresses/openconfig-if-ip:address/openconfig-if-ip:config",
+ .method = XPATH,
+ .datastore = RUNNING,
+ .cb.scb = openconfig_interfaces_interfaces_interface_subinterfaces_subinterface_oc_ip_ipv4_oc_ip_addresses_oc_ip_address_oc_ip_config_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_DEFAULT
+ },
+ {
+ .xpath = "/openconfig-interfaces:interfaces/interface/subinterfaces/subinterface/openconfig-if-ip:ipv4/openconfig-if-ip:addresses/openconfig-if-ip:address/openconfig-if-ip:state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_interfaces_interfaces_interface_subinterfaces_subinterface_oc_ip_ipv4_oc_ip_addresses_oc_ip_address_oc_ip_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+ {
+ .xpath = "/openconfig-local-routing:local-routes/static-routes/static/next-hops/next-hop/config",
+ .method = XPATH,
+ .datastore = RUNNING,
+ .cb.scb = openconfig_local_routing_local_routes_static_routes_static_next_hops_next_hop_config_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_DEFAULT
+ },
+ {
+ .xpath = "/openconfig-local-routing:local-routes/static-routes/static/next-hops/next-hop/interface-ref/config",
+ .method = XPATH,
+ .datastore = RUNNING,
+ .cb.scb = openconfig_local_routing_local_routes_static_routes_static_next_hops_next_hop_interface_ref_config_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_DEFAULT
+ },
+ {
+ .xpath = "/openconfig-local-routing:local-routes/static-routes/static/state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_local_routing_local_routes_static_routes_static_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+ {
+ .xpath = "/openconfig-local-routing:local-routes/static-routes/static/next-hops/next-hop/state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_local_routing_local_routes_static_routes_static_next_hops_next_hop_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+ {
+ .xpath = "/openconfig-local-routing:local-routes/static-routes/static/next-hops/next-hop/interface-ref/state",
+ .method = GETITEM,
+ .datastore = RUNNING,
+ .cb.gcb = openconfig_local_routing_local_routes_static_routes_static_next_hops_next_hop_interface_ref_state_cb,
+ .private_ctx = NULL,
+ .priority = 0,
+ .opts = SR_SUBSCR_CTX_REUSE
+ },
+};
+
+
+static int sys_repo_subscribe(plugin_main_t *plugin_main, sr_session_ctx_t *ds,
+ struct _sys_repo_call *call)
+{
+ int rc = SR_ERR_OK;
+ plugin_subcscription_t *end, *plugin_subcscription =
+ (plugin_subcscription_t *)calloc(sizeof(plugin_subcscription_t), 1);
+
+ if (plugin_subcscription == NULL) {
+ return SR_ERR_NOMEM;
+ }
+
+ if (plugin_main->plugin_subcscription != NULL) {
+ end = plugin_main->plugin_subcscription;
+ while (end->next != NULL) { end = end->next; }
+ end->next = plugin_subcscription;
+ }
+ else {
+ plugin_main->plugin_subcscription = plugin_subcscription;
+ }
+
+ plugin_subcscription->datastore = call->datastore;
+
+ switch (call->method) {
+ case MODULE:
+ rc = sr_module_change_subscribe(ds, call->xpath, call->cb.mcb,
+ call->private_ctx, call->priority,
+ call->opts,
+ &(plugin_subcscription->sr_subscription_ctx));
+ if (SR_ERR_OK != rc) {
+ SRP_LOG_ERR("Error subscribed to module: %s", call->xpath);
+ return rc;
+ }
+ break;
+
+ case XPATH:
+ rc = sr_subtree_change_subscribe(ds, call->xpath, call->cb.scb,
+ call->private_ctx, call->priority,
+ call->opts,
+ &(plugin_subcscription->sr_subscription_ctx));
+ if (SR_ERR_OK != rc) {
+ SRP_LOG_ERR("Error subscribed to change: %s", call->xpath);
+ return rc;
+ }
+ break;
+
+ case GETITEM:
+ SRP_LOG_DBG("Subscribe get item: %s", call->xpath);
+ rc = sr_dp_get_items_subscribe(ds, call->xpath, call->cb.gcb,
+ call->private_ctx, call->opts,
+ &(plugin_subcscription->sr_subscription_ctx));
+ if (SR_ERR_OK != rc) {
+ SRP_LOG_ERR("Error subscribed to get item: %s", call->xpath);
+ return rc;
+ }
+ break;
+
+ case RPC:
+ rc = sr_rpc_subscribe(ds, call->xpath, call->cb.rcb,
+ call->private_ctx, call->opts,
+ &(plugin_subcscription->sr_subscription_ctx));
+ if (SR_ERR_OK != rc) {
+ SRP_LOG_ERR("Error subscribed to RPC: %s", call->xpath);
+ return rc;
+ }
+ break;
+ }
+
+ SRP_LOG_DBG("Subscripted to xpath: %s", call->xpath);
+ return rc;
+}
+
+int openconfig_register_subscribe(plugin_main_t* plugin_main)
+{
+ int rc = 0;
+ uint32_t i = 0;
+ sr_session_ctx_t *datastore = NULL;
+
+ ARG_CHECK(-1, plugin_main);
+
+ for (i = 0; i < ARRAY_SIZE(sysrepo_callback); i++) {
+ if (STARTUP == sysrepo_callback[i].datastore) {
+ datastore = plugin_main->ds_startup;
+ } else if (RUNNING == sysrepo_callback[i].datastore) {
+ datastore = plugin_main->ds_running;
+ } else {
+ SRP_LOG_ERR_MSG("Error: wrong database type");
+ return -1;
+ }
+
+ rc = sys_repo_subscribe(plugin_main, datastore, &sysrepo_callback[i]);
+ if (SR_ERR_OK != rc) {
+ SRP_LOG_ERR("Error: subscribing to subtree change, xpath: %s",
+ sysrepo_callback[i].xpath);
+// return -1;
+ }
+ }
+
+ return 0;
+}
+
+void openconfig_unsubscribe(plugin_main_t* plugin_main)
+{
+ plugin_subcscription_t *plugin_subcscription, *tmp;
+
+ if (plugin_main->plugin_subcscription != NULL) {
+ plugin_subcscription = plugin_main->plugin_subcscription;
+ do {
+ tmp = plugin_subcscription;
+ plugin_subcscription = plugin_subcscription->next;
+ switch (tmp->datastore) {
+ case STARTUP:
+ sr_unsubscribe(plugin_main->ds_startup,
+ tmp->sr_subscription_ctx);
+ break;
+
+ case RUNNING:
+ sr_unsubscribe(plugin_main->ds_running,
+ tmp->sr_subscription_ctx);
+ break;
+ }
+ free(tmp);
+ } while (plugin_subcscription != NULL);
+ }
+}
diff --git a/src/plugins/openconfig/openconfig_plugin.h b/src/plugins/openconfig/openconfig_plugin.h
new file mode 100644
index 0000000..5f0c352
--- /dev/null
+++ b/src/plugins/openconfig/openconfig_plugin.h
@@ -0,0 +1,70 @@
+/*
+ * Copyright (c) 2018 PANTHEON.tech.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef __SWEETCOMB_OPENCONFIG_PLUGIN__
+#define __SWEETCOMB_OPENCONFIG_PLUGIN__
+
+#include <stdlib.h>
+#include <sysrepo.h>
+
+#define ARRAY_SIZE(X) (sizeof(X) / sizeof(*X))
+
+typedef enum {
+ MODULE,
+ XPATH,
+ GETITEM,
+ RPC,
+} method_e;
+
+typedef enum {
+ STARTUP,
+ RUNNING,
+} datastore_e;
+
+typedef struct _plugin_subcscription_t{
+ datastore_e datastore;
+ sr_subscription_ctx_t *sr_subscription_ctx;
+ struct _plugin_subcscription_t *next;
+} plugin_subcscription_t;
+
+typedef struct {
+ sr_conn_ctx_t *sr_conn_ctx;
+ sr_session_ctx_t *ds_startup;
+ sr_session_ctx_t *ds_running;
+ //sr_session_ctx_t *ds_candidate;
+ plugin_subcscription_t *plugin_subcscription;
+} plugin_main_t;
+
+struct _sys_repo_call {
+ char *xpath;
+ method_e method;
+ datastore_e datastore;
+ union {
+ sr_module_change_cb mcb;
+ sr_subtree_change_cb scb;
+ sr_dp_get_items_cb gcb;
+ sr_rpc_cb rcb;
+ } cb;
+ void *private_ctx;
+ uint32_t priority;
+ sr_subscr_options_t opts;
+};
+
+int openconfig_register_subscribe(plugin_main_t *plugin_main);
+void openconfig_unsubscribe(plugin_main_t *plugin_main);
+
+
+#endif /* __SWEETCOMB_OPENCONFIG_PLUGIN__ */