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: [email protected]
For additional commands, e-mail: [email protected]
