| commit | 6602b6a86b88b67f62835e39bec4979c4e5fa303 | [log] [tgz] |
|---|---|---|
| author | Pavlin Radoslavov <pavlin@onlab.us> | Fri Jan 10 16:43:29 2014 -0800 |
| committer | Pavlin Radoslavov <pavlin@onlab.us> | Fri Jan 10 16:43:29 2014 -0800 |
| tree | 63f2617065119f78d296b4ff49f62076dcfe3fdb | |
| parent | 2d6e5f1ce86a2daacdfa05d23424aea039d658b9 [diff] [blame] |
Use the parallel version of getFlows()
diff --git a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java index 7118e41..de372ef 100644 --- a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java +++ b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java
@@ -640,7 +640,8 @@ // Get my Flows Collection<FlowPath> myFlows = - FlowDatabaseOperation.getFlows(dbHandler, shouldFetchMyFlowIds); + ParallelFlowDatabaseOperation.getFlows(dbHandler, + shouldFetchMyFlowIds); for (FlowPath flowPath : myFlows) { fixFlowFromDatabase(flowPath);