Signed-off-by: ISHIDA Wataru <[email protected]>
---
ryu/services/protocols/bgp/base.py | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/ryu/services/protocols/bgp/base.py
b/ryu/services/protocols/bgp/base.py
index ef175db..616315f 100644
--- a/ryu/services/protocols/bgp/base.py
+++ b/ryu/services/protocols/bgp/base.py
@@ -267,14 +267,16 @@ class Activity(object):
if child_activity.started:
child_activity.stop()
- def _stop_child_threads(self):
+ def _stop_child_threads(self, name=None):
"""Stops all threads spawn by this activity.
"""
child_threads = self._child_thread_map.items()
for thread_name, thread in child_threads:
- LOG.debug('%s: Stopping child thread %s' %
- (self.name, thread_name))
- thread.kill()
+ if not name or thread_name is name:
+ LOG.debug('%s: Stopping child thread %s' %
+ (self.name, thread_name))
+ thread.kill()
+ del self._child_thread_map[thread_name]
def _close_asso_sockets(self):
"""Closes all the sockets linked to this activity.
--
1.7.10.4
------------------------------------------------------------------------------
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
