From 24bb2bd2aade06efbd2a40f1dd4c6769d3dfbcf0 Mon Sep 17 00:00:00 2001 From: fhanik Date: Thu, 17 May 2007 11:47:50 +0000 Subject: [PATCH] Avoid concurrent mod exception, remove from the iterator instead git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@538878 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/catalina/tribes/transport/nio/ParallelNioSender.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java index 01100eb14..7eeea1e70 100644 --- a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java +++ b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java @@ -283,7 +283,8 @@ public class ParallelNioSender extends AbstractSender implements MultiPointSende Map.Entry entry = (Map.Entry)i.next(); NioSender sender = (NioSender)entry.getValue(); if ( sender.keepalive() ) { - nioSenders.remove(entry.getKey()); + //nioSenders.remove(entry.getKey()); + i.remove(); result = true; } else { try { @@ -291,7 +292,8 @@ public class ParallelNioSender extends AbstractSender implements MultiPointSende }catch ( IOException x ) { sender.disconnect(); sender.reset(); - nioSenders.remove(entry.getKey()); + //nioSenders.remove(entry.getKey()); + i.remove(); result = true; }catch ( Exception x ) { log.warn("Error during keepalive test for sender:"+sender,x); -- 2.11.0