Handle duplicate listen requests submitted to the state machine

Change-Id: I9f17be5a751f7f2b17f8e89232dc0403ca260137

Handle duplicate listen requests submitted to the state machine
Change-Id: I9f17be5a751f7f2b17f8e89232dc0403ca260137
Madan Jampani · Gerrit Code Review
Commit e60388716f0c2353f5b43bfcee53b8d8af6c47e9 e6038871 1 parent 434e68dd
Showing 1 changed file with 4 additions and 1 deletions
core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java
View file @e603887
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapState.java
View file @e603887
@@ -318,7 +318,10 @@ public class AtomixConsistentMapState extends ResourceStateMachine implements Se
      */
     protected void listen(Commit<? extends Listen> commit) {
         Long sessionId = commit.session().id();
-         listeners.put(sessionId, commit);
+         if (listeners.putIfAbsent(sessionId, commit) != null) {
+             commit.close();
+             return;
+         }
         commit.session()
                 .onStateChange(
                         state -> {