Class HttpDestination.RequestTimeouts

java.lang.Object
org.eclipse.jetty.io.CyclicTimeouts<HttpExchange>
org.eclipse.jetty.client.HttpDestination.RequestTimeouts
All Implemented Interfaces:
Destroyable
Enclosing class:
HttpDestination

private class HttpDestination.RequestTimeouts extends CyclicTimeouts<HttpExchange>

Enforces the total timeout for for exchanges that are still in the queue.

The total timeout for exchanges that are not in the destination queue is enforced in HttpConnection.

  • Constructor Details

    • RequestTimeouts

      private RequestTimeouts(Scheduler scheduler)
  • Method Details

    • iterator

      protected Iterator<HttpExchange> iterator()
      Specified by:
      iterator in class CyclicTimeouts<HttpExchange>
      Returns:
      the entities to iterate over when this instance expires
    • onExpired

      protected boolean onExpired(HttpExchange exchange)
      Description copied from class: CyclicTimeouts

      Invoked during the iteration when the given entity is expired.

      This method may be invoked multiple times, and even concurrently, for the same expirable entity and therefore the expiration of the entity, if any, should be an idempotent action.

      Specified by:
      onExpired in class CyclicTimeouts<HttpExchange>
      Parameters:
      exchange - the entity that is expired
      Returns:
      whether the entity should be removed from the iterator via Iterator.remove()