import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
-public class MDSALManager implements IMdsalApiManager, AutoCloseable {
+public class MDSALManager implements AutoCloseable {
private static final Logger s_logger = LoggerFactory.getLogger(MDSALManager.class);
s_logger.info("MDSAL Manager Closed");
}
- @Override
+
public void printTest() {
s_logger.info(" INTER MODULECOMMUNICATION IS WORKING!!!!");
}
- @Override
+
public void installFlow(FlowEntity flowEntity) {
try {
}
}
- @Override
public void installGroup(GroupEntity groupEntity) {
try {
Group group = groupEntity.getGroupBuilder().build();
}
}
- @Override
public void removeFlow(FlowEntity flowEntity) {
try {
Node nodeDpn = buildDpnNode(flowEntity.getDpnId());
}
}
- @Override
public void removeGroup(GroupEntity groupEntity) {
try {
Node nodeDpn = buildDpnNode(groupEntity.getDpnId());
}
}
- @Override
public void modifyGroup(GroupEntity groupEntity) {
installGroup(groupEntity);
}
*/
- @Override
public void sendPacketOut(long lDpnId, int groupId, byte[] payload) {
List<ActionInfo> actionInfos = new ArrayList<ActionInfo>();
sendPacketOutWithActions(lDpnId, groupId, payload, actionInfos);
}
- @Override
public void sendPacketOutWithActions(long lDpnId, long groupId, byte[] payload, List<ActionInfo> actionInfos) {
m_packetProcessingService.transmitPacket(MDSALUtil.getPacketOut(actionInfos, payload, lDpnId,
getNodeConnRef("openflow:" + lDpnId, "0xfffffffd")));
}
- @Override
public void sendARPPacketOutWithActions(long lDpnId, byte[] payload, List<ActionInfo> actions) {
-
m_packetProcessingService.transmitPacket(MDSALUtil.getPacketOut(actions, payload, lDpnId,
getNodeConnRef("openflow:" + lDpnId, "0xfffffffd")));
}