Modifier and Type	Class and Description
pack-priv class	Exchange.ConnectionAborter

Field Summary

Modifier and Type	Field and Description
pack-priv volatile CompletableFuture<Void>	bodyIgnored
pack-priv final HttpClientImpl	client
pack-priv final Exchange<T>.ConnectionAborter	connectionAborter
pack-priv final String	dbgTag
pack-priv final Logger	debug
pack-priv volatile CompletableFuture<? extends ExchangeImpl<T>>	exchangeCF
pack-priv volatile ExchangeImpl<T>	exchImpl
private final AtomicReference<IOException>	failed
pack-priv static final int	MAX_NON_FINAL_RESPONSES
pack-priv final MultiExchange<T>	multi
pack-priv final AtomicInteger	nonFinalResponses
pack-priv final HttpClientImpl.DelegatingExecutor	parentExecutor
pack-priv final PushGroup<T>	pushGroup
pack-priv final HttpRequestImpl	request
pack-priv volatile boolean	streamLimitReached
private volatile boolean	unprocessedByPeer
pack-priv volatile boolean	upgraded
pack-priv volatile boolean	upgrading

Constructor Summary

Access	Constructor and Description
pack-priv	Exchange(HttpRequestImpl request, MultiExchange<T> multi)

Method Summary

Modifier and Type	Method and Description
public void	cancel()
public void	cancel(IOException cause)
private void	checkCancelled()
pack-priv <U> CompletableFuture<U>	checkCancelled(CompletableFuture<U> cf, HttpConnection connection)
private CompletableFuture<Response>	checkFor407(ExchangeImpl<T> ex, Throwable t, Function<ExchangeImpl<T>, CompletableFuture<Response>> andThen)
private CompletableFuture<Response>	checkForUpgradeAsync(Response resp, ExchangeImpl<T> ex)
pack-priv HttpClientImpl	client()
pack-priv String	dbgString()
private CompletableFuture<? extends ExchangeImpl<T>>	establishExchange(HttpConnection connection)
pack-priv HttpClientImpl.DelegatingExecutor	executor()
private CompletableFuture<Response>	expectContinue(ExchangeImpl<T> ex)
pack-priv synchronized IOException	failed(IOException io)
pack-priv synchronized IOException	getCancelCause()
pack-priv PushGroup<T>	getPushGroup()
pack-priv String	h2cSettingsStrings()
public void	h2Upgrade()
public boolean	hasReachedStreamLimit()
private CompletableFuture<Response>	Returns: A `CompletableFuture` with the final response from the server ignore1xxResponse(final Response The response rsp) Checks whether the passed Response has a status code between 102 and 199 (both inclusive).
public CompletableFuture<Void>	ignoreBody() Called after a redirect or similar kind of retry where a body might be sent but we don't want it.
pack-priv HttpResponse.BodySubscriber<T>	ignoreBody(HttpResponse.ResponseInfo hdrs)
pack-priv final boolean	isUnprocessedByPeer()
pack-priv final void	markUnprocessedByPeer()
pack-priv void	nullBody(HttpResponse<T> resp, Throwable t)
pack-priv boolean	pushEnabled()
public CompletableFuture<T>	readBodyAsync(HttpResponse.BodyHandler<T> handler)
public void	released() Called when a new exchange is created to replace this exchange.
public Optional<Duration>	remainingConnectTimeout()
public HttpRequestImpl	request()
public CompletableFuture<Response>	responseAsync()
pack-priv CompletableFuture<Response>	responseAsyncImpl(HttpConnection connection)
private CompletableFuture<Response>	sendRequestBody(ExchangeImpl<T> ex)
private CompletableFuture<Response>	startSendingBody(HttpClientImpl.DelegatingExecutor executor)
pack-priv void	streamLimitReached(boolean streamLimitReached)
pack-priv HttpClient.Version	version()
private CompletableFuture<Response>	wrapForLog(CompletableFuture<Response> cf)
private CompletableFuture<Response>	wrapForUpgrade(CompletableFuture<Response> cf)

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

