APIdia Launch Partner
Top Description Inners Fields Constructors Methods
jdk.internal.net.http

pack-priv final Class Http3ExchangeImpl<T>

extends Http3Stream<T>
Class Inheritance
Imports
java.io.EOFException, .IOException, java.lang.invoke.MethodHandles, .VarHandle, java.net.ProtocolException, java.net.http.HttpClient.Version, .HttpHeaders, .HttpRequest.BodyPublisher, .HttpResponse, .HttpResponse.BodyHandler, .HttpResponse.BodySubscriber, .HttpResponse.ResponseInfo, java.nio.ByteBuffer, java.nio.charset.StandardCharsets, java.util.ArrayList, .Collections, .List, .Map, .Optional, .Set, java.util.concurrent.CompletableFuture, .CompletionException, .ConcurrentHashMap, .ConcurrentLinkedQueue, .Executor, .Flow, .Flow.Subscription, java.util.concurrent.atomic.AtomicLong, .AtomicReference, java.util.concurrent.locks.ReentrantLock, java.util.function.BiPredicate, jdk.internal.net.http.PushGroup.Acceptor, jdk.internal.net.http.common.HttpBodySubscriberWrapper, .HttpHeadersBuilder, .Log, .Logger, .MinimalFuture, .SequentialScheduler, .SubscriptionBase, .Utils, .ValidatingHeadersConsumer, jdk.internal.net.http.http3.ConnectionSettings, .Http3Error, jdk.internal.net.http.http3.frames.DataFrame, .FramesDecoder, .HeadersFrame, .PushPromiseFrame, jdk.internal.net.http.qpack.Decoder, .DecodingCallback, .Encoder, .QPackException, jdk.internal.net.http.qpack.readers.HeaderFrameReader, jdk.internal.net.http.qpack.writers.HeaderFrameWriter, jdk.internal.net.http.quic.streams.QuicBidiStream, .QuicStreamReader, .QuicStreamWriter
This class represents an HTTP/3 Request/Response stream.

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
Http3ExchangeImpl.HeadersConsumer

pack-priv class
Http3ExchangeImpl.Http3StreamResponseSubscriber<U>

private class
Http3ExchangeImpl.PushHeadersConsumer

pack-priv static record
Http3ExchangeImpl.PushPromiseState

pack-priv class
Http3ExchangeImpl.RequestSubscriber

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
closed

private final Http3Connection
connection

private String
dbgTag

private final Logger
debug

Hides jdk.internal.net.http.ExchangeImpl.debug.

pack-priv volatile boolean
deRegistered

private static final VarHandle
DEREGISTERED

private final AtomicReference<Throwable>
errorRef

private final H3FrameOrderVerifier
frameOrderVerifier

private final FramesDecoder
framesDecoder

private final HeaderFrameReader
headerFrameReader

private final HeaderFrameWriter
headerFrameWriter

pack-priv volatile HttpResponse.BodySubscriber<T>
pendingResponseSubscriber

pack-priv final ConcurrentHashMap<PushPromiseFrame, Http3ExchangeImpl.PushPromiseState>
promiseMap

private final Decoder
qpackDecoder

private final Encoder
qpackEncoder

private final QuicStreamReader
reader

private final SequentialScheduler
readScheduler

private final HttpRequestImpl
request

private final CompletableFuture<Void>
requestBodyCF

pack-priv volatile long
requestContentLen

private final HttpHeaders
requestPseudoHeaders

private final HttpRequest.BodyPublisher
requestPublisher

pack-priv volatile boolean
requestSent

pack-priv volatile Http3ExchangeImpl<T>.RequestSubscriber
requestSubscriber

pack-priv volatile Response
response

private final List<CompletableFuture<Response>>
response_cfs

private final ReentrantLock
response_cfs_lock

pack-priv volatile CompletableFuture<T>
responseBodyCF

pack-priv volatile int
responseCode

private final HttpHeadersBuilder
responseHeadersBuilder

pack-priv volatile boolean
responseReceived

pack-priv volatile HttpResponse.BodySubscriber<T>
responseSubscriber

private final Http3ExchangeImpl<T>.HeadersConsumer
rspHeadersConsumer

private final AtomicLong
sentQuicBytes

private final ReentrantLock
stateLock

pack-priv volatile boolean
stopRequested

private final QuicBidiStream
stream

