tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kfuj...@apache.org
Subject svn commit: r1488876 - in /tomcat/trunk/java/org/apache/catalina/tribes/transport: bio/PooledMultiSender.java nio/PooledParallelSender.java
Date Mon, 03 Jun 2013 07:36:51 GMT
Author: kfujino
Date: Mon Jun  3 07:36:51 2013
New Revision: 1488876

URL: http://svn.apache.org/r1488876
Log:
Improve error message by including specified timeout if failed to retrieve a data sender.


Modified:
    tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java
    tomcat/trunk/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java

Modified: tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java?rev=1488876&r1=1488875&r2=1488876&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java Mon
Jun  3 07:36:51 2013
@@ -47,7 +47,7 @@ public class PooledMultiSender extends P
         try {
             sender = (MultiPointSender)getSender();
             if (sender == null) {
-                ChannelException cx = new ChannelException("Unable to retrieve a data sender,
time out error.");
+                ChannelException cx = new ChannelException("Unable to retrieve a data sender,
time out("+getMaxWait()+" ms) error.");
                 for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i],
new NullPointerException("Unable to retrieve a sender from the sender pool"));
                 throw cx;
             } else {

Modified: tomcat/trunk/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java?rev=1488876&r1=1488875&r2=1488876&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java Mon
Jun  3 07:36:51 2013
@@ -46,7 +46,7 @@ public class PooledParallelSender extend
         if ( !connected ) throw new ChannelException("Sender not connected.");
         ParallelNioSender sender = (ParallelNioSender)getSender();
         if (sender == null) {
-            ChannelException cx = new ChannelException("Unable to retrieve a data sender,
time out error.");
+            ChannelException cx = new ChannelException("Unable to retrieve a data sender,
time out("+getMaxWait()+" ms) error.");
             for (int i = 0; i < destination.length; i++) cx.addFaultyMember(destination[i],
new NullPointerException("Unable to retrieve a sender from the sender pool"));
             throw cx;
         } else {



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message