From 4e0caea14adfabf0e978d1cd5db77e9e01c371d2 Mon Sep 17 00:00:00 2001
From: fhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Date: Mon, 21 May 2007 09:14:08 +0000
Subject: [PATCH] Only lock when incrementing the counter on sending messages,
 can be further optimized to have a lock per member

git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@540077 13f79535-47bb-0310-9956-ffa450edef68
---
 .../group/interceptors/OrderInterceptor.java       | 24 ++++++++++++++--------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java b/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
index 02597ae8b..7dc2d435b 100644
--- a/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
+++ b/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
@@ -69,21 +69,29 @@ public class OrderInterceptor extends ChannelInterceptorBase {
             super.sendMessage(destination, msg, payload);
             return;
         }
-        try {
-            outLock.writeLock().lock();
-            for ( int i=0; i<destination.length; i++ ) {
-                int nr = incCounter(destination[i]);
+        ChannelException cx = null;
+        for (int i=0; i<destination.length; i++ ) {
+            try {
+                int nr = 0;
+                try {
+                    outLock.writeLock().lock();
+                    nr = incCounter(destination[i]);
+                } finally {
+                    outLock.writeLock().unlock();
+                }
                 //reduce byte copy
                 msg.getMessage().append(nr);
                 try {
                     getNext().sendMessage(new Member[] {destination[i]}, msg, payload);
-                }finally {
+                } finally {
                     msg.getMessage().trim(4);
                 }
+            }catch ( ChannelException x ) {
+                if ( cx == null ) cx = x;
+                cx.addFaultyMember(x.getFaultyMembers());
             }
-        }finally {
-            outLock.writeLock().unlock();
-        }
+        }//for
+        if ( cx != null ) throw cx;
     }
 
     public void messageReceived(ChannelMessage msg) {
-- 
2.11.0