You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2016/06/20 02:41:12 UTC
svn commit: r1749255 -
/tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Author: kfujino
Date: Mon Jun 20 02:41:12 2016
New Revision: 1749255
URL: http://svn.apache.org/viewvc?rev=1749255&view=rev
Log:
No-functional change.
Fix code format.
Modified:
tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
Modified: tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java
URL: http://svn.apache.org/viewvc/tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java?rev=1749255&r1=1749254&r2=1749255&view=diff
==============================================================================
--- tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java (original)
+++ tomcat/tc8.5.x/trunk/java/org/apache/catalina/tribes/group/RpcChannel.java Mon Jun 20 02:41:12 2016
@@ -35,7 +35,7 @@ import org.apache.juli.logging.LogFactor
/**
* A channel to handle RPC messaging
*/
-public class RpcChannel implements ChannelListener{
+public class RpcChannel implements ChannelListener {
private static final Log log = LogFactory.getLog(RpcChannel.class);
protected static final StringManager sm = StringManager.getManager(RpcChannel.class);
@@ -49,8 +49,7 @@ public class RpcChannel implements Chann
private byte[] rpcId;
private int replyMessageOptions = 0;
- private final HashMap<RpcCollectorKey, RpcCollector> responseMap =
- new HashMap<>();
+ private final HashMap<RpcCollectorKey, RpcCollector> responseMap = new HashMap<>();
/**
* Create an RPC channel. You can have several RPC channels attached to a group
@@ -100,7 +99,7 @@ public class RpcChannel implements Chann
}
} catch ( InterruptedException ix ) {
Thread.currentThread().interrupt();
- }finally {
+ } finally {
responseMap.remove(key);
}
return collector.getResponses();
@@ -129,7 +128,7 @@ public class RpcChannel implements Chann
}
}//synchronized
}//end if
- } else{
+ } else {
boolean finished = false;
final ExtendedRpcCallback excallback = (callback instanceof ExtendedRpcCallback)?((ExtendedRpcCallback)callback) : null;
boolean asyncReply = ((replyMessageOptions & Channel.SEND_OPTIONS_ASYNCHRONOUS) == Channel.SEND_OPTIONS_ASYNCHRONOUS);
@@ -159,7 +158,7 @@ public class RpcChannel implements Chann
channel.send(new Member[] {sender}, rmsg,replyMessageOptions & ~Channel.SEND_OPTIONS_SYNCHRONIZED_ACK);
}
finished = true;
- }catch ( Exception x ) {
+ } catch ( Exception x ) {
if (excallback != null && !asyncReply) {
excallback.replyFailed(rmsg.message, reply, sender, x);
} else {
@@ -187,7 +186,7 @@ public class RpcChannel implements Chann
if ( msg instanceof RpcMessage ) {
RpcMessage rmsg = (RpcMessage)msg;
return Arrays.equals(rmsg.rpcId,rpcId);
- }else return false;
+ } else return false;
}
public Channel getChannel() {
@@ -239,7 +238,7 @@ public class RpcChannel implements Chann
this.destcnt = destcnt;
}
- public void addResponse(Serializable message, Member sender){
+ public void addResponse(Serializable message, Member sender) {
Response resp = new Response(sender,message);
responses.add(resp);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org