You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by fh...@apache.org on 2007/05/14 14:25:23 UTC
svn commit: r537797 -
/tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Author: fhanik
Date: Mon May 14 05:25:21 2007
New Revision: 537797
URL: http://svn.apache.org/viewvc?view=rev&rev=537797
Log:
Make sure to respect the option flag, otherwise you must order everything
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=537797&r1=537796&r2=537797
==============================================================================
--- 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 14 05:25:21 2007
@@ -60,6 +60,10 @@
private int maxQueue = Integer.MAX_VALUE;
public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException {
+ if ( !okToProcess(msg.getOptions()) ) {
+ super.sendMessage(destination, msg, payload);
+ return;
+ }
for ( int i=0; i<destination.length; i++ ) {
int nr = incCounter(destination[i]);
//reduce byte copy
@@ -73,6 +77,10 @@
}
public void messageReceived(ChannelMessage msg) {
+ if ( !okToProcess(msg.getOptions()) ) {
+ 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());
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org