fhanik 2004/09/29 11:56:18
Modified: modules/cluster/src/share/org/apache/catalina/cluster/tcp
ReplicationTransmitter.java
Log:
Fixed, setting the flag in the correct place
Revision Changes Path
1.17 +2 -2
jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
Index: ReplicationTransmitter.java
===================================================================
RCS file:
/home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java,v
retrieving revision 1.16
retrieving revision 1.17
diff -u -r1.16 -r1.17
--- ReplicationTransmitter.java 29 Sep 2004 18:23:55 -0000 1.16
+++ ReplicationTransmitter.java 29 Sep 2004 18:56:18 -0000 1.17
@@ -116,6 +116,8 @@
{
if (!sender.isConnected())
sender.connect();
+ //set the timeout, will be ignored by async senders
+ sender.setAckTimeout(getAckTimeout());
sender.sendMessage(sessionId,data);
sender.setSuspect(false);
addStats(data.length);
@@ -146,8 +148,6 @@
{
IDataSender sender = senders[i];
- //set the timeout, will be ignored by async senders
- sender.setAckTimeout(getAckTimeout());
try
{
sendMessageData(sessionId,data,sender);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
