commit 1ab441bf2641f257eab0038f4c722c95d2a3302b
author Ray Milkey <ray@opennetworking.org> Tue Mar 06 15:33:44 2018 -0800
committer Ray Milkey <ray@opennetworking.org> Wed Mar 07 00:20:53 2018 +0000
tree e31c5f49cfcf7f49e20895bc9329b6cadf7e2800
parent df54373eaf9190825ab9a0cccb81f154d16ca301

Fix STC concurrent modification problem

Change-Id: Iead8226fbad17686667b12cd4b00752f94097cb4

providers/lldpcommon/src/main/java/org/onosproject/provider/lldpcommon/LinkDiscovery.java

diff --git a/providers/lldpcommon/src/main/java/org/onosproject/provider/lldpcommon/LinkDiscovery.java b/providers/lldpcommon/src/main/java/org/onosproject/provider/lldpcommon/LinkDiscovery.java
index 735255b..2afe4de 100644
--- a/providers/lldpcommon/src/main/java/org/onosproject/provider/lldpcommon/LinkDiscovery.java
+++ b/providers/lldpcommon/src/main/java/org/onosproject/provider/lldpcommon/LinkDiscovery.java
@@ -15,6 +15,7 @@
  */
 package org.onosproject.provider.lldpcommon;
 
+import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Maps;
 
 import io.netty.util.Timeout;
@@ -222,7 +223,7 @@
 
         if (context.mastershipService().isLocalMaster(device.id())) {
             log.trace("Sending probes from {}", device.id());
-            portMap.forEach(this::sendProbes);
+            ImmutableMap.copyOf(portMap).forEach(this::sendProbes);
         }
 
         if (!isStopped()) {