pack-priv final SubscriptionBase
userSubscription

private final QuicStreamWriter
writer

private final SequentialScheduler
writeScheduler

Inherited from jdk.internal.net.http.Http3Stream:
responseData

Constructor Summary

AccessConstructor and Description
pack-priv
Http3ExchangeImpl(final Http3Connection connection, final Exchange<T> exchange, final QuicBidiStream stream)

Method Summary

Modifier and TypeMethod and Description
pack-priv boolean
acceptPushPromise()

pack-priv PushGroup.Acceptor<T>

Returns:

an Acceptor to get the body handler for the push request, or null.
acceptPushPromise(long
the pushId
pushId, HttpRequestImpl
the promised push request
pushRequest)

This method is called by the Http3PushManager in order to invoke the Acceptor that will accept the push promise.

pack-priv void
cancel()

Implements abstract jdk.internal.net.http.ExchangeImpl.cancel.

Cancels a request.

pack-priv void
cancel(IOException cause)

Implements abstract jdk.internal.net.http.ExchangeImpl.cancel.

Cancels a request with a cause.

private void
cancel(Flow.Subscription subscription)

pack-priv void
cancelImpl(Throwable e, Http3Error error)

Implements abstract jdk.internal.net.http.Http3Stream.cancelImpl.

Cancel the stream exchange on error

private void
cancelPushPromise(Http3ExchangeImpl.PushPromiseState state, IOException cause)

pack-priv void
close()

pack-priv void
closeAsUnprocessed()

An unprocessed exchange is one that hasn't been processed by a peer.

pack-priv void
completed()

Implements abstract jdk.internal.net.http.ExchangeImpl.completed.

Called when the exchange is completed, so that cleanup actions may be performed - such as deregistering callbacks.

pack-priv void
completeResponse(Response resp)

Implements abstract jdk.internal.net.http.Http3Stream.completeResponse.

Completes the first uncompleted CF on list, and removes it.

pack-priv void
completeResponseExceptionally(Throwable t)

Same as completeResponse(Response) above but for errors

private static long
computeHeaderSize(final HttpHeaders... headers)

pack-priv HttpQuicConnection
connection()

Implements abstract jdk.internal.net.http.ExchangeImpl.connection.

Returns the HttpConnection instance to which this exchange is assigned.

pack-priv void
connectionError(Throwable throwable, long errorCode, String errMsg)

Implements abstract jdk.internal.net.http.Http3Stream.connectionError.

Notify of a connection error.

pack-priv Http3ExchangeImpl<T>.Http3StreamResponseSubscriber<T>
createResponseSubscriber(HttpResponse.BodyHandler<T> handler, HttpResponse.ResponseInfo response)

Overrides jdk.internal.net.http.ExchangeImpl.createResponseSubscriber.

Creates and wraps an HttpResponse.BodySubscriber from a HttpResponse.BodyHandler for the given ResponseInfo.

pack-priv String
dbgTag()

pack-priv boolean
deRegister()

pack-priv void
expectContinueFailed(int rcode)

Overrides jdk.internal.net.http.ExchangeImpl.expectContinueFailed.

private HttpHeaders
filterHeaders(HttpHeaders headers)

pack-priv Throwable
getCancelCause()

Implements abstract jdk.internal.net.http.ExchangeImpl.getCancelCause.

Returns the cause for which this exchange was canceled, if available.

pack-priv CompletableFuture<Response>
getResponseAsync(Executor executor)

Implements abstract jdk.internal.net.http.ExchangeImpl.getResponseAsync.

Gets the response headers.

protected void
handlePromise(Http3ExchangeImpl<T>.PushHeadersConsumer consumer)

protected void
handleResponse()

private static boolean
hasProxyAuthorization(HttpHeaders headers)

pack-priv Http3Connection
http3Connection()

pack-priv CompletableFuture<Void>
ignoreBody()

Implements abstract jdk.internal.net.http.ExchangeImpl.ignoreBody.

Ignore/consume the body.

private void
ignorePushPromiseData(PushPromiseFrame ppf, List<ByteBuffer> payload)

private boolean
ignorePushPromiseFrame(PushPromiseFrame ppf, List<ByteBuffer> payload)

pack-priv boolean
isCanceled()

Implements abstract jdk.internal.net.http.ExchangeImpl.isCanceled.

