Author: fhanik
Date: Tue Apr 25 07:15:53 2006
New Revision: 396896
URL: http://svn.apache.org/viewcvs?rev=396896&view=rev
Log:
don't need to add it to the map, if we don't expect any responses
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java?rev=396896&r1=396895&r2=396896&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/RpcChannel.java
Tue Apr 25 07:15:53 2006
@@ -88,10 +88,10 @@
RpcCollector collector = new
RpcCollector(key,rpcOptions,destination.length,timeout);
try {
synchronized (collector) {
- responseMap.put(key, collector);
+ if ( rpcOptions != NO_REPLY ) responseMap.put(key, collector);
RpcMessage rmsg = new RpcMessage(rpcId, key.id, message);
channel.send(destination, rmsg, channelOptions);
- if ( rpcOptions != NO_REPLY) collector.wait(timeout);
+ if ( rpcOptions != NO_REPLY ) collector.wait(timeout);
}
} catch ( InterruptedException ix ) {
Thread.currentThread().interrupted();
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
