commit | 3e29f6619360616e0ae3f33213efde56bb51dcd3 | [log] [tgz] |
---|---|---|
author | Aaron Kruglikov <aaron.kruglikov@us.fujitsu.com> | Wed Jul 13 10:18:10 2016 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Mon Jul 25 17:43:54 2016 +0000 |
tree | fdaa072622e8853ea3fb703c5539b9a14d8398d9 | |
parent | b1ce2609cb68c440fe88284eb34624d8fd13a832 [diff] [blame] |
Adding additional TreeMap resources Change-Id: I103a8c5e6fb1c5e7a6ae0942e0b746367da18736
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMap.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMap.java index 8bab853..df567d2 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMap.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMap.java
@@ -266,7 +266,7 @@ public synchronized CompletableFuture<Void> addListener(MapEventListener<String, byte[]> listener, Executor executor) { if (mapEventListeners.isEmpty()) { - return client.submit(new Listen()).thenRun(() -> mapEventListeners.putIfAbsent(listener, executor)); + return client.submit(new Listen()).thenRun(() -> mapEventListeners.put(listener, executor)); } else { mapEventListeners.put(listener, executor); return CompletableFuture.completedFuture(null);