Modifier and Type	Class and Description
pack-priv static class	MultiExchange.CancelableRef
private static class	MultiExchange.ConnectTimeoutTracker
pack-priv static class	MultiExchange.NullSubscription

Field Summary

Modifier and Type	Field and Description
pack-priv final AccessControlContext	acc References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element.
pack-priv final AtomicInteger	attempts
pack-priv volatile boolean	cancelled
pack-priv final HttpClientImpl	client
private final MultiExchange.ConnectTimeoutTracker	connectTimeout
pack-priv HttpRequestImpl	currentreq
pack-priv static final Logger	debug
pack-priv static final int	DEFAULT_MAX_ATTEMPTS
pack-priv Exchange<T>	exchange
pack-priv final HttpClientImpl.DelegatingExecutor	executor
pack-priv volatile boolean	expiredOnce
private final List<HeaderFilter>	filters
pack-priv AtomicReference<CancellationException>	interrupted
pack-priv static final int	max_attempts
pack-priv volatile int	numberOfRedirects
pack-priv Exchange<T>	previous
pack-priv HttpRequestImpl	previousreq
pack-priv volatile AuthenticationFilter.AuthInfo	proxyauth Filter fields.
pack-priv final PushGroup<T>	pushGroup
private final HttpRequestImpl	request
pack-priv volatile HttpResponse<T>	response
pack-priv final HttpResponse.BodyHandler<T>	responseHandler
pack-priv volatile ResponseTimerEvent	responseTimerEvent
private static final boolean	RETRY_ALWAYS True if ALL ( even non-idempotent ) requests can be automatic retried.
pack-priv static final boolean	RETRY_CONNECT True if ConnectException should cause a retry.
pack-priv volatile Throwable	retryCause
pack-priv volatile AuthenticationFilter.AuthInfo	serverauth Filter fields.
private final HttpRequest	userRequest

Constructor Summary

Access	Constructor and Description
pack-priv	MultiExchange(HttpRequest userRequest, HttpRequestImpl requestImpl, HttpClientImpl client, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler, AccessControlContext acc) References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. MultiExchange with one final response.

Method Summary

Modifier and Type	Method and Description
private boolean	bodyIsPresent(Response r)
private static boolean	bodyNotPermitted(Response r)
public void	cancel(IOException cause)
public boolean	Returns: true if the exchange was cancelled, false otherwise. cancel(boolean if true, and this exchange is not already cancelled, this method will attempt to interrupt and cancel the exchange. Otherwise, the exchange is allowed to proceed and this method does nothing. mayInterruptIfRunning) Implements jdk.internal.net.http.common.Cancelable.cancel. Used to relay a call from `CompletableFuture#cancel(boolean)` to this multi exchange for the purpose of cancelling the HTTP exchange.
private void	cancelTimer()
private static boolean	canRetryRequest(HttpRequest request) Returns true if the given request can be automatically retried.
pack-priv HttpClientImpl	client()
private static boolean	disableRetryConnect()
private CompletableFuture<Response>	getExceptionalCF(Throwable t) Takes a Throwable and returns a suitable CompletableFuture that is completed exceptionally, or null.
pack-priv synchronized Exchange<T>	getExchange()
private CompletableFuture<HttpResponse<T>>	handleNoBody(Response r, Exchange<T> exch)
private static boolean	isIdempotentRequest(HttpRequest request) Returns true is given request has an idempotent method.
public <U> MinimalFuture<U>	newMinimalFuture()
public Optional<Duration>	remainingConnectTimeout()
pack-priv boolean	requestCancelled()
private void	requestFilters(HttpRequestImpl r)
public CompletableFuture<HttpResponse<T>>	responseAsync(Executor executor)
private CompletableFuture<HttpResponse<T>>	responseAsync0(CompletableFuture<Void> start)
private CompletableFuture<Response>	responseAsyncImpl()
private HttpRequestImpl	responseFilters(Response response)
private Throwable	retryCause(Throwable t)
private boolean	retryOnFailure(Throwable t)
private static boolean	retryPostValue()
private void	setExchange(Exchange<T> exchange)
private HttpTimeoutException	toTimeoutException(IOException ioe)
pack-priv HttpClient.Version	version()
private CompletableFuture<HttpResponse<T>>	whenCancelled(Throwable t)
private Throwable	wrapIfCancelled(Throwable cause)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

acc	back to summary
pack-priv final AccessControlContext acc References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Annotations @SuppressWarnings:removal

attempts	back to summary
pack-priv final AtomicInteger attempts

cancelled	back to summary
pack-priv volatile boolean cancelled

client	back to summary
pack-priv final HttpClientImpl client

connectTimeout	back to summary
private final MultiExchange.ConnectTimeoutTracker connectTimeout

currentreq	back to summary
pack-priv HttpRequestImpl currentreq

debug	back to summary
pack-priv static final Logger debug

DEFAULT_MAX_ATTEMPTS	back to summary
pack-priv static final int DEFAULT_MAX_ATTEMPTS

exchange	back to summary
pack-priv Exchange<T> exchange

