From fe7fce41aae57821aea7e0aa6d6a1bce40c814a6 Mon Sep 17 00:00:00 2001 From: Alessandro Boch Date: Tue, 6 May 2014 10:39:18 -0700 Subject: [PATCH] FRM should use async function on southbound event - On reacting to southbound events (switch up/down, ports added/removed, ...) FRM is supposed to use asynchronous calls for flows installation/removal. This is needed because these events may affect a large number of flows, for which we do not want to slow down the processing via sync calls. Also, logic has been we never do process synchronously a southbound event. - In case of port up, FRM was still using a synchronous call. This patch is for taking care of that. Change-Id: I4b6dae0df75ad778ea2f1d555a258a48ea66c57b Signed-off-by: Alessandro Boch --- .../forwardingrulesmanager/internal/ForwardingRulesManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java b/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java index f7b647dd72..46008b24c6 100644 --- a/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java +++ b/opendaylight/forwardingrulesmanager/implementation/src/main/java/org/opendaylight/controller/forwardingrulesmanager/internal/ForwardingRulesManager.java @@ -2342,7 +2342,7 @@ public class ForwardingRulesManager implements for (FlowConfig flowConfig : flowConfigForNode) { if (doesFlowContainNodeConnector(flowConfig.getFlow(), nodeConnector)) { if (flowConfig.installInHw() && !flowConfig.getStatus().equals(StatusCode.SUCCESS.toString())) { - Status status = this.installFlowEntry(flowConfig.getFlowEntry()); + Status status = this.installFlowEntryAsync(flowConfig.getFlowEntry()); if (!status.isSuccess()) { flowConfig.setStatus(status.getDescription()); } else { -- 2.36.6