commit | 40f022ee59108e8e7109f010aa893cabacb122ec | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan.jampani@gmail.com> | Wed Mar 02 21:35:14 2016 -0800 |
committer | Gerrit Code Review <gerrit@onlab.us> | Thu Mar 03 06:46:08 2016 +0000 |
tree | 9ef50490b1870cbcac6b374792455733c140209f | |
parent | 2898a7f093cf0e1c77af78ef6261faec100fff38 [diff] [blame] |
Default ConsistentMap consistency level to SEQUENTIAL and reenable all Atomix unit tests Change-Id: Ic04ff81fbaaa7c007f20077391a72fdfa9fd382a
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java index a6e6ca0..6395f69 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java
@@ -337,10 +337,9 @@ * * @param commit unlisten commit */ - protected void unlisten( - Commit<? extends Unlisten> commit) { + protected void unlisten(Commit<? extends Unlisten> commit) { try { - Commit<? extends Listen> listener = listeners.remove(commit.session()); + Commit<? extends Listen> listener = listeners.remove(commit.session().id()); if (listener != null) { listener.close(); }