commit 4491403198e4468cc54cc54d8967dc47b4044789
author Yuta HIGUCHI <y-higuchi@ak.jp.nec.com> Fri Dec 23 13:39:08 2016 -0800
committer Yuta HIGUCHI <y-higuchi@onlab.us> Tue Jan 10 23:30:48 2017 +0000
tree 57a27152b6e7b1abeee87384f0fc58bd92686353
parent 7066136fc2de5fffe246b2ce4675aa6dd4f735b6

fix potential race condition

Change-Id: I0bf9df79691e9b08af981348a75886b053404add

src/main/java/org/onosproject/segmentrouting/IpHandler.java

diff --git a/src/main/java/org/onosproject/segmentrouting/IpHandler.java b/src/main/java/org/onosproject/segmentrouting/IpHandler.java
index 34368be..19153b4 100644
--- a/src/main/java/org/onosproject/segmentrouting/IpHandler.java
+++ b/src/main/java/org/onosproject/segmentrouting/IpHandler.java
@@ -109,13 +109,9 @@
 
         Ip4Address destIpAddress = Ip4Address.valueOf(ipPacket.getDestinationAddress());
 
-        if (ipPacketQueue.get(destIpAddress) == null) {
-            ConcurrentLinkedQueue<IPv4> queue = new ConcurrentLinkedQueue<>();
-            queue.add(ipPacket);
-            ipPacketQueue.put(destIpAddress, queue);
-        } else {
-            ipPacketQueue.get(destIpAddress).add(ipPacket);
-        }
+        ipPacketQueue
+            .computeIfAbsent(destIpAddress, a -> new ConcurrentLinkedQueue<>())
+            .add(ipPacket);
     }
 
     /**