Hi,
For install routes into your dataplane (e.g. OpenFlow switches, Linux's routing
tables),
it is required to implement your Ryu application.
In other words, Ryu does not have any dataplane feature in its self.
OTOH, for monitoring the best paths, I realized that it is difficult to get
notifications by
using application.py and bgp_sample_conf.py.
Currently, application.py has no way to register event handlers (e.g.,
best_path_change_handler
of bgpspeaker.BGPSpeaker class) to get BGP events.
Then, I made a patch for this problem, I hope this patch will help your
implementations.
Or...
You need to implement your own application like:
https://github.com/osrg/ryu/blob/master/ryu/app/rest_vtep.py
Thanks,
Iwase
On 2017年02月02日 18:00, Jordi Bisbal wrote:
> Hey,
>
> I have a BGP scenario configured, using the BGPSpeaker library
> (application.py) and the bgp_sample_conf.py.
>
> My question is how, can I set the values from my RIB table to my real
> machine, or in other words to my routing table, in order to, for example, be
> able to ping one host from a prefix A and neighbor A to a host in a prefix B
> and neighbor B.
>
> Thank you in advance,
>
> Jordi Bisbal
>
>
> ------------------------------------------------------------------------------
> Check out the vibrant tech community on one of the world's most
> engaging tech sites, SlashDot.org! http://sdm.link/slashdot
>
>
>
> _______________________________________________
> Ryu-devel mailing list
> [email protected]
> https://lists.sourceforge.net/lists/listinfo/ryu-devel
>
>From c88805272c0913ebb5da2c6935886dca25637ba1 Mon Sep 17 00:00:00 2001
From: IWASE Yusuke <[email protected]>
Date: Thu, 9 Feb 2017 15:17:59 +0900
Subject: [PATCH] RyuBGPSpeaker: Enable to notify BGP events
This patch enables RyuBGPSpeaker, which is a base Ryu application for
creating user BGP applications, to notify the BGP events corresponding
to 'best_path_change_handler', 'peer_down_handler' and 'peer_up_handler'
of bgpspeaker.BGPSpeaker.
Signed-off-by: IWASE Yusuke <[email protected]>
---
ryu/services/protocols/bgp/application.py | 111 ++++++++++++++++++++++++++++++
1 file changed, 111 insertions(+)
diff --git a/ryu/services/protocols/bgp/application.py b/ryu/services/protocols/bgp/application.py
index 9a85fe1..7fa7509 100644
--- a/ryu/services/protocols/bgp/application.py
+++ b/ryu/services/protocols/bgp/application.py
@@ -24,6 +24,7 @@ from ryu import cfg
from ryu.lib import hub
from ryu.utils import load_source
from ryu.base.app_manager import RyuApp
+from ryu.controller.event import EventBase
from ryu.services.protocols.bgp.base import add_bgp_error_metadata
from ryu.services.protocols.bgp.base import BGPSException
from ryu.services.protocols.bgp.base import BIN_ERROR
@@ -87,7 +88,97 @@ def load_config(config_file):
raise ApplicationException(desc=str(e))
+class EventBestPathChanged(EventBase):
+ """
+ Event called when any best remote path is changed due to UPDATE messages
+ or remote peer's down.
+
+ This event is the wrapper for ``best_path_change_handler`` of
+ ``bgpspeaker.BGPSpeaker``.
+
+ ``path`` attribute contains an instance of ``info_base.base.Path``
+ subclasses.
+
+ If ``is_withdraw`` attribute is ``True``, ``path`` attribute has the
+ information of the withdraw route.
+ """
+
+ def __init__(self, path, is_withdraw):
+ super(EventBestPathChanged, self).__init__()
+ self.path = path
+ self.is_withdraw = is_withdraw
+
+
+class EventPeerDown(EventBase):
+ """
+ Event called when the session to the remote peer goes down.
+
+ This event is the wrapper for ``peer_down_handler`` of
+ ``bgpspeaker.BGPSpeaker``.
+
+ ``remote_ip`` attribute is the IP address of the remote peer.
+
+ ``remote_as`` attribute is the AS number of the remote peer.
+ """
+
+ def __init__(self, remote_ip, remote_as):
+ super(EventPeerDown, self).__init__()
+ self.remote_ip = remote_ip
+ self.remote_as = remote_as
+
+
+class EventPeerUp(EventBase):
+ """
+ Event called when the session to the remote peer goes up.
+
+ This event is the wrapper for ``peer_up_handler`` of
+ ``bgpspeaker.BGPSpeaker``.
+
+ ``remote_ip`` attribute is the IP address of the remote peer.
+
+ ``remote_as`` attribute is the AS number of the remote peer.
+ """
+
+ def __init__(self, remote_ip, remote_as):
+ super(EventPeerUp, self).__init__()
+ self.remote_ip = remote_ip
+ self.remote_as = remote_as
+
+
class RyuBGPSpeaker(RyuApp):
+ """
+ Base application to create BGP applications.
+
+ This application will notifies ``EventPeerDown``, ``EventPeerDown``
+ and ``EventPeerUp`` to other BGP applications.
+ To catch these events, specify ``@set_ev_cls()`` decorator to the event
+ handlers in the Ryu applications.
+
+ Example::
+
+ ...
+ from ryu.base import app_manager
+ from ryu.controller.handler import set_ev_cls
+ from ryu.services.protocols.bgp import application as bgp_application
+ ...
+
+ class MyBGPApp(app_manager.RyuApp):
+ _CONTEXTS = {
+ 'ryubgpspeaker': bgp_application.RyuBGPSpeaker,
+ }
+
+ ...
+ @set_ev_cls(bgp_application.EventBestPathChanged)
+ def _best_patch_changed_handler(self, ev):
+ self.logger.info(
+ 'Best path changed: is_withdraw=%s, path=%s',
+ ev.is_withdraw, ev.path)
+ """
+ _EVENTS = [
+ EventBestPathChanged,
+ EventPeerDown,
+ EventPeerUp,
+ ]
def __init__(self, *args, **kwargs):
super(RyuBGPSpeaker, self).__init__(*args, **kwargs)
@@ -149,6 +240,14 @@ class RyuBGPSpeaker(RyuApp):
raise ApplicationException(
desc='Required BGP configuration missing: %s' % e)
+ # Set event notify handlers if no corresponding handler specified.
+ bgp_settings['best_path_change_handler'] = settings.get(
+ 'best_path_change_handler', self._notify_best_path_changed_event)
+ bgp_settings['peer_down_handler'] = settings.get(
+ 'peer_down_handler', self._notify_peer_down_event)
+ bgp_settings['peer_up_handler'] = settings.get(
+ 'peer_up_handler', self._notify_peer_up_event)
+
# Get optional settings.
bgp_settings[BGP_SERVER_PORT] = settings.get(
BGP_SERVER_PORT, DEFAULT_BGP_SERVER_PORT)
@@ -175,6 +274,18 @@ class RyuBGPSpeaker(RyuApp):
LOG.debug('Adding routes...')
self._add_routes(settings.get('routes', []))
+ def _notify_best_path_changed_event(self, ev):
+ ev = EventBestPathChanged(ev.path, ev.is_withdraw)
+ self.send_event_to_observers(ev)
+
+ def _notify_peer_down_event(self, remote_ip, remote_as):
+ ev = EventPeerDown(remote_ip, remote_as)
+ self.send_event_to_observers(ev)
+
+ def _notify_peer_up_event(self, remote_ip, remote_as):
+ ev = EventPeerUp(remote_ip, remote_as)
+ self.send_event_to_observers(ev)
+
def _add_neighbors(self, settings):
"""
Add BGP neighbors from the given settings.
--
2.7.4
------------------------------------------------------------------------------
Check out the vibrant tech community on one of the world's most
engaging tech sites, SlashDot.org! http://sdm.link/slashdot
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
