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 2010/11/09 17:59:24 UTC
svn commit: r1033097 -
/tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Author: markt
Date: Tue Nov 9 16:59:24 2010
New Revision: 1033097
URL: http://svn.apache.org/viewvc?rev=1033097&view=rev
Log:
Fix warnings
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java?rev=1033097&r1=1033096&r2=1033097&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java Tue Nov 9 16:59:24 2010
@@ -81,7 +81,8 @@ public class RpcChannel implements Chann
if ( destination==null || destination.length == 0 ) return new Response[0];
//avoid dead lock
- channelOptions = channelOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK;
+ int sendOptions =
+ channelOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK;
RpcCollectorKey key = new RpcCollectorKey(UUIDGenerator.randomUUID(false));
RpcCollector collector = new RpcCollector(key,rpcOptions,destination.length,timeout);
@@ -89,7 +90,7 @@ public class RpcChannel implements Chann
synchronized (collector) {
if ( rpcOptions != NO_REPLY ) responseMap.put(key, collector);
RpcMessage rmsg = new RpcMessage(rpcId, key.id, message);
- channel.send(destination, rmsg, channelOptions);
+ channel.send(destination, rmsg, sendOptions);
if ( rpcOptions != NO_REPLY ) collector.wait(timeout);
}
} catch ( InterruptedException ix ) {
@@ -101,6 +102,7 @@ public class RpcChannel implements Chann
return collector.getResponses();
}
+ @Override
public void messageReceived(Serializable msg, Member sender) {
RpcMessage rmsg = (RpcMessage)msg;
RpcCollectorKey key = new RpcCollectorKey(rmsg.uuid);
@@ -144,6 +146,7 @@ public class RpcChannel implements Chann
breakdown();
}
+ @Override
public boolean accept(Serializable msg, Member sender) {
if ( msg instanceof RpcMessage ) {
RpcMessage rmsg = (RpcMessage)msg;
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org