executor	back to summary
pack-priv final HttpClientImpl.DelegatingExecutor executor

expiredOnce	back to summary
pack-priv volatile boolean expiredOnce

filters	back to summary
private final List<HeaderFilter> filters

interrupted	back to summary
pack-priv AtomicReference<CancellationException> interrupted

max_attempts	back to summary
pack-priv static final int max_attempts

numberOfRedirects	back to summary
pack-priv volatile int numberOfRedirects

previous	back to summary
pack-priv Exchange<T> previous

previousreq	back to summary
pack-priv HttpRequestImpl previousreq

proxyauth	back to summary
pack-priv volatile AuthenticationFilter.AuthInfo proxyauth Filter fields. These are attached as required by filters and only used by the filter implementations. This could be generalised into Objects that are passed explicitly to the filters (one per MultiExchange object, and one per Exchange object possibly)

pushGroup	back to summary
pack-priv final PushGroup<T> pushGroup

request	back to summary
private final HttpRequestImpl request

response	back to summary
pack-priv volatile HttpResponse<T> response

responseHandler	back to summary
pack-priv final HttpResponse.BodyHandler<T> responseHandler

responseTimerEvent	back to summary
pack-priv volatile ResponseTimerEvent responseTimerEvent

RETRY_ALWAYS	back to summary
private static final boolean RETRY_ALWAYS True if ALL ( even non-idempotent ) requests can be automatic retried.

RETRY_CONNECT	back to summary
pack-priv static final boolean RETRY_CONNECT True if ConnectException should cause a retry. Enabled by default

retryCause	back to summary
pack-priv volatile Throwable retryCause

serverauth	back to summary
pack-priv volatile AuthenticationFilter.AuthInfo serverauth Filter fields. These are attached as required by filters and only used by the filter implementations. This could be generalised into Objects that are passed explicitly to the filters (one per MultiExchange object, and one per Exchange object possibly)

userRequest	back to summary
private final HttpRequest userRequest

Constructor Detail

MultiExchange back to summary

MultiExchange	back to summary
pack-priv MultiExchange(HttpRequest userRequest, HttpRequestImpl requestImpl, HttpClientImpl client, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler, AccessControlContext acc) References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. MultiExchange with one final response.

pack-priv MultiExchange(HttpRequest userRequest, HttpRequestImpl requestImpl, HttpClientImpl client, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler, AccessControlContext acc)

References Deprecated

AccessControlContext is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

MultiExchange with one final response.

Method Detail

bodyIsPresent	back to summary
private boolean bodyIsPresent(Response r)

bodyNotPermitted	back to summary
private static boolean bodyNotPermitted(Response r)

cancel	back to summary
public void cancel(IOException cause)

cancel back to summary

cancel	back to summary
public boolean cancel(boolean mayInterruptIfRunning) Implements jdk.internal.net.http.common.Cancelable.cancel. Used to relay a call from `CompletableFuture#cancel(boolean)` to this multi exchange for the purpose of cancelling the HTTP exchange. Parameters mayInterruptIfRunning:boolean if true, and this exchange is not already cancelled, this method will attempt to interrupt and cancel the exchange. Otherwise, the exchange is allowed to proceed and this method does nothing. Returns:boolean true if the exchange was cancelled, false otherwise. Annotations @Override

public boolean cancel(boolean mayInterruptIfRunning)

Implements jdk.internal.net.http.common.Cancelable.cancel.

Used to relay a call from CompletableFuture#cancel(boolean) to this multi exchange for the purpose of cancelling the HTTP exchange.

Parameters

mayInterruptIfRunning:boolean: if true, and this exchange is not already cancelled, this method will attempt to interrupt and cancel the exchange. Otherwise, the exchange is allowed to proceed and this method does nothing.

Returns:boolean

true if the exchange was cancelled, false otherwise.

Annotations

@Override

cancelTimer	back to summary
private void cancelTimer()

canRetryRequest	back to summary
private static boolean canRetryRequest(HttpRequest request) Returns true if the given request can be automatically retried.

client	back to summary
pack-priv HttpClientImpl client()

disableRetryConnect	back to summary
private static boolean disableRetryConnect()

getExceptionalCF	back to summary
private CompletableFuture<Response> getExceptionalCF(Throwable t) Takes a Throwable and returns a suitable CompletableFuture that is completed exceptionally, or null.

getExchange	back to summary
pack-priv synchronized Exchange<T> getExchange()

handleNoBody	back to summary
private CompletableFuture<HttpResponse<T>> handleNoBody(Response r, Exchange<T> exch)

isIdempotentRequest	back to summary
private static boolean isIdempotentRequest(HttpRequest request) Returns true is given request has an idempotent method.

newMinimalFuture	back to summary
public <U> MinimalFuture<U> newMinimalFuture()

remainingConnectTimeout	back to summary
public Optional<Duration> remainingConnectTimeout()

requestCancelled	back to summary
pack-priv boolean requestCancelled()

requestFilters	back to summary
private void requestFilters(HttpRequestImpl r) throws IOException

responseAsync	back to summary
public CompletableFuture<HttpResponse<T>> responseAsync(Executor executor)

responseAsync0	back to summary
private CompletableFuture<HttpResponse<T>> responseAsync0(CompletableFuture<Void> start)

responseAsyncImpl	back to summary
private CompletableFuture<Response> responseAsyncImpl()

responseFilters	back to summary
private HttpRequestImpl responseFilters(Response response) throws IOException

retryCause	back to summary
private Throwable retryCause(Throwable t)

retryOnFailure	back to summary
private boolean retryOnFailure(Throwable t)

retryPostValue	back to summary
private static boolean retryPostValue()

setExchange	back to summary
private void setExchange(Exchange<T> exchange)

toTimeoutException	back to summary
private HttpTimeoutException toTimeoutException(IOException ioe)

version	back to summary
pack-priv HttpClient.Version version()

whenCancelled	back to summary
private CompletableFuture<HttpResponse<T>> whenCancelled(Throwable t)

wrapIfCancelled	back to summary
private Throwable wrapIfCancelled(Throwable cause)

jdk.internal.net.http back to summary

pack-priv final Class MultiExchange.CancelableRef

Class Inheritance

extends Object
implements Cancelable

java.lang.Object
jdk.internal.net.http.MultiExchange.CancelableRef

All Implemented Interfaces

jdk.internal.net.http.common.Cancelable

Field Summary

Modifier and Type	Field and Description
private final WeakReference<Cancelable>	cancelableRef

Constructor Summary

Access	Constructor and Description
pack-priv	CancelableRef(Cancelable cancelable)

Method Summary

Modifier and Type	Method and Description
public boolean	cancel(boolean `true` if an attempt to stop the task should be made even if the task has already started; otherwise, in-progress tasks are allowed to complete. mayInterruptIfRunning) Implements jdk.internal.net.http.common.Cancelable.cancel. Attempts to cancel execution of a task.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

cancelableRef	back to summary
private final WeakReference<Cancelable> cancelableRef

Constructor Detail

CancelableRef	back to summary
pack-priv CancelableRef(Cancelable cancelable)

Method Detail

cancel back to summary

public boolean cancel(boolean mayInterruptIfRunning)

Implements jdk.internal.net.http.common.Cancelable.cancel.

Doc from jdk.internal.net.http.common.Cancelable.cancel.

Attempts to cancel execution of a task. This attempt may not succeed if the task has already completed, has already been cancelled, or could not be cancelled for some other reason.

Parameters

mayInterruptIfRunning:boolean: true if an attempt to stop the task should be made even if the task has already started; otherwise, in-progress tasks are allowed to complete.

Returns:boolean

false if the task could not be cancelled, typically because it has already completed normally; true otherwise

Annotations

@Override

jdk.internal.net.http back to summary

private final Class MultiExchange.ConnectTimeoutTracker

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.MultiExchange.ConnectTimeoutTracker

Field Summary

Modifier and Type	Field and Description
pack-priv final Duration	max
pack-priv final AtomicLong	startTime

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectTimeoutTracker(Duration connectTimeout)

Method Summary

Modifier and Type	Method and Description
pack-priv Duration	getRemaining()
pack-priv void	reset()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

max	back to summary
pack-priv final Duration max

startTime	back to summary
pack-priv final AtomicLong startTime

Constructor Detail

ConnectTimeoutTracker	back to summary
pack-priv ConnectTimeoutTracker(Duration connectTimeout)

Method Detail

getRemaining	back to summary
pack-priv Duration getRemaining()

reset	back to summary
pack-priv void reset()

jdk.internal.net.http back to summary

pack-priv Class MultiExchange.NullSubscription

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.MultiExchange.NullSubscription

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Constructor Summary

Access	Constructor and Description
pack-priv	NullSubscription()

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements java.util.concurrent.Flow.Subscription.cancel. Causes the Subscriber to (eventually) stop receiving messages.
public void	request(long the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

NullSubscription	back to summary
pack-priv NullSubscription()

Method Detail

cancel back to summary

public void cancel()

Implements java.util.concurrent.Flow.Subscription.cancel.

Doc from java.util.concurrent.Flow.Subscription.cancel.

Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an onComplete or onError signal.

Annotations

@Override

request back to summary

public void request(long n)

Implements java.util.concurrent.Flow.Subscription.request.

Doc from java.util.concurrent.Flow.Subscription.request.

Adds the given number n of items to the current unfulfilled demand for this subscription. If n is less than or equal to zero, the Subscriber will receive an onError signal with an IllegalArgumentException argument. Otherwise, the Subscriber will receive up to n additional onNext invocations (or fewer if terminated).

Parameters

n:long: the increment of demand; a value of Long.MAX_VALUE may be considered as effectively unbounded

Annotations

@Override

pack-priv Class MultiExchange<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class MultiExchange.CancelableRef

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class MultiExchange.ConnectTimeoutTracker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class MultiExchange.NullSubscription

Constructor Summary

Method Summary

Constructor Detail

Method Detail