Class AbstractNIOConnPool<T,C,E extends org.apache.http.pool.PoolEntry<T,C>>

java.lang.Object
org.apache.http.nio.pool.AbstractNIOConnPool<T,C,E>
Type Parameters:
T - route
C - connection object
E - pool entry
All Implemented Interfaces:
org.apache.http.pool.ConnPool<T,E>, org.apache.http.pool.ConnPoolControl<T>
Direct Known Subclasses:
BasicNIOConnPool

@Contract(threading=SAFE_CONDITIONAL) public abstract class AbstractNIOConnPool<T,C,E extends org.apache.http.pool.PoolEntry<T,C>> extends Object implements org.apache.http.pool.ConnPool<T,E>, org.apache.http.pool.ConnPoolControl<T>
Abstract non-blocking connection pool.
Since:
4.2
  • Constructor Details

  • Method Details

    • resolveRemoteAddress

      @Deprecated protected SocketAddress resolveRemoteAddress(T route)
      Deprecated.
    • resolveLocalAddress

      @Deprecated protected SocketAddress resolveLocalAddress(T route)
      Deprecated.
    • createEntry

      protected abstract E createEntry(T route, C conn)
    • onLease

      protected void onLease(E entry)
      Since:
      4.3
    • onRelease

      protected void onRelease(E entry)
      Since:
      4.3
    • onReuse

      protected void onReuse(E entry)
      Since:
      4.4
    • isShutdown

      public boolean isShutdown()
    • shutdown

      public void shutdown(long waitMs) throws IOException
      Throws:
      IOException
    • lease

      public Future<E> lease(T route, Object state, long connectTimeout, TimeUnit timeUnit, org.apache.http.concurrent.FutureCallback<E> callback)
    • lease

      public Future<E> lease(T route, Object state, long connectTimeout, long leaseTimeout, TimeUnit timeUnit, org.apache.http.concurrent.FutureCallback<E> callback)
      Since:
      4.3
    • lease

      public Future<E> lease(T route, Object state, org.apache.http.concurrent.FutureCallback<E> callback)
      Specified by:
      lease in interface org.apache.http.pool.ConnPool<T,C>
    • lease

      public Future<E> lease(T route, Object state)
    • release

      public void release(E entry, boolean reusable)
      Specified by:
      release in interface org.apache.http.pool.ConnPool<T,C>
    • validatePendingRequests

      public void validatePendingRequests()
    • requestCompleted

      protected void requestCompleted(SessionRequest request)
    • requestCancelled

      protected void requestCancelled(SessionRequest request)
    • requestFailed

      protected void requestFailed(SessionRequest request)
    • requestTimeout

      protected void requestTimeout(SessionRequest request)
    • setMaxTotal

      public void setMaxTotal(int max)
      Specified by:
      setMaxTotal in interface org.apache.http.pool.ConnPoolControl<T>
    • getMaxTotal

      public int getMaxTotal()
      Specified by:
      getMaxTotal in interface org.apache.http.pool.ConnPoolControl<T>
    • setDefaultMaxPerRoute

      public void setDefaultMaxPerRoute(int max)
      Specified by:
      setDefaultMaxPerRoute in interface org.apache.http.pool.ConnPoolControl<T>
    • getDefaultMaxPerRoute

      public int getDefaultMaxPerRoute()
      Specified by:
      getDefaultMaxPerRoute in interface org.apache.http.pool.ConnPoolControl<T>
    • setMaxPerRoute

      public void setMaxPerRoute(T route, int max)
      Specified by:
      setMaxPerRoute in interface org.apache.http.pool.ConnPoolControl<T>
    • getMaxPerRoute

      public int getMaxPerRoute(T route)
      Specified by:
      getMaxPerRoute in interface org.apache.http.pool.ConnPoolControl<T>
    • getTotalStats

      public org.apache.http.pool.PoolStats getTotalStats()
      Specified by:
      getTotalStats in interface org.apache.http.pool.ConnPoolControl<T>
    • getStats

      public org.apache.http.pool.PoolStats getStats(T route)
      Specified by:
      getStats in interface org.apache.http.pool.ConnPoolControl<T>
    • getRoutes

      public Set<T> getRoutes()
      Returns snapshot of all knows routes
      Since:
      4.4
    • enumAvailable

      protected void enumAvailable(org.apache.http.pool.PoolEntryCallback<T,C> callback)
      Enumerates all available connections.
      Since:
      4.3
    • enumLeased

      protected void enumLeased(org.apache.http.pool.PoolEntryCallback<T,C> callback)
      Enumerates all leased connections.
      Since:
      4.3
    • enumEntries

      @Deprecated protected void enumEntries(Iterator<E> it, org.apache.http.pool.PoolEntryCallback<T,C> callback)
      Deprecated.
      (4.3.2)
    • closeIdle

      public void closeIdle(long idletime, TimeUnit timeUnit)
    • closeExpired

      public void closeExpired()
    • toString

      public String toString()
      Overrides:
      toString in class Object