Expose topology.isBroadcastDomainPort()

src/main/java/net/floodlightcontroller/core/internal/Controller.java

@@ -1233,15 +1233,7 @@ public class Controller
         ldd.addListener(type, listener);
         
         if (log.isDebugEnabled()) {
-            StringBuffer sb = new StringBuffer();
-            sb.append("OFListeners for ");
-            sb.append(type);
-            sb.append(": ");
-            for (IOFMessageListener l : ldd.getOrderedListeners()) {
-                sb.append(l.getName());
-                sb.append(",");
-            }
-            log.debug(sb.toString());
+        	logListeners(type, ldd);
         }
     }
 
@@ -1252,7 +1244,22 @@ public class Controller
             messageListeners.get(type);
         if (ldd != null) {
             ldd.removeListener(listener);
+            if (log.isDebugEnabled()) {
+            	logListeners(type, ldd);
+            }
+        }
+    }
+    
+    private void logListeners(OFType type, ListenerDispatcher<OFType, IOFMessageListener> ldd) {
+        StringBuffer sb = new StringBuffer();
+        sb.append("OFListeners for ");
+        sb.append(type);
+        sb.append(": ");
+        for (IOFMessageListener l : ldd.getOrderedListeners()) {
+            sb.append(l.getName());
+            sb.append(",");
         }
+        log.debug(sb.toString());
     }
     
     public void removeOFMessageListeners(OFType type) {

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

@@ -38,6 +38,8 @@ public interface ITopologyService extends IFloodlightService  {
 
 
     public void addListener(ITopologyListener listener);
+    
+    public boolean isBroadcastDomainPort(long sw, short port);
 
     public boolean isIncomingBroadcastAllowedOnSwitchPort(long sw, short portId);
 

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

@@ -410,5 +410,10 @@ IRoutingService, ILinkDiscoveryListener {
         // Use this function to redirect traffic if needed.
         return currentInstance.getOutgoingSwitchPort(src, srcPort, dst, dstPort);
     }
+
+	@Override
+	public boolean isBroadcastDomainPort(long sw, short port) {
+		return currentInstance.isBroadcastDomainPort(new NodePortTuple(sw, port));
+	}
 }