Field Detail

bodyIgnored	back to summary
pack-priv volatile CompletableFuture<Void> bodyIgnored

client	back to summary
pack-priv final HttpClientImpl client

connectionAborter	back to summary
pack-priv final Exchange<T>.ConnectionAborter connectionAborter

dbgTag	back to summary
pack-priv final String dbgTag

debug	back to summary
pack-priv final Logger debug

exchangeCF	back to summary
pack-priv volatile CompletableFuture<? extends ExchangeImpl<T>> exchangeCF

exchImpl	back to summary
pack-priv volatile ExchangeImpl<T> exchImpl

failed	back to summary
private final AtomicReference<IOException> failed

MAX_NON_FINAL_RESPONSES	back to summary
pack-priv static final int MAX_NON_FINAL_RESPONSES

multi	back to summary
pack-priv final MultiExchange<T> multi

nonFinalResponses	back to summary
pack-priv final AtomicInteger nonFinalResponses

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

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

request	back to summary
pack-priv final HttpRequestImpl request

streamLimitReached	back to summary
pack-priv volatile boolean streamLimitReached

unprocessedByPeer	back to summary
private volatile boolean unprocessedByPeer

upgraded	back to summary
pack-priv volatile boolean upgraded

upgrading	back to summary
pack-priv volatile boolean upgrading

Constructor Detail

Exchange	back to summary
pack-priv Exchange(HttpRequestImpl request, MultiExchange<T> multi)

Method Detail

cancel	back to summary
public void cancel()

cancel	back to summary
public void cancel(IOException cause)

checkCancelled	back to summary
private void checkCancelled()

checkCancelled	back to summary
pack-priv <U> CompletableFuture<U> checkCancelled(CompletableFuture<U> cf, HttpConnection connection)

checkFor407	back to summary
private CompletableFuture<Response> checkFor407(ExchangeImpl<T> ex, Throwable t, Function<ExchangeImpl<T>, CompletableFuture<Response>> andThen)

checkForUpgradeAsync	back to summary
private CompletableFuture<Response> checkForUpgradeAsync(Response resp, ExchangeImpl<T> ex)

client	back to summary
pack-priv HttpClientImpl client()

dbgString	back to summary
pack-priv String dbgString()

establishExchange	back to summary
private CompletableFuture<? extends ExchangeImpl<T>> establishExchange(HttpConnection connection)

executor	back to summary
pack-priv HttpClientImpl.DelegatingExecutor executor()

expectContinue	back to summary
private CompletableFuture<Response> expectContinue(ExchangeImpl<T> ex)

failed	back to summary
pack-priv synchronized IOException failed(IOException io)

getCancelCause	back to summary
pack-priv synchronized IOException getCancelCause()

getPushGroup	back to summary
pack-priv PushGroup<T> getPushGroup()

h2cSettingsStrings	back to summary
pack-priv String h2cSettingsStrings()

h2Upgrade	back to summary
public void h2Upgrade()

hasReachedStreamLimit	back to summary
public boolean hasReachedStreamLimit()

ignore1xxResponse back to summary

