Modifier and Type	Class and Description
pack-priv static class	RawChannelTube.CleanupChecker
pack-priv class	RawChannelTube.ReadSubscriber
pack-priv class	RawChannelTube.WritePublisher
pack-priv class	RawChannelTube.WriteSubscription

Modifier and Type	Field and Description
private static final Cleaner	cleaner
pack-priv final AtomicBoolean	closed
pack-priv final HttpConnection	connection
pack-priv final String	dbgTag
pack-priv final Logger	debug
pack-priv final AtomicBoolean	inited
pack-priv final Supplier<ByteBuffer>	initial
pack-priv final AtomicBoolean	inputClosed
pack-priv final AtomicBoolean	outputClosed
pack-priv final RawChannelTube.ReadSubscriber	readSubscriber
pack-priv final FlowTube	tube
pack-priv final RawChannelTube.WritePublisher	writePublisher

Access	Constructor and Description
pack-priv	RawChannelTube(HttpConnection connection, Supplier<ByteBuffer> initial)

Modifier and Type	Method and Description
public void	close() Implements jdk.internal.net.http.websocket.RawChannel.close. Closes this channel.
private void	connectFlows()
private static List<ByteBuffer>	copy(ByteBuffer[] src, int offset, int len)
public ByteBuffer	Returns: the initial bytes initialByteBuffer() Implements jdk.internal.net.http.websocket.RawChannel.initialByteBuffer. Hands over the initial bytes.
public ByteBuffer	read() Implements jdk.internal.net.http.websocket.RawChannel.read.
public void	registerEvent(RawChannel.RawEvent event) Implements jdk.internal.net.http.websocket.RawChannel.registerEvent.
public void	shutdownInput() Implements jdk.internal.net.http.websocket.RawChannel.shutdownInput. Shutdown the connection for reading without closing the channel.
public void	shutdownOutput() Implements jdk.internal.net.http.websocket.RawChannel.shutdownOutput. Shutdown the connection for writing without closing the channel.
public long	write(ByteBuffer[] srcs, int offset, int length) Implements jdk.internal.net.http.websocket.RawChannel.write.

cleaner	back to summary
private static final Cleaner cleaner

closed	back to summary
pack-priv final AtomicBoolean closed

connection	back to summary
pack-priv final HttpConnection connection

dbgTag	back to summary
pack-priv final String dbgTag

debug	back to summary
pack-priv final Logger debug

inited	back to summary
pack-priv final AtomicBoolean inited

initial	back to summary
pack-priv final Supplier<ByteBuffer> initial

inputClosed	back to summary
pack-priv final AtomicBoolean inputClosed

outputClosed	back to summary
pack-priv final AtomicBoolean outputClosed

readSubscriber	back to summary
pack-priv final RawChannelTube.ReadSubscriber readSubscriber

tube	back to summary
pack-priv final FlowTube tube

writePublisher	back to summary
pack-priv final RawChannelTube.WritePublisher writePublisher

RawChannelTube	back to summary
pack-priv RawChannelTube(HttpConnection connection, Supplier<ByteBuffer> initial)

Method Detail

close	back to summary
public void close() Implements jdk.internal.net.http.websocket.RawChannel.close. Closes this channel. Annotations @Override Exceptions IOException: If an I/O error occurs

public void close()

Implements jdk.internal.net.http.websocket.RawChannel.close.

Closes this channel.

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs

connectFlows	back to summary
private void connectFlows()

copy	back to summary
private static List<ByteBuffer> copy(ByteBuffer[] src, int offset, int len)

initialByteBuffer back to summary

initialByteBuffer	back to summary
public ByteBuffer initialByteBuffer() throws IllegalStateException Implements jdk.internal.net.http.websocket.RawChannel.initialByteBuffer. Hands over the initial bytes. Once the bytes have been returned they are no longer available and the method will throw an `IllegalStateException` on each subsequent invocation. Returns:ByteBuffer the initial bytes Exceptions IllegalStateException: if the method has been already invoked

public ByteBuffer initialByteBuffer() throws IllegalStateException

Implements jdk.internal.net.http.websocket.RawChannel.initialByteBuffer.

Hands over the initial bytes. Once the bytes have been returned they are no longer available and the method will throw an IllegalStateException on each subsequent invocation.

Returns:ByteBuffer

the initial bytes

Exceptions

IllegalStateException:: if the method has been already invoked

read	back to summary
public ByteBuffer read() throws IOException Implements jdk.internal.net.http.websocket.RawChannel.read.

registerEvent	back to summary
public void registerEvent(RawChannel.RawEvent event) throws IOException Implements jdk.internal.net.http.websocket.RawChannel.registerEvent.

shutdownInput back to summary

shutdownInput	back to summary
public void shutdownInput() Implements jdk.internal.net.http.websocket.RawChannel.shutdownInput. Shutdown the connection for reading without closing the channel. Once shutdown for reading then further reads on the channel will return `null`, the end-of-stream indication. If the input side of the connection is already shutdown then invoking this method has no effect. Exceptions ClosedChannelException: If this channel is closed IOException: If some other I/O error occurs

public void shutdownInput()

Implements jdk.internal.net.http.websocket.RawChannel.shutdownInput.

Shutdown the connection for reading without closing the channel.

Once shutdown for reading then further reads on the channel will return null, the end-of-stream indication. If the input side of the connection is already shutdown then invoking this method has no effect.

