1 files changed, 126 insertions, 0 deletions
diff --git a/framework/src/openstack/neutron/plugin/networking-onos/networking-onos/networking_onos/plugins/l3/driver.py b/framework/src/openstack/neutron/plugin/networking-onos/networking-onos/networking_onos/plugins/l3/driver.py
new file mode 100644
index 00000000..2db3ad35
--- /dev/null
+++ b/framework/src/openstack/neutron/plugin/networking-onos/networking-onos/networking_onos/plugins/l3/driver.py
@@ -0,0 +1,126 @@
+# Copyright (C) 2015 Huawei Technologies India Pvt Ltd.
+# All Rights Reserved.
+#
+#  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.
+#
+
+from oslo_config import cfg
+
+from neutron.api.rpc.agentnotifiers import l3_rpc_agent_api
+from neutron.api.rpc.handlers import l3_rpc
+from neutron.common import constants as q_const
+from neutron.common import rpc as n_rpc
+from neutron.common import topics
+from neutron.db import db_base_plugin_v2
+from neutron.db import extraroute_db
+from neutron.db import l3_agentschedulers_db
+from neutron.db import l3_gwmode_db
+from neutron.plugins.common import constants
+
+from networking_onos.common import config   # noqa
+from networking_onos.plugins.l3 import floating_ip as onos_fip
+from networking_onos.plugins.l3 import router as onos_router
+
+
+class ONOSL3Plugin(db_base_plugin_v2.NeutronDbPluginV2,
+                   extraroute_db.ExtraRoute_db_mixin,
+                   l3_gwmode_db.L3_NAT_db_mixin,
+                   l3_agentschedulers_db.L3AgentSchedulerDbMixin,
+                   onos_router.ONOSRouter,
+                   onos_fip.ONOSFloatingIP):
+
+    """Implementation of the ONOS L3 Router Service Plugin.
+
+    This class implements a L3 service plugin that provides
+    router and floatingip resources and manages associated
+    request/response.
+    """
+    supported_extension_aliases = ["router", "ext-gw-mode", "extraroute"]
+
+    def __init__(self):
+        self.setup_rpc()
+        self.onos_path = cfg.CONF.onos.url_path
+        self.onos_auth = (cfg.CONF.onos.username, cfg.CONF.onos.password)
+
+    def setup_rpc(self):
+        self.topic = topics.L3PLUGIN
+        self.conn = n_rpc.create_connection(new=True)
+        self.agent_notifiers.update(
+            {q_const.AGENT_TYPE_L3: l3_rpc_agent_api.L3AgentNotifyAPI()})
+        self.endpoints = [l3_rpc.L3RpcCallback()]
+        self.conn.create_consumer(self.topic, self.endpoints, fanout=False)
+        self.conn.consume_in_threads()
+
+    def get_plugin_type(self):
+        return constants.L3_ROUTER_NAT
+
+    def get_plugin_description(self):
+        """returns plug-in description"""
+        return ("L3 Router Service Plug-in for basic L3 forwarding using ONOS")
+
+    def create_router(self, context, router):
+        router_dict = super(ONOSL3Plugin, self).create_router(context, router)
+        self.handle_create_router(router_dict)
+        return router_dict
+
+    def update_router(self, context, id, router):
+        router_dict = super(ONOSL3Plugin, self).update_router(context, id,
+                                                              router)
+        self.handle_update_router(router_dict, id)
+        return router_dict
+
+    def delete_router(self, context, id):
+        super(ONOSL3Plugin, self).delete_router(context, id)
+        self.handle_delete_router(id)
+
+    def create_floatingip(self, context, floatingip,
+                          initial_status=q_const.FLOATINGIP_STATUS_ACTIVE):
+        fip_dict = super(ONOSL3Plugin, self).create_floatingip(context,
+                                                               floatingip,
+                                                               initial_status)
+        self.handle_create_floatingip(fip_dict)
+        return fip_dict
+
+    def update_floatingip(self, context, id, floatingip):
+        fip_dict = super(ONOSL3Plugin, self).update_floatingip(context, id,
+                                                               floatingip)
+        self.handle_update_floatingip(id, fip_dict)
+        return fip_dict
+
+    def delete_floatingip(self, context, id):
+        super(ONOSL3Plugin, self).delete_floatingip(context, id)
+        self.handle_delete_floatingip(id)
+
+    def add_router_interface(self, context, router_id, interface_info):
+        router = super(ONOSL3Plugin, self).add_router_interface(context,
+                                                                router_id,
+                                                                interface_info)
+        intf_add_type = self._get_intf_add_type(router, interface_info)
+        self.handle_add_router_interface(router, router_id,
+                                         interface_info, intf_add_type)
+        return router
+
+    def remove_router_interface(self, context, router_id, interface_info):
+        router = super(ONOSL3Plugin, self).remove_router_interface(
+            context, router_id, interface_info)
+        intf_add_type = self._get_intf_add_type(router, interface_info)
+        self.handle_remove_router_interface(router, router_id,
+                                            interface_info, intf_add_type)
+        return router
+
+    def _get_intf_add_type(self, router_info, intf_info):
+        add_by_port, add_by_sub = self._validate_interface_info(intf_info)
+        if add_by_sub:
+            return onos_router.ADD_INTF_BY_SUBNET
+
+        return onos_router.ADD_INTF_BY_PORT