Returns true if this exchange was canceled.

private static boolean
needsFiltering(HttpHeaders headers, BiPredicate<String, String> filter)

pack-priv Response
newResponse(HttpHeaders responseHeaders, int responseCode)

Implements abstract jdk.internal.net.http.Http3Stream.newResponse.

Called to create a new Response object for the newly receive response headers and response status code.

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

Overrides jdk.internal.net.http.ExchangeImpl.nullBody.

pack-priv void
onHttp3PushStreamStarted(HttpRequestImpl
the pushRequest
pushRequest, Http3PushPromiseStream<T>
the pushStream
pushStream)

This method is called by the Http3PushPromiseStream when starting

pack-priv void
onPollException(QuicStreamReader reader, IOException io)

Implements abstract jdk.internal.net.http.Http3Stream.onPollException.

Called when an exception is thrown by reader::poll when called from processQuicData.

pack-priv void
onProtocolError(IOException cause)

Implements abstract jdk.internal.net.http.ExchangeImpl.onProtocolError.

Invoked whenever there is a (HTTP) protocol error when dealing with the response from the server.

pack-priv void
onPushRequestAccepted(long
the pushId
pushId, CompletableFuture<HttpResponse<T>>
the response completable future
responseCF)

This method is called by the Http3PushManager once the responseCF has been obtained from the acceptor.

pack-priv void
onReaderReset()

Implements abstract jdk.internal.net.http.Http3Stream.onReaderReset.

Called when processQuicData detects that the reader has been reset.

pack-priv void
onSubscriptionError(Throwable t)

private void
processQuicData()

pack-priv void
pushResponseData(ConcurrentLinkedQueue<List<ByteBuffer>> responseData)

Implements abstract jdk.internal.net.http.Http3Stream.pushResponseData.

Push response data to the response body subscriber if allowed by the subscription state.

pack-priv CompletableFuture<T>
readBodyAsync(HttpResponse.BodyHandler<T> handler, boolean returnConnectionToPool, Executor executor)

Implements abstract jdk.internal.net.http.ExchangeImpl.readBodyAsync.

pack-priv void
receiveHeaders(HeadersFrame headers, List<ByteBuffer> payload)

Implements abstract jdk.internal.net.http.Http3Stream.receiveHeaders.

Called when new payload data is received by processQuicData for a given header frame.

pack-priv void
receivePushPromiseFrame(PushPromiseFrame ppf, List<ByteBuffer> payload)

Implements abstract jdk.internal.net.http.Http3Stream.receivePushPromiseFrame.

Called when new payload data is received by processQuicData for a given push promise frame.

pack-priv CompletableFuture<T>
receiveResponseBody(HttpResponse.BodySubscriber<T> bodySubscriber, Executor executor)

pack-priv void
recordError(Throwable closeCause)

private void
registerResponseSubscriber(Http3ExchangeImpl<T>.Http3StreamResponseSubscriber<?> subscriber)

pack-priv void
released()

Implements abstract jdk.internal.net.http.ExchangeImpl.released.

Called when the exchange is released, so that cleanup actions may be performed - such as deregistering callbacks.

pack-priv void
requestSent()

private void
requestSent0()

pack-priv void
responseReceived()

private void
responseReceived0()

pack-priv CompletableFuture<ExchangeImpl<T>>
sendBodyAsync()

Implements abstract jdk.internal.net.http.ExchangeImpl.sendBodyAsync.

Sends a request body, after request headers have been sent.

pack-priv CompletableFuture<Void>
sendBodyImpl()

private Http3ExchangeImpl<T>
sendHeaders()

pack-priv CompletableFuture<ExchangeImpl<T>>
sendHeadersAsync()

Implements abstract jdk.internal.net.http.ExchangeImpl.sendHeadersAsync.

private void
sendQuicData()

public void
start()

pack-priv long
streamId()

Implements abstract jdk.internal.net.http.Http3Stream.streamId.

Returns the Quic stream id for this exchange (request/response or push response).

private void
unregisterResponseSubscriber(Http3ExchangeImpl<T>.Http3StreamResponseSubscriber<?> subscriber)

Inherited from jdk.internal.net.http.Http3Stream:
checkInterimResponseCountExceededconnectionErrorhandleResponseprocessQuicDatareadingPausedreceivedQuicBytesswitchReadingPaused