Package org.apache.hc.client5.http.impl.async

Class InternalH2AsyncExecRuntime

java.lang.Object

org.apache.hc.client5.http.impl.async.InternalH2AsyncExecRuntime

All Implemented Interfaces:

AsyncExecRuntime

class InternalH2AsyncExecRuntime
extends java.lang.Object
implements AsyncExecRuntime

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	InternalH2AsyncExecRuntime.Endpoint

Field Summary

Fields

Modifier and Type	Field	Description
private InternalH2ConnPool	connPool
private org.slf4j.Logger	log
private org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer>	pushHandlerFactory
private boolean	reusable
private java.util.concurrent.atomic.AtomicReference<InternalH2AsyncExecRuntime.Endpoint>	sessionRef

Constructor Summary

Constructors

Constructor	Description
InternalH2AsyncExecRuntime(org.slf4j.Logger log, InternalH2ConnPool connPool, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)

Method Summary

Modifier and Type	Method	Description
org.apache.hc.core5.concurrent.Cancellable	acquireEndpoint(java.lang.String id, HttpRoute route, java.lang.Object object, HttpClientContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)	Initiates operation to acquire a connection endpoint.
private void	closeEndpoint(InternalH2AsyncExecRuntime.Endpoint endpoint)
org.apache.hc.core5.concurrent.Cancellable	connectEndpoint(HttpClientContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)	Initiates operation to connect the local endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).
void	discardEndpoint()	Shuts down and discards the acquired endpoint.
void	disconnectEndpoint()	Disconnects the local endpoint from the initial hop in the connection route.
(package private) InternalH2AsyncExecRuntime.Endpoint	ensureValid()
org.apache.hc.core5.concurrent.Cancellable	execute(java.lang.String id, org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler, HttpClientContext context)	Initiates a message exchange using the given handler.
AsyncExecRuntime	fork()	Forks this runtime for parallel execution.
boolean	isEndpointAcquired()	Determines of a connection endpoint has been acquired.
boolean	isEndpointConnected()	Determines of there the endpoint is connected to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).
void	markConnectionNonReusable()	Marks the connection as non re-usable.
void	markConnectionReusable(java.lang.Object newState, org.apache.hc.core5.util.TimeValue newValidDuration)	Marks the connection as potentially re-usable for the given period of time and also marks it as stateful if the state representation is given.
void	releaseEndpoint()	Releases the acquired endpoint potentially making it available for re-use.
void	upgradeTls(HttpClientContext context)	Upgrades transport security of the active connection by using the TLS security protocol.
void	upgradeTls(HttpClientContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)	Upgrades transport security of the active connection by using the TLS security protocol.
boolean	validateConnection()	Validates the connection making sure it can be used to execute requests.

Methods inherited from class java.lang.Object

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

Field Detail

log

private final org.slf4j.Logger log

connPool

private final InternalH2ConnPool connPool

pushHandlerFactory

private final org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory

sessionRef

private final java.util.concurrent.atomic.AtomicReference<InternalH2AsyncExecRuntime.Endpoint> sessionRef

reusable

private volatile boolean reusable

Constructor Detail

InternalH2AsyncExecRuntime

InternalH2AsyncExecRuntime(org.slf4j.Logger log,
                           InternalH2ConnPool connPool,
                           org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)

Method Detail

isEndpointAcquired

public boolean isEndpointAcquired()

Description copied from interface: AsyncExecRuntime

Determines of a connection endpoint has been acquired.

Specified by:

isEndpointAcquired in interface AsyncExecRuntime

Returns:

true if an endpoint has been acquired, false otherwise.

acquireEndpoint

public org.apache.hc.core5.concurrent.Cancellable acquireEndpoint(java.lang.String id,
                                                                  HttpRoute route,
                                                                  java.lang.Object object,
                                                                  HttpClientContext context,
                                                                  org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)

Description copied from interface: AsyncExecRuntime

Initiates operation to acquire a connection endpoint. Endpoints can leased from a pool or unconnected new endpoint can be created.

Specified by:

