Added FlowPath/FlowEntry version interfaces to FlowPusher
diff --git a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
index a3f602f..0e70a9b 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
@@ -785,7 +785,7 @@
*/
private boolean installFlowEntry(IOFSwitch mySwitch, IFlowPath flowObj,
IFlowEntry flowEntryObj) {
- return pusher.send(mySwitch, flowObj, flowEntryObj);
+ return pusher.add(mySwitch, flowObj, flowEntryObj);
}
/**
@@ -798,14 +798,7 @@
*/
private boolean installFlowEntry(IOFSwitch mySwitch, FlowPath flowPath,
FlowEntry flowEntry) {
- log.debug("Flow is sent to pusher : dpid({}) flow_id({})", mySwitch.getId(), flowEntry.getFlowId());
- // TODO handle this installation by FlowPusher
-
-// return FlowSwitchOperation.installFlowEntry(
-// floodlightProvider.getOFMessageFactory(),
-// messageDamper, mySwitch, flowPath, flowEntry);
-
- return true;
+ return pusher.add(mySwitch, flowPath, flowEntry);
}
/**
@@ -920,7 +913,7 @@
return;
}
- pusher.send(sw, msg);
+ pusher.add(sw, msg);
}
@Override