Package org.apache.http.nio.pool

Class RouteSpecificPool<T,C,E extends PoolEntry<T,C>>

java.lang.Object

org.apache.http.nio.pool.RouteSpecificPool<T,C,E>

abstract class RouteSpecificPool<T,C,E extends PoolEntry<T,C>>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.LinkedList<E>	available
private java.util.Set<E>	leased
private java.util.Map<SessionRequest,BasicFuture<E>>	pending
private T	route

Constructor Summary

Constructors

Constructor	Description
RouteSpecificPool(T route)

Method Summary

Modifier and Type	Method	Description
void	addPending(SessionRequest request, BasicFuture<E> future)
void	cancelled(SessionRequest request)
boolean	completed(SessionRequest request, E entry)
E	createEntry(SessionRequest request, C conn)
protected abstract E	createEntry(T route, C conn)
void	failed(SessionRequest request, java.lang.Exception ex)
void	free(E entry, boolean reusable)
int	getAllocatedCount()
int	getAvailableCount()
E	getFree(java.lang.Object state)
E	getLastUsed()
int	getLeasedCount()
int	getPendingCount()
T	getRoute()
boolean	remove(E entry)
private BasicFuture<E>	removeRequest(SessionRequest request)
void	shutdown()
void	timeout(SessionRequest request)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

route

private final T route

leased

private final java.util.Set<E extends PoolEntry<T,C>> leased

available

private final java.util.LinkedList<E extends PoolEntry<T,C>> available

pending

private final java.util.Map<SessionRequest,BasicFuture<E extends PoolEntry<T,C>>> pending

Constructor Detail

RouteSpecificPool

RouteSpecificPool(T route)

Method Detail

getRoute

public T getRoute()

createEntry

protected abstract E createEntry(T route,
                                 C conn)

getLeasedCount

public int getLeasedCount()

getPendingCount

public int getPendingCount()

getAvailableCount

public int getAvailableCount()

getAllocatedCount

public int getAllocatedCount()

getFree

public E getFree(java.lang.Object state)

getLastUsed

public E getLastUsed()

remove

public boolean remove(E entry)

free

public void free(E entry,
                 boolean reusable)

addPending

public void addPending(SessionRequest request,
                       BasicFuture<E> future)

removeRequest

private BasicFuture<E> removeRequest(SessionRequest request)

createEntry

public E createEntry(SessionRequest request,
                     C conn)

completed

public boolean completed(SessionRequest request,
                         E entry)

cancelled

public void cancelled(SessionRequest request)

failed

public void failed(SessionRequest request,
                   java.lang.Exception ex)

timeout

public void timeout(SessionRequest request)

shutdown

public void shutdown()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object