Modifier and Type	Class and Description
pack-priv class	PlainHttpConnection.ConnectEvent
pack-priv class	PlainHttpConnection.ConnectTimerEvent

Modifier and Type	Field and Description
protected final SocketChannel	chan
private volatile boolean	closed
private volatile boolean	connected
private volatile PlainHttpConnection.ConnectTimerEvent	connectTimerEvent
private final AtomicReference<Throwable>	errorRef
private final ReentrantLock	stateLock
private final SocketTube	tube
private final HttpConnection.PlainHttpPublisher	writePublisher

Access	Constructor and Description
pack-priv	PlainHttpConnection(Origin originServer, InetSocketAddress addr, HttpClientImpl client, String label)

Method Summary

Modifier and Type	Method and Description
pack-priv ConnectionPool.CacheKey	cacheKey() Implements abstract jdk.internal.net.http.HttpConnection.cacheKey.
pack-priv SocketChannel	channel() Implements abstract jdk.internal.net.http.HttpConnection.channel.
public void	close() Implements abstract jdk.internal.net.http.HttpConnection.close. Implements java.io.Closeable.close. Closes this connection.
pack-priv void	close(Throwable cause) Implements abstract jdk.internal.net.http.HttpConnection.close. Closes this connection due to the given cause.
public CompletableFuture<Void>	connectAsync(Exchange<?> exchange) Implements abstract jdk.internal.net.http.HttpConnection.connectAsync. Initiates the connect phase.
pack-priv boolean	connected() Implements abstract jdk.internal.net.http.HttpConnection.connected. Tells whether, or not, this connection is connected to its destination.
pack-priv boolean	connectionOpened()
public CompletableFuture<Void>	finishConnect() Implements abstract jdk.internal.net.http.HttpConnection.finishConnect. Finishes the connection phase.
pack-priv final FlowTube	getConnectionFlow() Implements abstract jdk.internal.net.http.HttpConnection.getConnectionFlow. Returns the underlying connection flow, if applicable.
pack-priv Throwable	getError(Throwable cause)
pack-priv boolean	isProxied() Implements abstract jdk.internal.net.http.HttpConnection.isProxied. Tells whether, or not, this connection is proxied.
pack-priv boolean	isSecure() Implements abstract jdk.internal.net.http.HttpConnection.isSecure. Tells whether, or not, this connection is secure ( over SSL )
private PlainHttpConnection.ConnectTimerEvent	newConnectTimer(Exchange<?> exchange, CompletableFuture<?> cf) Returns a ConnectTimerEvent iff there is a connect timeout duration, otherwise null.
pack-priv InetSocketAddress	proxy() Implements abstract jdk.internal.net.http.HttpConnection.proxy. Returns the address of the proxy used by this connection.
pack-priv HttpConnection.HttpPublisher	publisher() Implements abstract jdk.internal.net.http.HttpConnection.publisher. Returns the HTTP publisher associated with this connection.
public String	toString() Overrides jdk.internal.net.http.HttpConnection.toString. Returns a string representation of the object.

Inherited from jdk.internal.net.http.HttpConnection:: address addTrailingOperation checkOpen client closeOrReturnToCache contextRestricted dbgString getConnection getOriginServer getSNIServerNames headerFilter isFlowFinished isOpen isTunnel label newConnectionId

Field Detail

chan	back to summary
protected final SocketChannel chan

closed	back to summary
private volatile boolean closed

connected	back to summary
private volatile boolean connected

connectTimerEvent	back to summary
private volatile PlainHttpConnection.ConnectTimerEvent connectTimerEvent

errorRef	back to summary
private final AtomicReference<Throwable> errorRef

stateLock	back to summary
private final ReentrantLock stateLock

tube	back to summary
private final SocketTube tube

writePublisher	back to summary
private final HttpConnection.PlainHttpPublisher writePublisher

Constructor Detail

PlainHttpConnection	back to summary
pack-priv PlainHttpConnection(Origin originServer, InetSocketAddress addr, HttpClientImpl client, String label)

Method Detail

cacheKey	back to summary
pack-priv ConnectionPool.CacheKey cacheKey() Implements abstract jdk.internal.net.http.HttpConnection.cacheKey. Annotations @Override

