Modifier and Type	Class and Description
pack-priv static class	SSLTube.DelegateWrapper
pack-priv class	SSLTube.SSLSubscriberWrapper
pack-priv class	SSLTube.SSLSubscriptionWrapper
pack-priv class	SSLTube.SSLTubeFlowDelegate

Modifier and Type	Field and Description
pack-priv final Logger	debug
private final SSLEngine	engine
private volatile boolean	finished
private final SSLTube.SSLSubscriberWrapper	readSubscriber
private volatile Flow.Subscription	readSubscription
private final SSLFlowDelegate	sslDelegate
private final FlowTube	tube
private final Demand	writeDemand Outstanding write demand from the SSL Flow Delegate.
private final SSLTube.SSLSubscriptionWrapper	writeSubscription

Access	Constructor and Description
public	SSLTube(SSLEngine engine, Executor executor, FlowTube tube)
public	SSLTube(SSLEngine engine, Executor executor, Consumer<ByteBuffer> recycler, FlowTube tube)

Method Summary

Modifier and Type	Method and Description
pack-priv Throwable	Returns: t or an SSLHandshakeException wrapping t, or null. checkForHandshake(Throwable an exception from upstream, or null. t) If the stream is completed before the handshake is finished, we want to forward an SSLHandshakeException downstream.
public void	connectFlows(FlowTube.TubePublisher A new publisher for writing to the bidirectional flow. writePub, FlowTube.TubeSubscriber A new subscriber for reading from the bidirectional flow. readSub) Overrides default jdk.internal.net.http.common.FlowTube.connectFlows. Connects the bidirectional flows to a write `Publisher` and a read `Subscriber`.
pack-priv final String	dbgString()
public CompletableFuture<String>	getALPN()
private String	handshakeFailed()
private boolean	handshaking()
public boolean	Returns: true when one of this FlowTube Subscriber's OnError or onComplete methods have been invoked isFinished() Implements jdk.internal.net.http.common.FlowTube.isFinished. Tells whether, or not, this FlowTube has finished receiving data.
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable the exception throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onNext(List<ByteBuffer> the item item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription a new subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.
public void	subscribe(Flow.Subscriber<? super List<ByteBuffer>> the subscriber s) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

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

Field Detail

debug	back to summary
pack-priv final Logger debug

engine	back to summary
private final SSLEngine engine

finished	back to summary
private volatile boolean finished

readSubscriber	back to summary
private final SSLTube.SSLSubscriberWrapper readSubscriber

readSubscription	back to summary
private volatile Flow.Subscription readSubscription

sslDelegate	back to summary
private final SSLFlowDelegate sslDelegate

tube	back to summary
private final FlowTube tube

writeDemand	back to summary
private final Demand writeDemand Outstanding write demand from the SSL Flow Delegate.

writeSubscription	back to summary
private final SSLTube.SSLSubscriptionWrapper writeSubscription

SSLTube	back to summary
public SSLTube(SSLEngine engine, Executor executor, FlowTube tube)

SSLTube	back to summary
public SSLTube(SSLEngine engine, Executor executor, Consumer<ByteBuffer> recycler, FlowTube tube)

Method Detail

checkForHandshake	back to summary
pack-priv Throwable checkForHandshake(Throwable t) If the stream is completed before the handshake is finished, we want to forward an SSLHandshakeException downstream. If t is not null an exception will always be returned. If t is null an exception will be returned if the engine is handshaking. Parameters t:Throwable an exception from upstream, or null. Returns:Throwable t or an SSLHandshakeException wrapping t, or null.

checkForHandshake

back to summary

pack-priv Throwable checkForHandshake(Throwable t)

If the stream is completed before the handshake is finished, we want to forward an SSLHandshakeException downstream. If t is not null an exception will always be returned. If t is null an exception will be returned if the engine is handshaking.

Parameters

t:Throwable: an exception from upstream, or null.

Returns:Throwable

t or an SSLHandshakeException wrapping t, or null.

connectFlows back to summary

connectFlows	back to summary
public void connectFlows(FlowTube.TubePublisher writePub, FlowTube.TubeSubscriber readSub) Overrides default jdk.internal.net.http.common.FlowTube.connectFlows. Doc from jdk.internal.net.http.common.FlowTube.connectFlows. Connects the bidirectional flows to a write `Publisher` and a read `Subscriber`. This method can be called sequentially several times to switch existing publishers and subscribers to a new pair of write subscriber and read publisher. Parameters writePub:FlowTube.TubePublisher A new publisher for writing to the bidirectional flow. readSub:FlowTube.TubeSubscriber A new subscriber for reading from the bidirectional flow. Annotations @Override

public void connectFlows(FlowTube.TubePublisher writePub, FlowTube.TubeSubscriber readSub)

Overrides default jdk.internal.net.http.common.FlowTube.connectFlows.

Doc from jdk.internal.net.http.common.FlowTube.connectFlows.

Connects the bidirectional flows to a write Publisher and a read Subscriber. This method can be called sequentially several times to switch existing publishers and subscribers to a new pair of write subscriber and read publisher.

Parameters

writePub:FlowTube.TubePublisher: A new publisher for writing to the bidirectional flow.
readSub:FlowTube.TubeSubscriber: A new subscriber for reading from the bidirectional flow.

Annotations

@Override

dbgString	back to summary
pack-priv final String dbgString()

getALPN	back to summary
public CompletableFuture<String> getALPN()

handshakeFailed	back to summary
private String handshakeFailed()

handshaking	back to summary
private boolean handshaking()

isFinished	back to summary
public boolean isFinished() Implements jdk.internal.net.http.common.FlowTube.isFinished. Tells whether, or not, this FlowTube has finished receiving data. Returns:boolean true when one of this FlowTube Subscriber's OnError or onComplete methods have been invoked Annotations @Override

isFinished

back to summary

public boolean isFinished()

Implements jdk.internal.net.http.common.FlowTube.isFinished.

Tells whether, or not, this FlowTube has finished receiving data.

Returns:boolean

true when one of this FlowTube Subscriber's OnError or onComplete methods have been invoked

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Doc from java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined.

Annotations

@Override

onError	back to summary
public void onError(Throwable throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Doc from java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined. Parameters throwable:Throwable the exception Annotations @Override

onError

back to summary

public void onError(Throwable throwable)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined.

Parameters

throwable:Throwable: the exception

Annotations

@Override

onNext	back to summary
public void onNext(List<ByteBuffer> item) Implements java.util.concurrent.Flow.Subscriber.onNext. Doc from java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled. Parameters item:List<ByteBuffer> the item Annotations @Override

onNext

back to summary

public void onNext(List<ByteBuffer> item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Parameters

item:List<ByteBuffer>: the item

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Doc from java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled. Typically, implementations of this method invoke `subscription.request` to enable receiving items. Parameters subscription:Flow.Subscription a new subscription Annotations @Override

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Parameters

subscription:Flow.Subscription: a new subscription

Annotations

@Override

subscribe back to summary

subscribe	back to summary
public void subscribe(Flow.Subscriber<? super List<ByteBuffer>> s) Implements java.util.concurrent.Flow.Publisher.subscribe. Doc from java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's `onError` method is invoked with an `IllegalStateException`. Otherwise, the Subscriber's `onSubscribe` method is invoked with a new `Subscription`. Subscribers may enable receiving items by invoking the `request` method of this Subscription, and may unsubscribe by invoking its `cancel` method. Parameters s:Flow.Subscriber<? super List<ByteBuffer>> the subscriber Annotations @Override

public void subscribe(Flow.Subscriber<? super List<ByteBuffer>> s)

Implements java.util.concurrent.Flow.Publisher.subscribe.

Doc from java.util.concurrent.Flow.Publisher.subscribe.

Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's onError method is invoked with an IllegalStateException. Otherwise, the Subscriber's onSubscribe method is invoked with a new Subscription. Subscribers may enable receiving items by invoking the request method of this Subscription, and may unsubscribe by invoking its cancel method.

Parameters

s:Flow.Subscriber<? super List<ByteBuffer>>: the subscriber

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.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. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.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.

Returns:String

a string representation of the object

Annotations

@Override

jdk.internal.net.http.common back to summary

pack-priv final Class SSLTube.DelegateWrapper

Class Inheritance

extends Object
implements TubeSubscriber

java.lang.Object
jdk.internal.net.http.common.SSLTube.DelegateWrapper

All Implemented Interfaces

jdk.internal.net.http.common.FlowTube.TubeSubscriber, java.util.concurrent.Flow.Subscriber

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	completed
private final Logger	debug
private final FlowTube.TubeSubscriber	delegate
pack-priv volatile Throwable	error
pack-priv volatile boolean	subscribedCalled
pack-priv volatile boolean	subscribedDone

Constructor Summary

Access	Constructor and Description
pack-priv	DelegateWrapper(Flow.Subscriber<? super List<ByteBuffer>> delegate, Logger debug)

Method Summary

Modifier and Type	Method and Description
public void	dropSubscription() Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription. Called when the flow is connected again, and the subscription is handed over to a new subscriber.
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable the exception t) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onNext(List<ByteBuffer> the item item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription a new subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.
private void	onSubscribe(Consumer<Flow.Subscription> method, Flow.Subscription subscription)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

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

Field Detail

completed	back to summary
pack-priv volatile boolean completed

debug	back to summary
private final Logger debug

delegate	back to summary
private final FlowTube.TubeSubscriber delegate

error	back to summary
pack-priv volatile Throwable error

subscribedCalled	back to summary
pack-priv volatile boolean subscribedCalled

subscribedDone	back to summary
pack-priv volatile boolean subscribedDone

Constructor Detail

DelegateWrapper	back to summary
pack-priv DelegateWrapper(Flow.Subscriber<? super List<ByteBuffer>> delegate, Logger debug)

Method Detail

dropSubscription back to summary

dropSubscription	back to summary
public void dropSubscription() Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription. Doc from jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription. Called when the flow is connected again, and the subscription is handed over to a new subscriber. Once `dropSubscription()` is called, the `TubeSubscriber` should stop calling any method on its subscription. Annotations @Override

public void dropSubscription()

Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Doc from jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Called when the flow is connected again, and the subscription is handed over to a new subscriber. Once dropSubscription() is called, the TubeSubscriber should stop calling any method on its subscription.

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Doc from java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Annotations

@Override

onError	back to summary
public void onError(Throwable t) Implements java.util.concurrent.Flow.Subscriber.onError. Doc from java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined. Parameters t:Throwable the exception Annotations @Override

onError

back to summary

public void onError(Throwable t)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Parameters

t:Throwable: the exception

Annotations

@Override

onNext	back to summary
public void onNext(List<ByteBuffer> item) Implements java.util.concurrent.Flow.Subscriber.onNext. Doc from java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled. Parameters item:List<ByteBuffer> the item Annotations @Override

onNext

back to summary

public void onNext(List<ByteBuffer> item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Parameters

item:List<ByteBuffer>: the item

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Doc from java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled. Typically, implementations of this method invoke `subscription.request` to enable receiving items. Parameters subscription:Flow.Subscription a new subscription Annotations @Override

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Parameters

subscription:Flow.Subscription: a new subscription

Annotations

@Override

onSubscribe	back to summary
private void onSubscribe(Consumer<Flow.Subscription> method, Flow.Subscription subscription)

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.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. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.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.

Returns:String

a string representation of the object

Annotations

@Override

jdk.internal.net.http.common back to summary

pack-priv final Class SSLTube.SSLSubscriberWrapper

Class Inheritance

extends Object
implements TubeSubscriber

java.lang.Object
jdk.internal.net.http.common.SSLTube.SSLSubscriberWrapper

All Implemented Interfaces

jdk.internal.net.http.common.FlowTube.TubeSubscriber, java.util.concurrent.Flow.Subscriber

Field Summary

Modifier and Type	Field and Description
private final AtomicReference<Throwable>	errorRef
private volatile boolean	onCompleteReceived
private AtomicReference<SSLTube.DelegateWrapper>	pendingDelegate
private volatile SSLTube.DelegateWrapper	subscribed

Constructor Summary

Access	Constructor and Description
pack-priv	SSLSubscriberWrapper()

Method Summary

Modifier and Type	Method and Description
private void	complete(SSLTube.DelegateWrapper subscriberImpl, Throwable t)
public void	dropSubscription() Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription. Called when the flow is connected again, and the subscription is handed over to a new subscriber.
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable the exception throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onErrorImpl(Throwable throwable)
private void	onNewSubscription(SSLTube.DelegateWrapper subscriberImpl, Flow.Subscription subscription)
public void	onNext(List<ByteBuffer> the item item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription a new subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.
private void	onSubscribeImpl(Flow.Subscription subscription)
pack-priv void	processPendingSubscriber()
pack-priv void	setDelegate(Flow.Subscriber<? super List<ByteBuffer>> delegate)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

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

Field Detail

errorRef	back to summary
private final AtomicReference<Throwable> errorRef

onCompleteReceived	back to summary
private volatile boolean onCompleteReceived

pendingDelegate	back to summary
private AtomicReference<SSLTube.DelegateWrapper> pendingDelegate

subscribed	back to summary
private volatile SSLTube.DelegateWrapper subscribed

Constructor Detail

SSLSubscriberWrapper	back to summary
pack-priv SSLSubscriberWrapper()

Method Detail

complete	back to summary
private void complete(SSLTube.DelegateWrapper subscriberImpl, Throwable t)

dropSubscription back to summary

public void dropSubscription()

Overrides default jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Doc from jdk.internal.net.http.common.FlowTube.TubeSubscriber.dropSubscription.

Annotations

@Override

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Annotations

@Override

onError

back to summary

public void onError(Throwable throwable)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Parameters

throwable:Throwable: the exception

Annotations

@Override

onErrorImpl	back to summary
public void onErrorImpl(Throwable throwable)

onNewSubscription	back to summary
private void onNewSubscription(SSLTube.DelegateWrapper subscriberImpl, Flow.Subscription subscription)

onNext

back to summary

public void onNext(List<ByteBuffer> item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Parameters

item:List<ByteBuffer>: the item

Annotations

@Override

onSubscribe back to summary

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Parameters

subscription:Flow.Subscription: a new subscription

Annotations

@Override

onSubscribeImpl	back to summary
private void onSubscribeImpl(Flow.Subscription subscription)

processPendingSubscriber	back to summary
pack-priv void processPendingSubscriber()

setDelegate	back to summary
pack-priv void setDelegate(Flow.Subscriber<? super List<ByteBuffer>> delegate)

toString back to summary

public String toString()

Overrides java.lang.Object.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.

Returns:String

a string representation of the object

Annotations

@Override

jdk.internal.net.http.common back to summary

pack-priv final Class SSLTube.SSLSubscriptionWrapper

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.common.SSLTube.SSLSubscriptionWrapper

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Field Summary

Modifier and Type	Field and Description
private volatile boolean	cancelled
pack-priv volatile Flow.Subscription	delegate

Constructor Summary

Access	Constructor and Description
pack-priv	SSLSubscriptionWrapper()

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 the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.
pack-priv void	setSubscription(Flow.Subscription sub)

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

Field Detail

cancelled	back to summary
private volatile boolean cancelled

delegate	back to summary
pack-priv volatile Flow.Subscription delegate

Constructor Detail

SSLSubscriptionWrapper	back to summary
pack-priv SSLSubscriptionWrapper()

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

Parameters

n:long: the increment of demand; a value of Long.MAX_VALUE may be considered as effectively unbounded

Annotations

@Override

setSubscription	back to summary
pack-priv void setSubscription(Flow.Subscription sub)

jdk.internal.net.http.common back to summary

pack-priv final Class SSLTube.SSLTubeFlowDelegate

Class Inheritance

extends SSLFlowDelegate

java.lang.Object
jdk.internal.net.http.common.SSLFlowDelegate
jdk.internal.net.http.common.SSLTube.SSLTubeFlowDelegate

Field Summary

Constructor Summary

Access	Constructor and Description
pack-priv	SSLTubeFlowDelegate(SSLEngine engine, Executor executor, Consumer<ByteBuffer> recycler, SSLTube.SSLSubscriberWrapper readSubscriber, FlowTube tube)

Method Summary

Modifier and Type	Method and Description
protected Throwable	checkForHandshake(Throwable t) Overrides jdk.internal.net.http.common.SSLFlowDelegate.checkForHandshake.
pack-priv void	connect(Flow.Subscriber<? super List<ByteBuffer>> The left hand side read sink (typically, the HttpConnection read subscriber). downReader, Flow.Subscriber<? super List<ByteBuffer>> The right hand side write sink (typically the SocketTube write subscriber). downWriter) Overrides jdk.internal.net.http.common.SSLFlowDelegate.connect. Connects the read sink (downReader) to the SSLFlowDelegate Reader, and the write sink (downWriter) to the SSLFlowDelegate Writer.
protected SubscriberWrapper.SchedulingAction	enterReadScheduling() Overrides jdk.internal.net.http.common.SSLFlowDelegate.enterReadScheduling.

Inherited from jdk.internal.net.http.common.SSLFlowDelegate:: alpn closeNotifyReceived dbgString doClosure getAppBuffer getNetBuffer monitor resetReaderDemand resumeReader trySetALPN upstreamReader upstreamWriter

Constructor Detail

SSLTubeFlowDelegate	back to summary
pack-priv SSLTubeFlowDelegate(SSLEngine engine, Executor executor, Consumer<ByteBuffer> recycler, SSLTube.SSLSubscriberWrapper readSubscriber, FlowTube tube)

Method Detail

checkForHandshake

back to summary

protected Throwable checkForHandshake(Throwable t)

Overrides jdk.internal.net.http.common.SSLFlowDelegate.checkForHandshake.

Annotations

@Override

connect

back to summary

pack-priv void connect(Flow.Subscriber<? super List<ByteBuffer>> downReader, Flow.Subscriber<? super List<ByteBuffer>> downWriter)

Overrides jdk.internal.net.http.common.SSLFlowDelegate.connect.

Doc from jdk.internal.net.http.common.SSLFlowDelegate.connect.

Connects the read sink (downReader) to the SSLFlowDelegate Reader, and the write sink (downWriter) to the SSLFlowDelegate Writer. Called from within the constructor. Overwritten by SSLTube.

Parameters

downReader:Flow.Subscriber<? super List<ByteBuffer>>: The left hand side read sink (typically, the HttpConnection read subscriber).
downWriter:Flow.Subscriber<? super List<ByteBuffer>>: The right hand side write sink (typically the SocketTube write subscriber).

enterReadScheduling	back to summary
protected SubscriberWrapper.SchedulingAction enterReadScheduling() Overrides jdk.internal.net.http.common.SSLFlowDelegate.enterReadScheduling.

public Class SSLTube

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class SSLTube.DelegateWrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class SSLTube.SSLSubscriberWrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class SSLTube.SSLSubscriptionWrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class SSLTube.SSLTubeFlowDelegate

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail