Work toward fixing ONOS-1031: Remove or comment-out references to the FlowManager
Removed or commented-out references to the FlowManager, in preparation for
its removal:
* BgpRoute.java
Commented-out references to the FlowManager to add/delete flows.
Those should be replaced by calls to the new Path Intent framework.
Currently, we don't have the setup to test BgpRoute and the new Path Intent
framework is not ready yet, hence those references are commented-out.
* FlowProgrammer.java
- Disabled the FlowSynchronizer, because it needs to be refactored,
and probably now is not working as expected.
- Removed a call to the FlowManager.flowEntryOnSwitchExpired(sw, id)
and replaced it with a comment that the Forwarding module needs to be
informed that a flow is expired.
Currently, the Forwarding module is not functional and needs to be
refactored, hence we cannot test any code refactoring around this.
* FlowSynchronizer.java
Commented-out a call and relevant code around
FlowDatabaseOperation.extractFlowEntry()
The FlowSyncronizer itself needs refactoring, and it is not clear what
the next version is going to look like.
* Forwarding.java
Commented-out a call to flowService.addFlow(flowPath)
This should be replaced by a call to the new Path Intent framework.
Currently, the Forwarding module is not working, and the new Path Intent
framework is not ready yet, hence the call is commented-out.
* ControllerTest.java
Removed reference to IFlowService.class because that class will be removed
* FlowSyncronizerTest.java
Commented out test code that refers to the FlowDatabaseOperation class.
That class will be removed, and the test needs to be rewritten after
the all the cleanup is completed.
Change-Id: I034636ba9c882220f71761a61ea9e6e10bc93357
diff --git a/src/main/java/net/onrc/onos/ofcontroller/forwarding/Forwarding.java b/src/main/java/net/onrc/onos/ofcontroller/forwarding/Forwarding.java
index 5ddee15..a220c43 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/forwarding/Forwarding.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/forwarding/Forwarding.java
@@ -26,7 +26,6 @@
import net.onrc.onos.ofcontroller.core.INetMapTopologyObjects.ISwitchObject;
import net.onrc.onos.ofcontroller.core.internal.DeviceStorageImpl;
import net.onrc.onos.ofcontroller.devicemanager.IOnosDeviceService;
-import net.onrc.onos.ofcontroller.flowmanager.IFlowService;
import net.onrc.onos.ofcontroller.flowprogrammer.IFlowPusherService;
import net.onrc.onos.ofcontroller.proxyarp.BroadcastPacketOutNotification;
import net.onrc.onos.ofcontroller.proxyarp.IProxyArpService;
@@ -72,7 +71,6 @@
private final CallerId callerId = new CallerId("Forwarding");
private IFloodlightProviderService floodlightProvider;
- private IFlowService flowService;
private IFlowPusherService flowPusher;
private IDatagridService datagrid;
private IControllerRegistryService controllerRegistryService;
@@ -162,7 +160,6 @@
List<Class<? extends IFloodlightService>> dependencies =
new ArrayList<Class<? extends IFloodlightService>>();
dependencies.add(IFloodlightProviderService.class);
- dependencies.add(IFlowService.class);
dependencies.add(IFlowPusherService.class);
dependencies.add(IOnosDeviceService.class);
dependencies.add(IControllerRegistryService.class);
@@ -176,7 +173,6 @@
public void init(FloodlightModuleContext context) {
floodlightProvider =
context.getServiceImpl(IFloodlightProviderService.class);
- flowService = context.getServiceImpl(IFlowService.class);
flowPusher = context.getServiceImpl(IFlowPusherService.class);
datagrid = context.getServiceImpl(IDatagridService.class);
controllerRegistryService = context.getServiceImpl(IControllerRegistryService.class);
@@ -430,7 +426,8 @@
log.debug("Adding forward {} to {}. Flow ID {}", new Object[] {
srcMacAddress, dstMacAddress, flowPath.flowId()});
- flowService.addFlow(flowPath);
+ // TODO: Add the flow by using the new Path Intent framework
+ // flowService.addFlow(flowPath);
}
private OFPacketOut constructPacketOut(OFPacketIn pi, IOFSwitch sw) {