This is an automated email from the ASF dual-hosted git repository.

markt pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tomcat.git


The following commit(s) were added to refs/heads/main by this push:
     new c1a5240  Refactor - no functional change
c1a5240 is described below

commit c1a524050f2be7c9d4e74dec4af06180b9fb348d
Author: Mark Thomas <ma...@apache.org>
AuthorDate: Mon Aug 23 12:31:22 2021 +0100

    Refactor - no functional change
---
 .../catalina/tribes/transport/nio/ParallelNioSender.java  | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git 
a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java 
b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java
index 0d250f9..3372b39 100644
--- a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java
+++ b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java
@@ -323,21 +323,20 @@ public class ParallelNioSender extends AbstractSender 
implements MultiPointSende
 
     private synchronized void close() throws ChannelException  {
         ChannelException x = null;
-        Object[] members = nioSenders.keySet().toArray();
-        for (Object member : members) {
-            Member mbr = (Member) member;
+        Iterator<Map.Entry<Member,NioSender>> iter = 
nioSenders.entrySet().iterator();
+        while (iter.hasNext()) {
+            Map.Entry<Member,NioSender> entry = iter.next();
             try {
-                NioSender sender = nioSenders.get(mbr);
-                sender.disconnect();
+                entry.getValue().disconnect();
             } catch (Exception e) {
                 if (x == null) {
                     x = new ChannelException(e);
                 }
-                x.addFaultyMember(mbr, e);
+                x.addFaultyMember(entry.getKey(), e);
             }
-            nioSenders.remove(mbr);
+            iter.remove();
         }
-        if ( x != null ) {
+        if (x != null) {
             throw x;
         }
     }

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org

Reply via email to