cacheKey

back to summary

pack-priv ConnectionPool.CacheKey cacheKey()

Implements abstract jdk.internal.net.http.HttpConnection.cacheKey.

Annotations

@Override

channel	back to summary
pack-priv SocketChannel channel() Implements abstract jdk.internal.net.http.HttpConnection.channel. Annotations @Override

channel

back to summary

pack-priv SocketChannel channel()

Implements abstract jdk.internal.net.http.HttpConnection.channel.

Annotations

@Override

close	back to summary
public void close() Implements abstract jdk.internal.net.http.HttpConnection.close. Implements java.io.Closeable.close. Doc from jdk.internal.net.http.HttpConnection.close. Closes this connection. Annotations @Override

back to summary

public void close()

Implements abstract jdk.internal.net.http.HttpConnection.close.

Implements java.io.Closeable.close.

Doc from jdk.internal.net.http.HttpConnection.close.

Closes this connection.

Annotations

@Override

close	back to summary
pack-priv void close(Throwable cause) Implements abstract jdk.internal.net.http.HttpConnection.close. Doc from jdk.internal.net.http.HttpConnection.close. Closes this connection due to the given cause. Annotations @Override

back to summary

pack-priv void close(Throwable cause)

Implements abstract jdk.internal.net.http.HttpConnection.close.

Doc from jdk.internal.net.http.HttpConnection.close.

Closes this connection due to the given cause.

Annotations

@Override

connectAsync	back to summary
public CompletableFuture<Void> connectAsync(Exchange<?> exchange) Implements abstract jdk.internal.net.http.HttpConnection.connectAsync. Doc from jdk.internal.net.http.HttpConnection.connectAsync. Initiates the connect phase. Returns a CompletableFuture that completes when the underlying TCP connection has been established or an error occurs. Annotations @Override

connectAsync

back to summary

public CompletableFuture<Void> connectAsync(Exchange<?> exchange)

Implements abstract jdk.internal.net.http.HttpConnection.connectAsync.

Doc from jdk.internal.net.http.HttpConnection.connectAsync.

Initiates the connect phase. Returns a CompletableFuture that completes when the underlying TCP connection has been established or an error occurs.

Annotations

@Override

connected	back to summary
pack-priv boolean connected() Implements abstract jdk.internal.net.http.HttpConnection.connected. Doc from jdk.internal.net.http.HttpConnection.connected. Tells whether, or not, this connection is connected to its destination. Annotations @Override

connected

back to summary

pack-priv boolean connected()

Implements abstract jdk.internal.net.http.HttpConnection.connected.

Doc from jdk.internal.net.http.HttpConnection.connected.

Tells whether, or not, this connection is connected to its destination.

Annotations

@Override

connectionOpened	back to summary
pack-priv boolean connectionOpened()

finishConnect	back to summary
public CompletableFuture<Void> finishConnect() Implements abstract jdk.internal.net.http.HttpConnection.finishConnect. Doc from jdk.internal.net.http.HttpConnection.finishConnect. Finishes the connection phase. Returns a CompletableFuture that completes when any additional, type specific, setup has been done. Must be called after connectAsync. Annotations @Override

finishConnect

back to summary

public CompletableFuture<Void> finishConnect()

Implements abstract jdk.internal.net.http.HttpConnection.finishConnect.

Doc from jdk.internal.net.http.HttpConnection.finishConnect.

Finishes the connection phase. Returns a CompletableFuture that completes when any additional, type specific, setup has been done. Must be called after connectAsync.

Annotations

@Override

getConnectionFlow	back to summary
pack-priv final FlowTube getConnectionFlow() Implements abstract jdk.internal.net.http.HttpConnection.getConnectionFlow. Doc from jdk.internal.net.http.HttpConnection.getConnectionFlow. Returns the underlying connection flow, if applicable. Annotations @Override

getConnectionFlow

back to summary

pack-priv final FlowTube getConnectionFlow()

Implements abstract jdk.internal.net.http.HttpConnection.getConnectionFlow.

Doc from jdk.internal.net.http.HttpConnection.getConnectionFlow.

