| commit | c395d0fc1cb670621cb883b8e9af8e52bde8e5ae | [log] [tgz] |
|---|---|---|
| author | sangho <sangho@onlab.us> | Tue Jul 11 10:05:25 2017 +0900 |
| committer | Hyunsun Moon <hyunsun.moon@gmail.com> | Thu Jul 13 06:03:07 2017 +0000 |
| tree | 89e115fa7297afe6d71c6872299a93ac9231dcf3 | |
| parent | f3d1fcccf8008c94dc1db99c66e6fb3489dc81cb [diff] |
Initialize the pipeline when the OpenStackFlowRuleManager service is activated. - Pipeline is initialized also when node complete events are detected. Change-Id: If8dd1d267c6fca978d2caf586069998ac86dd4fc
diff --git a/apps/openstacknetworking/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java b/apps/openstacknetworking/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java index 8b93115..4ea001e 100644 --- a/apps/openstacknetworking/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java +++ b/apps/openstacknetworking/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java
@@ -83,6 +83,9 @@ coreService.registerApplication(OPENSTACK_NETWORKING_APP_ID); osNodeService.addListener(internalNodeListener); + osNodeService.completeNodes(OpenstackNode.NodeType.COMPUTE) + .forEach(node -> initializePipeline(node.intgBridge())); + log.info("Started"); }