Author: fhanik
Date: Mon May 21 02:27:15 2007
New Revision: 540082
URL: http://svn.apache.org/viewvc?view=rev&rev=540082
Log:
lock in the right place
Modified:
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Modified:
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java?view=diff&rev=540082&r1=540081&r2=540082
==============================================================================
---
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
(original)
+++
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Mon May 21 02:27:15 2007
@@ -99,13 +99,12 @@
super.messageReceived(msg);
return;
}
+ int msgnr =
XByteBuffer.toInt(msg.getMessage().getBytesDirect(),msg.getMessage().getLength()-4);
+ msg.getMessage().trim(4);
+ MessageOrder order = new
MessageOrder(msgnr,(ChannelMessage)msg.deepclone());
try {
inLock.writeLock().lock();
- int msgnr =
XByteBuffer.toInt(msg.getMessage().getBytesDirect(),msg.getMessage().getLength()-4);
- msg.getMessage().trim(4);
- MessageOrder order = new
MessageOrder(msgnr,(ChannelMessage)msg.deepclone());
if ( processIncoming(order) )
processLeftOvers(msg.getAddress(),false);
-
}finally {
inLock.writeLock().unlock();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
