Fixes #233 - Add message to idle TimeoutException.

This commit is contained in:
Simone Bordet 2016-04-01 14:44:26 +02:00
parent 4aa512e468
commit ce04cadb79
5 changed files with 5 additions and 5 deletions

View File

@ -68,7 +68,7 @@ public class TimeoutCompleteListener implements Response.CompleteListener, Runna
{
if (LOG.isDebugEnabled())
LOG.debug("Executing timeout task {} for {}", task, request);
request.abort(new TimeoutException("Total timeout elapsed"));
request.abort(new TimeoutException("Total timeout " + request.getTimeout() + " ms elapsed"));
}
public void cancel()

View File

@ -101,7 +101,7 @@ public class HttpConnectionOverHTTP extends AbstractConnection implements Connec
long idleTimeout = getEndPoint().getIdleTimeout();
boolean close = delegate.onIdleTimeout(idleTimeout);
if (close)
close(new TimeoutException("Idle timeout " + idleTimeout + "ms"));
close(new TimeoutException("Idle timeout " + idleTimeout + " ms"));
return false;
}

View File

@ -198,7 +198,7 @@ public class HttpConnectionOverFCGI extends AbstractConnection implements Connec
if (multiplexed)
close &= isFillInterested();
if (close)
close(new TimeoutException("Idle timeout " + idleTimeout + "ms"));
close(new TimeoutException("Idle timeout " + idleTimeout + " ms"));
return false;
}

View File

@ -871,7 +871,7 @@ public abstract class HTTP2Session extends ContainerLifeCycle implements ISessio
case LOCALLY_CLOSED:
case REMOTELY_CLOSED:
{
abort(new TimeoutException());
abort(new TimeoutException("Idle timeout " + endPoint.getIdleTimeout() + " ms"));
return false;
}
default:

View File

@ -155,7 +155,7 @@ public interface SocketAddressResolver
{
if (complete.compareAndSet(false, true))
{
promise.failed(new TimeoutException());
promise.failed(new TimeoutException("DNS timeout " + getTimeout() + " ms"));
thread.interrupt();
}
}, timeout, TimeUnit.MILLISECONDS);