Package org.apache.http.nio.pool

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

java.lang.Object

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

All Implemented Interfaces:

Cancellable

class LeaseRequest<T,C,E extends PoolEntry<T,C>>
extends Object
implements Cancellable

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	completed
private final long	connectTimeout
private final long	deadline
private Exception	ex
private final BasicFuture<E>	future
private E	result
private final T	route
private final AtomicReference<SessionRequest>	sessionRequestRef
private final Object	state

Constructor Summary

Constructors

Constructor	Description
LeaseRequest(T route, Object state, long connectTimeout, long leaseTimeout, BasicFuture<E> future)	Contructor

Method Summary

Modifier and Type	Method	Description
void	attachSessionRequest(SessionRequest sessionRequest)
boolean	cancel()	Cancels the ongoing operation or process.
void	completed(E result)
void	failed(Exception ex)
long	getConnectTimeout()
long	getDeadline()
Exception	getException()
BasicFuture<E>	getFuture()
E	getResult()
T	getRoute()
Object	getState()
boolean	isDone()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

route

private final T route

state

private final Object state

connectTimeout

private final long connectTimeout

deadline

private final long deadline

future

private final BasicFuture<E extends PoolEntry<T,C>> future

sessionRequestRef

private final AtomicReference<SessionRequest> sessionRequestRef

completed

private final AtomicBoolean completed

result

private volatile E extends PoolEntry<T,C> result

ex

private volatile Exception ex

Constructor Details

LeaseRequest

public LeaseRequest(T route,
 Object state,
 long connectTimeout,
 long leaseTimeout,
 BasicFuture<E> future)

Contructor

Parameters:

route - route

state - state

connectTimeout - http connection timeout

leaseTimeout - timeout to wait in a request queue until kicked off

future - future callback

Method Details

getRoute

public T getRoute()

getState

public Object getState()

getConnectTimeout

public long getConnectTimeout()

getDeadline

public long getDeadline()

isDone

public boolean isDone()

attachSessionRequest

public void attachSessionRequest(SessionRequest sessionRequest)

cancel

public boolean cancel()

Description copied from interface: Cancellable

Cancels the ongoing operation or process.

Specified by:

cancel in interface Cancellable

Returns:

true if the operation or process has been cancelled as a result of this method call or false if it has already been cancelled or not started.

failed

public void failed(Exception ex)

completed

public void completed(E result)

getFuture

public BasicFuture<E> getFuture()

getResult

public E getResult()

getException

public Exception getException()

toString

public String toString()

Overrides:

toString in class Object