OpenJDK 27 · jdk.internal.net.http.HttpClientImpl · APIdia, the JavaDoc alternative

Modifier and Type	Class and Description
private static class	HttpClientImpl.DefaultThreadFactory
pack-priv static class	HttpClientImpl.DelegatingExecutor A DelegatingExecutor is an executor that delegates tasks to a wrapped executor when it detects that the current thread is the SelectorManager thread.
pack-priv static class	HttpClientImpl.HttpClientTracker
private static class	HttpClientImpl.PendingRequest
private static class	HttpClientImpl.SelectorAttachment Tracks multiple user level registrations associated with one NIO registration (SelectionKey).
private static class	HttpClientImpl.SelectorManager
private static class	HttpClientImpl.SingleFacadeFactory This is a bit tricky: 1.
private static class	HttpClientImpl.SSLDirectBufferSupplier

Modifier and Type	Field and Description
private static final Executor	ASYNC_POOL
private final Authenticator	authenticator
private final Http2ClientImpl	client2
private final Http3ClientImpl	client3
pack-priv static final AtomicLong	CLIENT_IDS
private final AtomicLong	CONNECTION_IDS
private final ConnectionPool	connections
private final Duration	connectTimeout
private final CookieHandler	cookieHandler
private final String	dbgTag
pack-priv final Logger	debug
pack-priv static final boolean	DEBUGELAPSED
pack-priv final Logger	debugelapsed
pack-priv static final boolean	DEBUGTIMEOUT
pack-priv final Logger	debugtimeout
pack-priv static final int	DEFAULT_KEEP_ALIVE_TIMEOUT
private final HttpClientImpl.DelegatingExecutor	delegatingExecutor
private final WeakReference<HttpClientFacade>	facadeRef
private final FilterFactory	filters
private final HttpClient.Redirect	followRedirects
private final boolean	hasRequiredH2TLS
private final boolean	hasRequiredH3TLS
private final long	id
pack-priv static final long	IDLE_CONNECTION_TIMEOUT_H2
pack-priv static final long	IDLE_CONNECTION_TIMEOUT_H3
private final WeakReference<HttpClientImpl>	implRef
private final AtomicBoolean	isAlive
private final boolean	isDefaultExecutor
private final AtomicBoolean	isStarted
pack-priv static final long	KEEP_ALIVE_TIMEOUT
private final InetAddress	localAddr
private final ConcurrentSkipListSet<PlainHttpConnection>	openedConnections
private final AtomicLong	pendingHttp2StreamCount
private final AtomicLong	pendingHttp3StreamCount
private final AtomicLong	pendingHttpOperationsCount
private final AtomicLong	pendingHttpRequestCount
private final AtomicLong	pendingOperationCount
private final AtomicLong	pendingRequestId
private final Set<HttpClientImpl.PendingRequest>	pendingRequests
private final AtomicLong	pendingSubscribersCount
private final AtomicLong	pendingTCPConnectionCount
private final AtomicLong	pendingWebSocketCount
private final ProxySelector	proxySelector
private final AltServicesRegistry	registry
private final HttpClientImpl.SelectorManager	selmgr
private final Thread	selmgrThread
private volatile boolean	shutdownRequested
private final HttpClientImpl.SSLDirectBufferSupplier	sslBufferSupplier
private final SSLContext	sslContext
private final SSLParameters	sslParams
private final ConcurrentSkipListSet<HttpBodySubscriberWrapper<?>>	subscribers
private final TreeSet<TimeoutEvent>	timeouts A Set of, deadline first, ordered timeout events.
pack-priv static final Utils.UseVTForSelector	USE_VT_FOR_SELECTOR
private final ProxySelector	userProxySelector
private final HttpClient.Version	version

Access	Constructor and Description
private	HttpClientImpl(HttpClientBuilderImpl builder, HttpClientImpl.SingleFacadeFactory facadeFactory)

Method Summary

