Fixed bug in Data store where multiple readers could overwrite

[controller.git] / opendaylight / md-sal / sal-dom-broker / src / main / java / org / opendaylight / yangtools / yang / util / YangDataUtils.java

diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/yangtools/yang/util/YangDataUtils.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/yangtools/yang/util/YangDataUtils.java
new file mode 100644 (file)
index 0000000..687e4d9
--- /dev/null
+++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/yangtools/yang/util/YangDataUtils.java
@@ -0,0 +1,44 @@
+package org.opendaylight.yangtools.yang.util;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.opendaylight.yangtools.yang.common.QName;
+import org.opendaylight.yangtools.yang.data.api.CompositeNode;
+import org.opendaylight.yangtools.yang.data.api.SimpleNode;
+
+import static com.google.common.base.Preconditions.*;
+
+public class YangDataUtils {
+
+    public YangDataUtils() {
+        // TODO Auto-generated constructor stub
+    }
+
+    
+    
+    public static Map<Map<QName,Object>,CompositeNode> toIndexMap(List<CompositeNode> nodes,List<QName> keys) {
+        ConcurrentHashMap<Map<QName,Object>,CompositeNode> ret = new ConcurrentHashMap<>();
+        for(CompositeNode node : nodes) {
+            Map<QName, Object> key = getKeyMap(node,keys);
+            ret.put(key, node);
+        }
+        return ret;
+    }
+
+
+
+    public static Map<QName,Object> getKeyMap(CompositeNode node, List<QName> keys) {
+        Map<QName,Object> map = new HashMap<>();
+        for(QName key : keys) {
+            SimpleNode<?> keyNode = node.getFirstSimpleByName(QName.create(node.getNodeType(), key.getLocalName()));
+            checkArgument(keyNode != null,"Node must contains all keys.");
+            Object value = keyNode.getValue();
+            map.put(key, value);
+            
+        }
+        return map;
+    }
+}