You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2014/03/26 15:45:13 UTC
svn commit: r1581871 -
/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Author: markt
Date: Wed Mar 26 14:45:13 2014
New Revision: 1581871
URL: http://svn.apache.org/r1581871
Log:
Locks should be outside try/finally
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java?rev=1581871&r1=1581870&r2=1581871&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java Wed Mar 26 14:45:13 2014
@@ -73,8 +73,8 @@ public class OrderInterceptor extends Ch
for (int i=0; i<destination.length; i++ ) {
try {
int nr = 0;
+ outLock.writeLock().lock();
try {
- outLock.writeLock().lock();
nr = incCounter(destination[i]);
} finally {
outLock.writeLock().unlock();
@@ -103,10 +103,10 @@ public class OrderInterceptor extends Ch
int msgnr = XByteBuffer.toInt(msg.getMessage().getBytesDirect(),msg.getMessage().getLength()-4);
msg.getMessage().trim(4);
MessageOrder order = new MessageOrder(msgnr,(ChannelMessage)msg.deepclone());
+ inLock.writeLock().lock();
try {
- inLock.writeLock().lock();
if ( processIncoming(order) ) processLeftOvers(msg.getAddress(),false);
- }finally {
+ } finally {
inLock.writeLock().unlock();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org