Modifier and Type	Method and Description
pack-priv static void	abortPendingRequests(HttpClientImpl client, Throwable reason)
private void	addFilter(Class<? extends HeaderFilter> f)
public Optional<Authenticator>	authenticator() Implements abstract java.net.http.HttpClient.authenticator. Returns an `Optional` containing the `Authenticator` set on this client.
public boolean	awaitTermination(Duration duration) Overrides java.net.http.HttpClient.awaitTermination. Blocks until all operations have completed execution after a shutdown request, or the `duration` elapses, or the current thread is interrupted, whichever happens first.
pack-priv void	cancelTimer(TimeoutEvent event)
pack-priv Http2ClientImpl	client2()
pack-priv Optional<Http3ClientImpl>	client3()
private void	closeConnection(HttpConnection conn)
private void	closeSubscribers()
private static void	closeSubscribers(HttpClientImpl client, Throwable t)
public void	connectionClosed(PlainHttpConnection plainHttpConnection)
public void	connectionOpened(PlainHttpConnection plainHttpConnection)
pack-priv ConnectionPool	connectionPool()
public Optional<Duration>	connectTimeout() Implements abstract java.net.http.HttpClient.connectTimeout. Returns an `Optional` containing the connect timeout duration for this client.
public Optional<CookieHandler>	cookieHandler() Implements abstract java.net.http.HttpClient.cookieHandler. Returns an `Optional` containing this client's `CookieHandler`.
pack-priv static HttpClientFacade	create(HttpClientBuilderImpl builder)
pack-priv String	dbgString()
private void	debugCompleted(String tag, long startNanos, HttpRequest req)
pack-priv final String	debugInterestOps(SelectableChannel channel)
pack-priv void	eventUpdated(AsyncEvent The modified event. event) Allows an AsyncEvent to modify its interestOps.
public final Optional<Executor>	executor() Implements abstract java.net.http.HttpClient.executor. Returns an `Optional` containing this client's `Executor`.
pack-priv final HttpClientFacade	facade()
pack-priv void	facadeCleanup()
pack-priv final List<HeaderFilter>	filterChain()
pack-priv boolean	finished()
public HttpClient.Redirect	followRedirects() Implements abstract java.net.http.HttpClient.followRedirects. Returns the follow redirects policy for this client.
public OperationTrackers.Tracker	getOperationsTracker() Implements jdk.internal.net.http.common.OperationTrackers.Trackable.getOperationsTracker.
pack-priv int	getReceiveBufferSize()
pack-priv int	getSendBufferSize()
pack-priv BufferSupplier	getSSLBufferSupplier()
private static long	getTimeoutProp(String prop, long def)
pack-priv final long	h3StreamReference()
pack-priv final long	h3StreamUnreference()
pack-priv boolean	hasRequiredHTTP2TLSVersion() Returns true if the SSL parameter protocols contains at least one TLS version that HTTP/2 requires.
pack-priv boolean	hasRequiredHTTP3TLSVersion() Returns true if the SSL parameter protocols contains at least one TLS version that HTTP/3 requires.
pack-priv Optional<Duration>	idleConnectionTimeout(HttpClient.Version version)
private void	initFilters()
private boolean	isReferenced()
pack-priv boolean	isSelectorClosed()
pack-priv boolean	isSelectorThread()
public boolean	isTerminated() Overrides java.net.http.HttpClient.isTerminated. Returns `true` if all operations have completed following a shutdown.
pack-priv InetAddress	localAddress()
public long	newConnectionId()
public WebSocket.Builder	newWebSocketBuilder() Overrides java.net.http.HttpClient.newWebSocketBuilder. Creates a new `WebSocket` builder (optional operation).
pack-priv void	onSubmitFailure(Runnable command, Throwable failure)
public Optional<ProxySelector>	proxy() Implements abstract java.net.http.HttpClient.proxy. Returns an `Optional` containing the `ProxySelector` supplied to this client.
pack-priv ProxySelector	proxySelector()
private long	purgeTimeoutsAndReturnNextDeadline() Purges ( handles ) timer events that have passed their deadline, and returns the amount of time, in milliseconds, until the next earliest event.
pack-priv final long	reference()
pack-priv final long	referenceCount()
pack-priv void	registerEvent(AsyncEvent exchange) Wait for activity on given exchange.
pack-priv static <T> CompletableFuture<T>	registerPending(HttpClientImpl.PendingRequest pending, CompletableFuture<T> res)
public boolean	Returns: true if the subscriber was added to the list. registerSubscriber(HttpBodySubscriberWrapper<?> the subscriber subscriber) Adds the given subscriber to the subscribers list, or call its onError method if the client is shutting down.
pack-priv void	registerTimer(TimeoutEvent event)
pack-priv AltServicesRegistry	registry()
pack-priv final long	requestReference()
pack-priv final long	requestUnreference()
pack-priv IOException	selectorClosedException()
public <T> HttpResponse<T>	send(HttpRequest req, HttpResponse.BodyHandler<T> responseHandler) Implements abstract java.net.http.HttpClient.send. Sends the given request using this client, blocking if necessary to get the response.
public <T> CompletableFuture<HttpResponse<T>>	sendAsync(HttpRequest userRequest, HttpResponse.BodyHandler<T> responseHandler) Implements abstract java.net.http.HttpClient.sendAsync. Sends the given request asynchronously using this client with the given response body handler.
public <T> CompletableFuture<HttpResponse<T>>	sendAsync(HttpRequest userRequest, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler) Implements abstract java.net.http.HttpClient.sendAsync. Sends the given request asynchronously using this client with the given response body handler and push promise handler.
private <T> CompletableFuture<HttpResponse<T>>	sendAsync(HttpRequest userRequest, HttpResponse.BodyHandler<T> responseHandler, HttpResponse.PushPromiseHandler<T> pushPromiseHandler, Executor exchangeExecutor)
public void	shutdown() Overrides java.net.http.HttpClient.shutdown. Initiates an orderly shutdown in which requests previously submitted with `send` or `sendAsync` are run to completion, but no new request will be accepted.
public void	shutdownNow() Overrides java.net.http.HttpClient.shutdownNow. This method attempts to initiate an immediate shutdown.
public SSLContext	sslContext() Implements abstract java.net.http.HttpClient.sslContext. Returns this client's `SSLContext`.
public SSLParameters	sslParameters() Implements abstract java.net.http.HttpClient.sslParameters. Returns a copy of this client's `SSLParameters`.
private void	start()
private void	stop()
pack-priv final long	streamReference()
pack-priv final long	streamUnreference()
pack-priv final HttpClientImpl.DelegatingExecutor	theExecutor()
pack-priv SSLContext	theSSLContext()
private Optional<Duration>	timeoutDuration(long seconds)
pack-priv List<TimeoutEvent>	timers()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private static <T> CompletableFuture<HttpResponse<T>>	Returns: a new `CompletableFuture` wrapping the `sendAsync()` execution failures with, as per specification, `IOException`, if necessary translateSendAsyncExecFailure(CompletableFuture<HttpResponse<T>> responseFuture) Returns a new `CompletableFuture` wrapping the `sendAsync()` execution failures with, as per specification, `IOException`, if necessary.
pack-priv final long	unreference()
public boolean	Returns: true if the subscriber was found and removed from the list. unregisterSubscriber(HttpBodySubscriberWrapper<?> the subscriber subscriber) Remove the given subscriber from the subscribers list.
private static boolean	useVtForSelector()
public HttpClient.Version	version() Implements abstract java.net.http.HttpClient.version. Returns the preferred HTTP protocol version for this client.
pack-priv final long	webSocketClose()
pack-priv final long	webSocketOpen()

Inherited from java.net.http.HttpClient:: close newBuilder newHttpClient

pack-priv final Class HttpClientImpl

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary