X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openstack%2Fnet-virt%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fovsdb%2Fopenstack%2Fnetvirt%2Fimpl%2FNodeCacheManagerImpl.java;h=7e21101e004a9e3cff4cab2f7adeacd8f6240e48;hb=df08ae0d239824f7bce568a5dbaa7de48ad9ae31;hp=0f7cd698930dac213d07e4f8accb34de445578e4;hpb=83cfd5bd73f79b3b10e71a13b8f6563ea37fee20;p=ovsdb.git diff --git a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/NodeCacheManagerImpl.java b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/NodeCacheManagerImpl.java index 0f7cd6989..7e21101e0 100644 --- a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/NodeCacheManagerImpl.java +++ b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/NodeCacheManagerImpl.java @@ -164,6 +164,19 @@ public class NodeCacheManagerImpl extends AbstractHandler implements NodeCacheMa return nodes; } + private void populateNodeCache() { + LOG.debug("populateNodeCache : Populating the node cache"); + List nodes = southbound.readOvsdbTopologyNodes(); + for(Node ovsdbNode : nodes) { + this.nodeCache.put(ovsdbNode.getNodeId(), ovsdbNode); + } + nodes = southbound.readOvsdbTopologyBridgeNodes(); + for(Node bridgeNode : nodes) { + this.nodeCache.put(bridgeNode.getNodeId(), bridgeNode); + } + LOG.debug("populateNodeCache : Node cache population is done. Total nodes : {}",this.nodeCache.size()); + } + @Override public void setDependencies(ServiceReference serviceReference) { southbound = @@ -171,6 +184,7 @@ public class NodeCacheManagerImpl extends AbstractHandler implements NodeCacheMa eventDispatcher = (EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this); eventDispatcher.eventHandlerAdded(serviceReference, this); + populateNodeCache(); } @Override