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 java.lang.Object
implements Cancellable

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.atomic.AtomicBoolean	completed
private long	connectTimeout
private long	deadline
private java.lang.Exception	ex
private BasicFuture<E>	future
private E	result
private T	route
private java.util.concurrent.atomic.AtomicReference<SessionRequest>	sessionRequestRef
private java.lang.Object	state

Constructor Summary

Constructors

Constructor	Description
LeaseRequest(T route, java.lang.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(java.lang.Exception ex)
long	getConnectTimeout()
long	getDeadline()
java.lang.Exception	getException()
BasicFuture<E>	getFuture()
E	getResult()
T	getRoute()
java.lang.Object	getState()
boolean	isDone()
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

state

private final java.lang.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 java.util.concurrent.atomic.AtomicReference<SessionRequest> sessionRequestRef

completed

private final java.util.concurrent.atomic.AtomicBoolean completed

result

private volatile E extends PoolEntry<T,C> result

ex

private volatile java.lang.Exception ex

Constructor Detail

LeaseRequest

public LeaseRequest(T route,
                    java.lang.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 Detail

getRoute

public T getRoute()

getState

public java.lang.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(java.lang.Exception ex)

completed

public void completed(E result)

getFuture

public BasicFuture<E> getFuture()

getResult

public E getResult()

getException

public java.lang.Exception getException()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object