Add a method to allow re-directing flows if needed.

src/main/java/net/floodlightcontroller/topology/ITopologyService.java

@@ -16,7 +16,7 @@ public interface ITopologyService extends IFloodlightService  {
     public boolean isInternal(long switchid, short port);
 
     public long getSwitchClusterId(long switchId);
-    
+
     /**
      * Retrieves a set of all the switches in the same cluster as sw.
      * A cluster is a set of switches that are directly or indirectly
@@ -27,7 +27,7 @@ public interface ITopologyService extends IFloodlightService  {
      * @return Set of switches in the cluster
      */
     public Set<Long> getSwitchesInCluster(long switchId);
-    
+
     /**
      * Queries whether two switches are in the same cluster.
      * @param switch1
@@ -36,9 +36,9 @@ public interface ITopologyService extends IFloodlightService  {
      */
     public boolean inSameCluster(long switch1, long switch2);
 
-    
+
     public void addListener(ITopologyListener listener);
-    
+
     public boolean isIncomingBroadcastAllowedOnSwitchPort(long sw, short portId);
 
     public boolean isInSameBroadcastDomain(long s1, short p1, long s2, short p2);
@@ -46,4 +46,7 @@ public interface ITopologyService extends IFloodlightService  {
     public Set<Short> getPorts(long sw);
 
     public Set<Short> getBroadcastPorts(long targetSw, long src, short srcPort);
+
+    public NodePortTuple getOutgoingSwitchPort(long src, short srcPort,
+                                               long dst, short dstPort);
 }

src/main/java/net/floodlightcontroller/topology/TopologyInstance.java

@@ -532,6 +532,16 @@ public class TopologyInstance {
         return clusterBroadcastNodePorts.get(clusterId);
     }
 
+    public boolean isInSameBroadcastDomain(long s1, short p1, long s2, short p2) {
+        return false;
+    }
+
+    public NodePortTuple getOutgoingSwitchPort(long src, short srcPort,
+                                               long dst, short dstPort) {
+        // Use this function to redirect traffic if needed.
+        return new NodePortTuple(dst, dstPort);
+    }
+
     public Set<Long> getSwitches() {
         return switches;
     }

src/main/java/net/floodlightcontroller/topology/TopologyManager.java

@@ -399,8 +399,15 @@ IRoutingService, ILinkDiscoveryListener {
 
     @Override
     public boolean isInSameBroadcastDomain(long s1, short p1, long s2, short p2) {
-        // TODO Auto-generated method stub
-        return false;
+        return currentInstance.isInSameBroadcastDomain(s1, p1, s2, p2);
+
+    }
+
+    @Override
+    public NodePortTuple getOutgoingSwitchPort(long src, short srcPort,
+                                               long dst, short dstPort) {
+        // Use this function to redirect traffic if needed.
+        return currentInstance.getOutgoingSwitchPort(src, srcPort, dst, dstPort);
     }
 }