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

Field Summary

Modifier and Type	Field and Description
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
private final List<HeaderFilter>	filters
pack-priv final long	id
private static final AtomicLong	IDS
pack-priv AtomicReference<CancellationException>	interrupted
pack-priv static final int	max_attempts
pack-priv static final int	max_stream_limit_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 AuthenticationFilter.AuthInfo	serverauth Filter fields.
private final AtomicInteger	streamLimitRetries
private final HttpRequest	userRequest

Access	Constructor and Description
pack-priv	MultiExchange(HttpRequest userRequest, HttpRequestImpl requestImpl, HttpClientImpl client, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler) MultiExchange with one final response.

Method Summary

Modifier and Type	Method and Description
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.
pack-priv void	cancelTimer()
private MultiExchange.RetryContext	Returns: a non-null RetryContext which contains the result of retry eligibility checkRetryEligible(final Throwable the exception that caused the request to fail requestFailureCause, final Exchange<?> the Exchange exchg) This method determines if a failed request can be retried.
pack-priv HttpClientImpl	client()
private static boolean	disableRetryConnect()
private void	ensureNoBody(HttpHeaders headers)
pack-priv synchronized Exchange<T>	getExchange()
private CompletableFuture<HttpResponse<T>>	handleNoBody(Response r, Exchange<T> exch)
private static boolean	isHttpMethodRetriable(HttpRequest request) Returns true if the given request can be automatically retried.
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(final boolean applyReqFilters)
private HttpRequestImpl	responseFilters(Response response)
private static boolean	retryPostValue()
private CompletableFuture<Response>	retryRequest()
private void	setExchange(Exchange<T> exchange)
private HttpResponse<T>	setNewResponse(HttpRequest request, Response r, T body, Exchange<T> exch)
pack-priv String	streamLimitState()
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

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

filters	back to summary
private final List<HeaderFilter> filters

id	back to summary
pack-priv final long id

IDS	back to summary
private static final AtomicLong IDS

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

max_attempts	back to summary
pack-priv static final int max_attempts

max_stream_limit_attempts	back to summary
pack-priv static final int max_stream_limit_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

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)

streamLimitRetries	back to summary
private final AtomicInteger streamLimitRetries

userRequest	back to summary
private final HttpRequest userRequest

MultiExchange	back to summary
pack-priv MultiExchange(HttpRequest userRequest, HttpRequestImpl requestImpl, HttpClientImpl client, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler) MultiExchange with one final response.

Method Detail

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
pack-priv void cancelTimer()

checkRetryEligible back to summary

checkRetryEligible	back to summary
private MultiExchange.RetryContext checkRetryEligible(final Throwable requestFailureCause, final Exchange<?> exchg) This method determines if a failed request can be retried. The returned RetryContext will contain the retry decision and the underlying cause (computed out of the given `requestFailureCause`) of the request failure. Parameters requestFailureCause:Throwable the exception that caused the request to fail exchg:Exchange<?> the Exchange Returns:MultiExchange.RetryContext a non-null RetryContext which contains the result of retry eligibility

private MultiExchange.RetryContext checkRetryEligible(final Throwable requestFailureCause, final Exchange<?> exchg)

This method determines if a failed request can be retried. The returned RetryContext will contain the retry decision and the underlying cause (computed out of the given requestFailureCause) of the request failure.

Parameters

requestFailureCause:Throwable: the exception that caused the request to fail
exchg:Exchange<?>: the Exchange

Returns:MultiExchange.RetryContext

a non-null RetryContext which contains the result of retry eligibility

client	back to summary
pack-priv HttpClientImpl client()

disableRetryConnect	back to summary
private static boolean disableRetryConnect()

ensureNoBody	back to summary
private void ensureNoBody(HttpHeaders headers) throws ProtocolException

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

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

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

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(final boolean applyReqFilters)

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

retryPostValue	back to summary
private static boolean retryPostValue()

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

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

setNewResponse	back to summary
private HttpResponse<T> setNewResponse(HttpRequest request, Response r, T body, Exchange<T> exch)

streamLimitState	back to summary
pack-priv String streamLimitState()

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 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.

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 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).

Annotations

@Override

jdk.internal.net.http back to summary

private final Record MultiExchange.RetryContext

Class Inheritance

extends Record

java.lang.Object
java.lang.Record
jdk.internal.net.http.MultiExchange.RetryContext

Record Components

requestFailureCause:Throwable
shouldRetry:boolean
reqAttemptCounter:AtomicInteger
shouldResetConnectTimer:boolean

Field Summary

Modifier and Type	Field and Description
private final AtomicInteger	reqAttemptCounter Record Component accessed by reqAttemptCounter().
private final Throwable	requestFailureCause Record Component accessed by requestFailureCause().
private final boolean	shouldResetConnectTimer Record Component accessed by shouldResetConnectTimer().
private final boolean	shouldRetry Record Component accessed by shouldRetry().

Constructor Summary

Access	Constructor and Description
private	RetryContext(Throwable requestFailureCause, boolean shouldRetry, AtomicInteger reqAttemptCounter, boolean shouldResetConnectTimer)

Method Summary

Modifier and Type	Method and Description
private static MultiExchange.RetryContext	doNotRetry(Throwable requestFailureCause)
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
public AtomicInteger	reqAttemptCounter() Record Component getter of reqAttemptCounter.
public Throwable	requestFailureCause() Record Component getter of requestFailureCause.
public boolean	shouldResetConnectTimer() Record Component getter of shouldResetConnectTimer.
public boolean	shouldRetry() Record Component getter of shouldRetry.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

reqAttemptCounter	back to summary
private final AtomicInteger reqAttemptCounter Record Component accessed by reqAttemptCounter().

requestFailureCause	back to summary
private final Throwable requestFailureCause Record Component accessed by requestFailureCause().

shouldResetConnectTimer	back to summary
private final boolean shouldResetConnectTimer Record Component accessed by shouldResetConnectTimer().

shouldRetry	back to summary
private final boolean shouldRetry Record Component accessed by shouldRetry().

Constructor Detail

RetryContext	back to summary
private RetryContext(Throwable requestFailureCause, boolean shouldRetry, AtomicInteger reqAttemptCounter, boolean shouldResetConnectTimer)

Method Detail

doNotRetry	back to summary
private static MultiExchange.RetryContext doNotRetry(Throwable requestFailureCause)

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

Indicates whether some other object is "equal to" this one. In addition to the general contract of Object.equals, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows:

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

Returns a hash code value for the record. Obeys the general contract of Object.hashCode. For records, hashing behavior is constrained by the refined contract of Record.equals, so that any two records created from the same components must have the same hash code.

reqAttemptCounter	back to summary
public AtomicInteger reqAttemptCounter() Record Component getter of reqAttemptCounter.

requestFailureCause	back to summary
public Throwable requestFailureCause() Record Component getter of requestFailureCause.

shouldResetConnectTimer	back to summary
public boolean shouldResetConnectTimer() Record Component getter of shouldResetConnectTimer.

shouldRetry	back to summary
public boolean shouldRetry() Record Component getter of shouldRetry.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

Returns a string representation of the record. In accordance with the general contract of Object#toString(), the toString method returns a string that "textually represents" this record. The result should be a concise but informative representation that is easy for a person to read.

In addition to this general contract, record classes must further participate in the invariant that any two records which are equal must produce equal strings. This invariant is necessarily relaxed in the rare case where corresponding equal component values might fail to produce equal strings for themselves.

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

private final Record MultiExchange.RetryContext

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail