From d0e3264a84228bcec648bb3782de4aa28df3c2c3 Mon Sep 17 00:00:00 2001 From: FUJITA Tomonori Date: Sat, 25 Feb 2012 11:47:13 +0900 Subject: [PATCH] limit the queue size (send_q) cbench in throughtput mode doesn't work with ryu. We need to limit queue size to prevent the queue from eating memory up. The size is arbitrary. It can be the startup parameter. But I think that we should solve this in the better way. So let's not make it global for now Signed-off-by: FUJITA Tomonori --- ryu/controller/controller.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/ryu/controller/controller.py b/ryu/controller/controller.py index 13e04ee8..cb854509 100644 --- a/ryu/controller/controller.py +++ b/ryu/controller/controller.py @@ -81,8 +81,9 @@ class Datapath(object): self.address = address self.is_active = True - # XIX limit queue size somehow to prevent it from eating memory up - self.send_q = Queue() + # The limit is arbitrary. We need to limit queue size to + # prevent it from eating memory up + self.send_q = Queue(16) # circular reference self.ev_q.aux == self self.ev_q = dispatcher.EventQueue(handler.QUEUE_NAME_OFP_MSG,