Returns the underlying connection flow, if applicable.

Annotations

@Override

getError	back to summary
pack-priv Throwable getError(Throwable cause)

isProxied	back to summary
pack-priv boolean isProxied() Implements abstract jdk.internal.net.http.HttpConnection.isProxied. Doc from jdk.internal.net.http.HttpConnection.isProxied. Tells whether, or not, this connection is proxied. Returns true for tunnel connections, or clear connection to any host through proxy. Annotations @Override

isProxied

back to summary

pack-priv boolean isProxied()

Implements abstract jdk.internal.net.http.HttpConnection.isProxied.

Doc from jdk.internal.net.http.HttpConnection.isProxied.

Tells whether, or not, this connection is proxied. Returns true for tunnel connections, or clear connection to any host through proxy.

Annotations

@Override

isSecure	back to summary
pack-priv boolean isSecure() Implements abstract jdk.internal.net.http.HttpConnection.isSecure. Doc from jdk.internal.net.http.HttpConnection.isSecure. Tells whether, or not, this connection is secure ( over SSL ) Annotations @Override

isSecure

back to summary

pack-priv boolean isSecure()

Implements abstract jdk.internal.net.http.HttpConnection.isSecure.

Doc from jdk.internal.net.http.HttpConnection.isSecure.

Tells whether, or not, this connection is secure ( over SSL )

Annotations

@Override

newConnectTimer	back to summary
private PlainHttpConnection.ConnectTimerEvent newConnectTimer(Exchange<?> exchange, CompletableFuture<?> cf) Returns a ConnectTimerEvent iff there is a connect timeout duration, otherwise null.

proxy back to summary

proxy	back to summary
pack-priv InetSocketAddress proxy() Implements abstract jdk.internal.net.http.HttpConnection.proxy. Doc from jdk.internal.net.http.HttpConnection.proxy. Returns the address of the proxy used by this connection. Returns the proxy address for tunnel connections, or clear connection to any host through proxy. Returns `null` otherwise. Annotations @Override

pack-priv InetSocketAddress proxy()

Implements abstract jdk.internal.net.http.HttpConnection.proxy.

Doc from jdk.internal.net.http.HttpConnection.proxy.

Returns the address of the proxy used by this connection. Returns the proxy address for tunnel connections, or clear connection to any host through proxy. Returns null otherwise.

Annotations

@Override

publisher	back to summary
pack-priv HttpConnection.HttpPublisher publisher() Implements abstract jdk.internal.net.http.HttpConnection.publisher. Doc from jdk.internal.net.http.HttpConnection.publisher. Returns the HTTP publisher associated with this connection. May be null if invoked before connecting. Annotations @Override

publisher

back to summary

pack-priv HttpConnection.HttpPublisher publisher()

Implements abstract jdk.internal.net.http.HttpConnection.publisher.

Doc from jdk.internal.net.http.HttpConnection.publisher.

Returns the HTTP publisher associated with this connection. May be null if invoked before connecting.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides jdk.internal.net.http.HttpConnection.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Annotations @Override

public String toString()

Overrides jdk.internal.net.http.HttpConnection.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv final Class PlainHttpConnection.ConnectEvent

Class Inheritance

extends AsyncEvent

java.lang.Object
jdk.internal.net.http.AsyncEvent
jdk.internal.net.http.PlainHttpConnection.ConnectEvent

Field Summary

Modifier and Type	Field and Description
private final CompletableFuture<Void>	cf
private final Exchange<?>	exchange

Inherited from jdk.internal.net.http.AsyncEvent:: flags REPEATING

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectEvent(CompletableFuture<Void> cf, Exchange<?> exchange)

Method Summary

Modifier and Type	Method and Description
public void	abort(IOException ioe) Implements abstract jdk.internal.net.http.AsyncEvent.abort. Called when an error occurs during registration, or when the selector has been shut down.
public SelectableChannel	channel() Implements abstract jdk.internal.net.http.AsyncEvent.channel. Returns the channel
public void	handle() Implements abstract jdk.internal.net.http.AsyncEvent.handle. Called when event occurs
public int	interestOps() Implements abstract jdk.internal.net.http.AsyncEvent.interestOps. Returns the selector interest op flags OR'd

