From: Isaku Yamahata <yamah...@valinux.co.jp> Signed-off-by: Isaku Yamahata <yamah...@valinux.co.jp> Signed-off-by: FUJITA Tomonori <fujita.tomon...@lab.ntt.co.jp> --- ryu/app/conf_switch_key.py | 18 +++++ ryu/app/rest_conf_switch.py | 173 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 191 insertions(+), 0 deletions(-) create mode 100644 ryu/app/conf_switch_key.py create mode 100644 ryu/app/rest_conf_switch.py
diff --git a/ryu/app/conf_switch_key.py b/ryu/app/conf_switch_key.py new file mode 100644 index 0000000..1eae3a0 --- /dev/null +++ b/ryu/app/conf_switch_key.py @@ -0,0 +1,18 @@ +# Copyright (C) 2012 Nippon Telegraph and Telephone Corporation. +# Copyright (C) 2012 Isaku Yamahata <yamahata at private email ne jp> +# +# 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. + +OVSDB_ADDR = 'ovsdb_addr' # value <method>:<port>[:<ip>] +OVS_TUNNEL_ADDR = 'ovs_tunnel_addr' # ip address of tunnel diff --git a/ryu/app/rest_conf_switch.py b/ryu/app/rest_conf_switch.py new file mode 100644 index 0000000..0cd1541 --- /dev/null +++ b/ryu/app/rest_conf_switch.py @@ -0,0 +1,173 @@ +# Copyright (C) 2012 Nippon Telegraph and Telephone Corporation. +# Copyright (C) 2012 Isaku Yamahata <yamahata at private email ne jp> +# +# 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. + +import httplib +import json +import logging +from webob import Response + +from ryu.app.wsgi import ControllerBase +from ryu.base import app_manager +from ryu.controller import conf_switch +from ryu.lib import dpid as dpid_lib + + +LOG = logging.getLogger(__name__) + + +# REST API for switch configuration +# +# get all the switches +# GET /v1.0/conf/switches +# +# get all the configuration keys of a switch +# GET /v1.0/conf/switches/<dpid> +# +# delete all the configuration of a switch +# DELETE /v1.0/conf/switches/<dpid> +# +# set the <key> configuration of a switch +# PUT /v1.0/conf/switches/<dpid>/<key> +# +# get the <key> configuration of a switch +# GET /v1.0/conf/switches/<dpid>/<key> +# +# delete the <key> configuration of a switch +# DELETE /v1.0/conf/switches/<dpid>/<key> +# +# where +# <dpid>: datapath id in 16 hex + + +class ConfSwitchController(ControllerBase): + def __init__(self, req, link, data, **config): + super(ConfSwitchController, self).__init__(req, link, data, **config) + self.conf_switch = data + + def list_switches(self, _req, **_kwargs): + dpids = self.conf_switch.dpids() + body = json.dumps([dpid_lib.dpid_to_str(dpid) for dpid in dpids]) + return Response(content_type='application/json', body=body) + + @staticmethod + def _do_switch(dpid, func, ret_func): + dpid = dpid_lib.str_to_dpid(dpid) + try: + ret = func(dpid) + except KeyError: + return Response(status=httplib.NOT_FOUND, + body='no dpid is found %s' % + dpid_lib.dpid_to_str(dpid)) + + return ret_func(ret) + + def delete_switch(self, _req, dpid, **_kwargs): + def _delete_switch(dpid): + self.conf_switch.del_dpid(dpid) + return None + + def _ret(_ret): + return Response(status=httplib.ACCEPTED) + + return self._do_switch(dpid, _delete_switch, _ret) + + def list_keys(self, _req, dpid, **_kwargs): + def _list_keys(dpid): + return self.conf_switch.keys(dpid) + + def _ret(keys): + body = json.dumps(keys) + return Response(content_type='application/json', body=body) + + return self._do_switch(dpid, _list_keys, _ret) + + @staticmethod + def _do_key(dpid, key, func, ret_func): + dpid = dpid_lib.str_to_dpid(dpid) + try: + ret = func(dpid, key) + except KeyError: + return Response(status=httplib.NOT_FOUND, + body='no dpid/key is found %s %s' % + (dpid_lib.dpid_to_str(dpid), key)) + return ret_func(ret) + + def set_key(self, req, dpid, key, **_kwargs): + def _set_val(dpid, key): + val = json.loads(req.body) + self.conf_switch.set_key(dpid, key, val) + return None + + def _ret(_ret): + return Response(status=httplib.CREATED) + + return self._do_key(dpid, key, _set_val, _ret) + + def get_key(self, _req, dpid, key, **_kwargs): + def _get_key(dpid, key): + return self.conf_switch.get_key(dpid, key) + + def _ret(val): + return Response(content_type='application/json', + body=json.dumps(val)) + + return self._do_key(dpid, key, _get_key, _ret) + + def delete_key(self, _req, dpid, key, **_kwargs): + def _delete_key(dpid, key): + self.conf_switch.del_key(dpid, key) + return None + + def _ret(_ret): + return Response() + + return self._do_key(dpid, key, _delete_key, _ret) + + +class ConfSwitchAPI(app_manager.RyuApp): + _CONTEXTS = { + 'conf_switch': conf_switch.ConfSwitchSet, + } + + def __init__(self, *args, **kwargs): + super(ConfSwitchAPI, self).__init__(*args, **kwargs) + self.conf_switch = kwargs['conf_switch'] + wsgi = kwargs['wsgi'] + mapper = wsgi.mapper + + controller = ConfSwitchController + wsgi.registory[controller.__name__] = self.conf_switch + route_name = 'conf_switch' + uri = '/v1.0/conf/switches' + mapper.connect(route_name, uri, controller=controller, + action='list_switches', + conditions=dict(method=['GET'])) + + uri += '/{dpid}' + requirements = {'dpid': dpid_lib.DPID_PATTERN} + s = mapper.submapper(controller=controller, requirements=requirements) + s.connect(route_name, uri, action='delete_switch', + conditions=dict(method=['DELETE'])) + s.connect(route_name, uri, action='list_keys', + conditions=dict(method=['GET'])) + + uri += '/{key}' + s.connect(route_name, uri, action='set_key', + conditions=dict(method=['PUT'])) + s.connect(route_name, uri, action='get_key', + conditions=dict(method=['GET'])) + s.connect(route_name, uri, action='delete_key', + conditions=dict(method=['DELETE'])) -- 1.7.4.4 ------------------------------------------------------------------------------ Free Next-Gen Firewall Hardware Offer Buy your Sophos next-gen firewall before the end March 2013 and get the hardware for free! Learn more. http://p.sf.net/sfu/sophos-d2d-feb _______________________________________________ Ryu-devel mailing list Ryu-devel@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/ryu-devel