acquireEndpoint in interface AsyncExecRuntime

Parameters:

id - unique operation ID or null.

route - the connection route.

object - the expected connection state. May be null if connection can be state-less or its state is irrelevant.

context - the execution context.

callback - the result callback.

Returns:

handle that can be used to cancel the operation.

closeEndpoint

private void closeEndpoint(InternalH2AsyncExecRuntime.Endpoint endpoint)

releaseEndpoint

public void releaseEndpoint()

Description copied from interface: AsyncExecRuntime

Releases the acquired endpoint potentially making it available for re-use.

Specified by:

releaseEndpoint in interface AsyncExecRuntime

discardEndpoint

public void discardEndpoint()

Description copied from interface: AsyncExecRuntime

Shuts down and discards the acquired endpoint.

Specified by:

discardEndpoint in interface AsyncExecRuntime

validateConnection

public boolean validateConnection()

Description copied from interface: AsyncExecRuntime

Validates the connection making sure it can be used to execute requests.

Specified by:

validateConnection in interface AsyncExecRuntime

Returns:

true if the connection is valid, false.

isEndpointConnected

public boolean isEndpointConnected()

Description copied from interface: AsyncExecRuntime

Determines of there the endpoint is connected to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).

Specified by:

isEndpointConnected in interface AsyncExecRuntime

Returns:

true if the endpoint is connected, false otherwise.

ensureValid

InternalH2AsyncExecRuntime.Endpoint ensureValid()

connectEndpoint

public org.apache.hc.core5.concurrent.Cancellable connectEndpoint(HttpClientContext context,
                                                                  org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)

Description copied from interface: AsyncExecRuntime

Initiates operation to connect the local endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).

Specified by:

connectEndpoint in interface AsyncExecRuntime

Parameters:

context - the execution context.

callback - the result callback.

Returns:

handle that can be used to cancel the operation.

disconnectEndpoint

public void disconnectEndpoint()

Description copied from interface: AsyncExecRuntime

Disconnects the local endpoint from the initial hop in the connection route.

Specified by:

disconnectEndpoint in interface AsyncExecRuntime

upgradeTls

public void upgradeTls(HttpClientContext context)

Description copied from interface: AsyncExecRuntime

Upgrades transport security of the active connection by using the TLS security protocol.

Specified by:

upgradeTls in interface AsyncExecRuntime

Parameters:

context - the execution context.

upgradeTls

public void upgradeTls(HttpClientContext context,
                       org.apache.hc.core5.concurrent.FutureCallback<AsyncExecRuntime> callback)

Description copied from interface: AsyncExecRuntime

Upgrades transport security of the active connection by using the TLS security protocol.

Specified by:

upgradeTls in interface AsyncExecRuntime

Parameters:

context - the execution context.

execute

public org.apache.hc.core5.concurrent.Cancellable execute(java.lang.String id,
                                                          org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler,
                                                          HttpClientContext context)

Description copied from interface: AsyncExecRuntime

Initiates a message exchange using the given handler.

Specified by:

execute in interface AsyncExecRuntime

Parameters:

id - unique operation ID or null.

exchangeHandler - the client message handler.

context - the execution context.

markConnectionReusable

public void markConnectionReusable(java.lang.Object newState,
                                   org.apache.hc.core5.util.TimeValue newValidDuration)

Description copied from interface: AsyncExecRuntime

Marks the connection as potentially re-usable for the given period of time and also marks it as stateful if the state representation is given.

Specified by:

markConnectionReusable in interface AsyncExecRuntime

Parameters:

newState - the connection state representation or null if stateless.

newValidDuration - the period of time this connection is valid for.

markConnectionNonReusable

public void markConnectionNonReusable()

Description copied from interface: AsyncExecRuntime

Marks the connection as non re-usable.

Specified by:

markConnectionNonReusable in interface AsyncExecRuntime

fork

public AsyncExecRuntime fork()

Description copied from interface: AsyncExecRuntime

Forks this runtime for parallel execution.

Specified by:

fork in interface AsyncExecRuntime

Returns:

another runtime with the same configuration.