Inherited from jdk.internal.net.http.AsyncEvent:: repeating

Field Detail

cf	back to summary
private final CompletableFuture<Void> cf

exchange	back to summary
private final Exchange<?> exchange

Constructor Detail

ConnectEvent	back to summary
pack-priv ConnectEvent(CompletableFuture<Void> cf, Exchange<?> exchange)

Method Detail

abort	back to summary
public void abort(IOException ioe) Implements abstract jdk.internal.net.http.AsyncEvent.abort. Doc from jdk.internal.net.http.AsyncEvent.abort. Called when an error occurs during registration, or when the selector has been shut down. Aborts all exchanges. Annotations @Override

abort

back to summary

public void abort(IOException ioe)

Implements abstract jdk.internal.net.http.AsyncEvent.abort.

Doc from jdk.internal.net.http.AsyncEvent.abort.

Called when an error occurs during registration, or when the selector has been shut down. Aborts all exchanges.

Annotations

@Override

channel	back to summary
public SelectableChannel channel() Implements abstract jdk.internal.net.http.AsyncEvent.channel. Doc from jdk.internal.net.http.AsyncEvent.channel. Returns the channel Annotations @Override

channel

back to summary

public SelectableChannel channel()

Implements abstract jdk.internal.net.http.AsyncEvent.channel.

Doc from jdk.internal.net.http.AsyncEvent.channel.

Returns the channel

Annotations

@Override

handle	back to summary
public void handle() Implements abstract jdk.internal.net.http.AsyncEvent.handle. Doc from jdk.internal.net.http.AsyncEvent.handle. Called when event occurs Annotations @Override

handle

back to summary

public void handle()

Implements abstract jdk.internal.net.http.AsyncEvent.handle.

Doc from jdk.internal.net.http.AsyncEvent.handle.

Called when event occurs

Annotations

@Override

interestOps	back to summary
public int interestOps() Implements abstract jdk.internal.net.http.AsyncEvent.interestOps. Doc from jdk.internal.net.http.AsyncEvent.interestOps. Returns the selector interest op flags OR'd Annotations @Override

interestOps

back to summary

public int interestOps()

Implements abstract jdk.internal.net.http.AsyncEvent.interestOps.

Doc from jdk.internal.net.http.AsyncEvent.interestOps.

Returns the selector interest op flags OR'd

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv final Class PlainHttpConnection.ConnectTimerEvent

Class Inheritance

extends TimeoutEvent

java.lang.Object
jdk.internal.net.http.TimeoutEvent
jdk.internal.net.http.PlainHttpConnection.ConnectTimerEvent

Field Summary

Modifier and Type	Field and Description
private final CompletableFuture<?>	cf
private final Exchange<?>	exchange

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectTimerEvent(Duration duration, Exchange<?> exchange, CompletableFuture<?> cf)

Method Summary

Modifier and Type	Method and Description
public void	handle() Implements abstract jdk.internal.net.http.TimeoutEvent.handle.
public String	toString() Overrides jdk.internal.net.http.TimeoutEvent.toString. Returns a string representation of the object.

Inherited from jdk.internal.net.http.TimeoutEvent:: compareTo deadline

Field Detail

cf	back to summary
private final CompletableFuture<?> cf

exchange	back to summary
private final Exchange<?> exchange

Constructor Detail

ConnectTimerEvent	back to summary
pack-priv ConnectTimerEvent(Duration duration, Exchange<?> exchange, CompletableFuture<?> cf)

Method Detail

handle	back to summary
public void handle() Implements abstract jdk.internal.net.http.TimeoutEvent.handle. Annotations @Override

handle

back to summary

public void handle()

Implements abstract jdk.internal.net.http.TimeoutEvent.handle.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides jdk.internal.net.http.TimeoutEvent.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Annotations @Override

public String toString()

Overrides jdk.internal.net.http.TimeoutEvent.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations

@Override

pack-priv Class PlainHttpConnection

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class PlainHttpConnection.ConnectEvent

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class PlainHttpConnection.ConnectTimerEvent

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail