Signed-off-by: ISHIDA Wataru <[email protected]>
---
ryu/services/protocols/bgp/api/core.py | 2 +-
ryu/services/protocols/bgp/base.py | 3 ++-
ryu/services/protocols/bgp/peer.py | 2 +-
ryu/services/protocols/bgp/speaker.py | 4 ++--
ryu/services/protocols/bgp/utils/evtlet.py | 1 +
5 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/ryu/services/protocols/bgp/api/core.py
b/ryu/services/protocols/bgp/api/core.py
index e272eef..e45adf2 100644
--- a/ryu/services/protocols/bgp/api/core.py
+++ b/ryu/services/protocols/bgp/api/core.py
@@ -40,7 +40,7 @@ def start(**kwargs):
waiter = kwargs.pop('waiter')
common_config = CommonConf(**kwargs)
hub.spawn(CORE_MANAGER.start, *[], **{'common_conf': common_config,
- 'waiter': waiter})
+ 'waiter': waiter})
return True
diff --git a/ryu/services/protocols/bgp/base.py
b/ryu/services/protocols/bgp/base.py
index 77c8ef0..571826f 100644
--- a/ryu/services/protocols/bgp/base.py
+++ b/ryu/services/protocols/bgp/base.py
@@ -181,7 +181,7 @@ class Activity(object):
# Schedule to spawn a new greenthread after requested delay
greenthread = hub.spawn_after(seconds, activity.start, *args,
- **kwargs)
+ **kwargs)
self._child_thread_map[activity.name] = greenthread
self._child_activity_map[activity.name] = activity
return greenthread
@@ -353,6 +353,7 @@ class Activity(object):
self._spawn(conn_name, conn_handler, sock)
return sock
+
#
# Sink
#
diff --git a/ryu/services/protocols/bgp/peer.py
b/ryu/services/protocols/bgp/peer.py
index 7a11af1..24edf2d 100644
--- a/ryu/services/protocols/bgp/peer.py
+++ b/ryu/services/protocols/bgp/peer.py
@@ -726,7 +726,7 @@ class Peer(Source, Sink, NeighborConfListener, Activity):
# NeighborConf has this setting we add this to existing list.
communities = path_extcomm_attr.communities
if self._neigh_conf.soo_list:
- #construct extended community
+ # construct extended community
soo_list = self._neigh_conf.soo_list
subtype = 0x03
for soo in soo_list:
diff --git a/ryu/services/protocols/bgp/speaker.py
b/ryu/services/protocols/bgp/speaker.py
index 07ec6de..a0e2ae5 100644
--- a/ryu/services/protocols/bgp/speaker.py
+++ b/ryu/services/protocols/bgp/speaker.py
@@ -425,8 +425,8 @@ class BgpProtocol(Protocol, Activity):
message except for *Open* and *Notification* message. On receiving
*Notification* message we close connection with peer.
"""
- LOG.debug('Received msg from %s << %s' % \
- (str(self.get_peername()), msg))
+ LOG.debug('Received msg from %s << %s' % (str(self.get_peername()),
+ msg))
# If we receive open message we try to bind to protocol
if (msg.type == BGP_MSG_OPEN):
diff --git a/ryu/services/protocols/bgp/utils/evtlet.py
b/ryu/services/protocols/bgp/utils/evtlet.py
index 4c2aa44..339837f 100644
--- a/ryu/services/protocols/bgp/utils/evtlet.py
+++ b/ryu/services/protocols/bgp/utils/evtlet.py
@@ -34,6 +34,7 @@ class EventletIOFactory(object):
LOG.debug('create_looping_call called')
return LoopingCall(funct, *args, **kwargs)
+
# TODO: improve Timer service and move it into framework
class LoopingCall(object):
"""Call a function repeatedly.
--
1.7.9.5
------------------------------------------------------------------------------
Start Your Social Network Today - Download eXo Platform
Build your Enterprise Intranet with eXo Platform Software
Java Based Open Source Intranet - Social, Extensible, Cloud Ready
Get Started Now And Turn Your Intranet Into A Collaboration Platform
http://p.sf.net/sfu/ExoPlatform
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
