Fix for bug 278 Replace implementation of dbCache in InventoryService with a Concurre...

[ovsdb.git] / ovsdb / src / main / java / org / opendaylight / ovsdb / plugin / InventoryService.java

diff --git a/ovsdb/src/main/java/org/opendaylight/ovsdb/plugin/InventoryService.java b/ovsdb/src/main/java/org/opendaylight/ovsdb/plugin/InventoryService.java
index 66a69a501d23ac6623ce32b3b396854dfe8a8156..17bfa81dfcb29829266d3f0dee11776f00a54f42 100644 (file)
--- a/ovsdb/src/main/java/org/opendaylight/ovsdb/plugin/InventoryService.java
+++ b/ovsdb/src/main/java/org/opendaylight/ovsdb/plugin/InventoryService.java
@@ -56,7 +56,7 @@ public class InventoryService implements IPluginInInventoryService, InventorySer
             new CopyOnWriteArraySet<IPluginOutInventoryService>();
     private ConcurrentMap<Node, Map<String, Property>> nodeProps;
     private ConcurrentMap<NodeConnector, Map<String, Property>> nodeConnectorProps;
-    private Map<Node, NodeDB> dbCache = Maps.newHashMap();
+    private ConcurrentMap<Node, NodeDB> dbCache = Maps.newConcurrentMap();
     private ScheduledExecutorService executor;
 
     /**
@@ -126,7 +126,7 @@ public class InventoryService implements IPluginInInventoryService, InventorySer
 
 
     @Override
-    public Map<String, Map<String, Table<?>>> getCache(Node n) {
+    public ConcurrentMap<String, ConcurrentMap<String, Table<?>>> getCache(Node n) {
         NodeDB db = dbCache.get(n);
         if (db == null) return null;
         return db.getTableCache();
@@ -134,7 +134,7 @@ public class InventoryService implements IPluginInInventoryService, InventorySer
 
 
     @Override
-    public Map<String, Table<?>> getTableCache(Node n, String tableName) {
+    public ConcurrentMap<String, Table<?>> getTableCache(Node n, String tableName) {
         NodeDB db = dbCache.get(n);
         if (db == null) return null;
         return db.getTableCache(tableName);