Exceptions

ClosedChannelException:: If this channel is closed
IOException:: If some other I/O error occurs

shutdownOutput back to summary

shutdownOutput	back to summary
public void shutdownOutput() Implements jdk.internal.net.http.websocket.RawChannel.shutdownOutput. Shutdown the connection for writing without closing the channel. Once shutdown for writing then further attempts to write to the channel will throw `ClosedChannelException`. If the output side of the connection is already shutdown then invoking this method has no effect. Exceptions ClosedChannelException: If this channel is closed IOException: If some other I/O error occurs

public void shutdownOutput()

Implements jdk.internal.net.http.websocket.RawChannel.shutdownOutput.

Shutdown the connection for writing without closing the channel.

Once shutdown for writing then further attempts to write to the channel will throw ClosedChannelException. If the output side of the connection is already shutdown then invoking this method has no effect.

Exceptions

ClosedChannelException:: If this channel is closed
IOException:: If some other I/O error occurs

write	back to summary
public long write(ByteBuffer[] srcs, int offset, int length) throws IOException Implements jdk.internal.net.http.websocket.RawChannel.write.

jdk.internal.net.http back to summary

pack-priv final Class RawChannelTube.CleanupChecker

Class Inheritance

extends Object
implements Runnable

java.lang.Object
jdk.internal.net.http.RawChannelTube.CleanupChecker

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicBoolean	closed
pack-priv final System.Logger	debug

Constructor Summary

Access	Constructor and Description
pack-priv	CleanupChecker(AtomicBoolean closed, System.Logger debug)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

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

Field Detail

closed	back to summary
pack-priv final AtomicBoolean closed

debug	back to summary
pack-priv final System.Logger debug

Constructor Detail

CleanupChecker	back to summary
pack-priv CleanupChecker(AtomicBoolean closed, System.Logger debug)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv Class RawChannelTube.ReadSubscriber

Class Inheritance

extends Object
implements TubeSubscriber

java.lang.Object
jdk.internal.net.http.RawChannelTube.ReadSubscriber

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 final ConcurrentLinkedQueue<ByteBuffer>	buffers
pack-priv volatile boolean	completed
pack-priv final AtomicReference<Throwable>	errorRef
pack-priv final ConcurrentLinkedQueue<RawChannel.RawEvent>	events
pack-priv long	initialRequest
pack-priv volatile Flow.Subscription	readSubscription

Constructor Summary

Access	Constructor and Description
pack-priv	ReadSubscriber()

Method Summary

Modifier and Type	Method and Description
pack-priv void	checkEvents()
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 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> item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.

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

Field Detail

buffers	back to summary
pack-priv final ConcurrentLinkedQueue<ByteBuffer> buffers

completed	back to summary
pack-priv volatile boolean completed

errorRef	back to summary
pack-priv final AtomicReference<Throwable> errorRef

events	back to summary
pack-priv final ConcurrentLinkedQueue<RawChannel.RawEvent> events

initialRequest	back to summary
pack-priv long initialRequest

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

Constructor Detail

ReadSubscriber	back to summary
pack-priv ReadSubscriber()

Method Detail

checkEvents	back to summary
pack-priv void checkEvents()

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

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

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

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv Class RawChannelTube.WritePublisher

Class Inheritance

extends Object
implements TubePublisher

java.lang.Object
jdk.internal.net.http.RawChannelTube.WritePublisher

All Implemented Interfaces

jdk.internal.net.http.common.FlowTube.TubePublisher, java.util.concurrent.Flow.Publisher

Field Summary

Modifier and Type	Field and Description
pack-priv final ConcurrentLinkedQueue<RawChannel.RawEvent>	events
pack-priv volatile RawChannelTube.WriteSubscription	writeSubscription

Constructor Summary

Access	Constructor and Description
pack-priv	WritePublisher()

Method Summary

Modifier and Type	Method and Description
public void	subscribe(Flow.Subscriber<? super List<ByteBuffer>> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.

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

Field Detail

events	back to summary
pack-priv final ConcurrentLinkedQueue<RawChannel.RawEvent> events

writeSubscription	back to summary
pack-priv volatile RawChannelTube.WriteSubscription writeSubscription

Constructor Detail

WritePublisher	back to summary
pack-priv WritePublisher()

Method Detail

subscribe back to summary

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

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.

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv Class RawChannelTube.WriteSubscription

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.RawChannelTube.WriteSubscription

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	cancelled
pack-priv final Demand	demand
pack-priv final Flow.Subscriber<? super List<ByteBuffer>>	subscriber

Constructor Summary

Access	Constructor and Description
pack-priv	WriteSubscription(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

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 n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.

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

Field Detail

cancelled	back to summary
pack-priv volatile boolean cancelled

demand	back to summary
pack-priv final Demand demand

subscriber	back to summary
pack-priv final Flow.Subscriber<? super List<ByteBuffer>> subscriber

Constructor Detail

WriteSubscription	back to summary
pack-priv WriteSubscription(Flow.Subscriber<? super List<ByteBuffer>> subscriber)

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

Annotations

@Override

public Class RawChannelTube

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class RawChannelTube.CleanupChecker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class RawChannelTube.ReadSubscriber

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class RawChannelTube.WritePublisher

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class RawChannelTube.WriteSubscription

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail