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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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
-
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
- routestate
- stateconnectTimeout
- http connection timeoutleaseTimeout
- timeout to wait in a request queue until kicked offfuture
- 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 interfaceCancellable
- Returns:
true
if the operation or process has been cancelled as a result of this method call orfalse
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 classjava.lang.Object
-
-