Newcomers that register with TopologyManager should get all the existing edges

[controller.git] / opendaylight / topologymanager / implementation / src / main / java / org / opendaylight / controller / topologymanager / internal / TopologyManagerImpl.java

diff --git a/opendaylight/topologymanager/implementation/src/main/java/org/opendaylight/controller/topologymanager/internal/TopologyManagerImpl.java b/opendaylight/topologymanager/implementation/src/main/java/org/opendaylight/controller/topologymanager/internal/TopologyManagerImpl.java
index b905a8982e83113e10b23261ab2d3045f1142c54..5a38ecd4a61db131623b1e56efef7849bbba2800 100644 (file)
--- a/opendaylight/topologymanager/implementation/src/main/java/org/opendaylight/controller/topologymanager/internal/TopologyManagerImpl.java
+++ b/opendaylight/topologymanager/implementation/src/main/java/org/opendaylight/controller/topologymanager/internal/TopologyManagerImpl.java
@@ -20,6 +20,7 @@ import java.util.Iterator;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
 import java.util.Set;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.ConcurrentHashMap;
@@ -115,6 +116,14 @@ public class TopologyManagerImpl implements
         if (this.topologyManagerAware != null) {
             log.debug("Adding ITopologyManagerAware: {}", s);
             this.topologyManagerAware.add(s);
+            // Reply all the known edges
+            if (this.edgesDB != null) {
+                List<TopoEdgeUpdate> existingEdges = new ArrayList<TopoEdgeUpdate>();
+                for (Entry<Edge, Set<Property>> entry : this.edgesDB.entrySet()) {
+                    existingEdges.add(new TopoEdgeUpdate(entry.getKey(), entry.getValue(), UpdateType.ADDED));
+                }
+                s.edgeUpdate(existingEdges);
+            }
         }
     }
 
@@ -129,6 +138,14 @@ public class TopologyManagerImpl implements
         if (this.topologyManagerClusterWideAware != null) {
             log.debug("Adding ITopologyManagerClusterWideAware: {}", s);
             this.topologyManagerClusterWideAware.add(s);
+            // Reply all the known edges
+            if (this.edgesDB != null) {
+                List<TopoEdgeUpdate> existingEdges = new ArrayList<TopoEdgeUpdate>();
+                for (Entry<Edge, Set<Property>> entry : this.edgesDB.entrySet()) {
+                    existingEdges.add(new TopoEdgeUpdate(entry.getKey(), entry.getValue(), UpdateType.ADDED));
+                }
+                s.edgeUpdate(existingEdges);
+            }
         }
     }