ignore1xxResponse	back to summary
private CompletableFuture<Response> ignore1xxResponse(final Response rsp) Checks whether the passed Response has a status code between 102 and 199 (both inclusive). If so, then that `Response` is considered intermediate informational response and is ignored by the client. This method then creates a new `CompletableFuture` which completes when a subsequent response is sent by the server. Such newly constructed `CompletableFuture` will not complete till a "final" response (one which doesn't have a response code between 102 and 199 inclusive) is sent by the server. The returned `CompletableFuture` is thus capable of handling multiple subsequent intermediate informational responses from the server. If the passed Response doesn't have a status code between 102 and 199 (both inclusive) then this method immediately returns back a completed `CompletableFuture` with the passed `Response`. Parameters rsp:Response The response Returns:CompletableFuture<Response> A `CompletableFuture` with the final response from the server

private CompletableFuture<Response> ignore1xxResponse(final Response rsp)

Checks whether the passed Response has a status code between 102 and 199 (both inclusive). If so, then that Response is considered intermediate informational response and is ignored by the client. This method then creates a new CompletableFuture which completes when a subsequent response is sent by the server. Such newly constructed CompletableFuture will not complete till a "final" response (one which doesn't have a response code between 102 and 199 inclusive) is sent by the server. The returned CompletableFuture is thus capable of handling multiple subsequent intermediate informational responses from the server.

If the passed Response doesn't have a status code between 102 and 199 (both inclusive) then this method immediately returns back a completed CompletableFuture with the passed Response.

Parameters

rsp:Response: The response

Returns:CompletableFuture<Response>

A CompletableFuture with the final response from the server

ignoreBody	back to summary
public CompletableFuture<Void> ignoreBody() Called after a redirect or similar kind of retry where a body might be sent but we don't want it. Should send a RESET in h2. For http/1.1 we can consume small quantity of data, or close the connection in other cases.

ignoreBody	back to summary
pack-priv HttpResponse.BodySubscriber<T> ignoreBody(HttpResponse.ResponseInfo hdrs)

isUnprocessedByPeer	back to summary
pack-priv final boolean isUnprocessedByPeer()

markUnprocessedByPeer	back to summary
pack-priv final void markUnprocessedByPeer()

nullBody	back to summary
pack-priv void nullBody(HttpResponse<T> resp, Throwable t)

pushEnabled	back to summary
pack-priv boolean pushEnabled()

readBodyAsync	back to summary
public CompletableFuture<T> readBodyAsync(HttpResponse.BodyHandler<T> handler)

released	back to summary
public void released() Called when a new exchange is created to replace this exchange. At this point it is guaranteed that readBody/readBodyAsync will not be called.

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

request	back to summary
public HttpRequestImpl request()

responseAsync	back to summary
public CompletableFuture<Response> responseAsync()

responseAsyncImpl	back to summary
pack-priv CompletableFuture<Response> responseAsyncImpl(HttpConnection connection)

sendRequestBody	back to summary
private CompletableFuture<Response> sendRequestBody(ExchangeImpl<T> ex)

startSendingBody	back to summary
private CompletableFuture<Response> startSendingBody(HttpClientImpl.DelegatingExecutor executor)

streamLimitReached	back to summary
pack-priv void streamLimitReached(boolean streamLimitReached)

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

wrapForLog	back to summary
private CompletableFuture<Response> wrapForLog(CompletableFuture<Response> cf)

wrapForUpgrade	back to summary
private CompletableFuture<Response> wrapForUpgrade(CompletableFuture<Response> cf)

jdk.internal.net.http back to summary

pack-priv final Class Exchange.ConnectionAborter

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.Exchange.ConnectionAborter

Field Summary

Modifier and Type	Field and Description
private volatile Throwable	cause
private volatile boolean	closeRequested
private volatile HttpConnection	connection
private volatile HttpQuicConnection	quicConnection

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectionAborter()

Method Summary

Modifier and Type	Method and Description
pack-priv void	clear(HttpConnection connection)
pack-priv void	closeConnection(Throwable error)
private void	closeConnection(HttpConnection connection, Throwable cause)
pack-priv void	connection(HttpConnection connection)
pack-priv HttpConnection	disable()

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

Field Detail

cause	back to summary
private volatile Throwable cause

closeRequested	back to summary
private volatile boolean closeRequested

connection	back to summary
private volatile HttpConnection connection

quicConnection	back to summary
private volatile HttpQuicConnection quicConnection

Constructor Detail

ConnectionAborter	back to summary
pack-priv ConnectionAborter()

Method Detail

clear	back to summary
pack-priv void clear(HttpConnection connection)

closeConnection	back to summary
pack-priv void closeConnection(Throwable error)

closeConnection	back to summary
private void closeConnection(HttpConnection connection, Throwable cause)

connection	back to summary
pack-priv void connection(HttpConnection connection)

disable	back to summary
pack-priv HttpConnection disable()

pack-priv final Class Exchange<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class Exchange.ConnectionAborter

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail