jdk.internal.net.http.websocket

public Class TransportImpl

Class Inheritance

extends Object
implements Transport

java.lang.Object
jdk.internal.net.http.websocket.TransportImpl

All Implemented Interfaces

jdk.internal.net.http.websocket.Transport

Imports

jdk.internal.net.http.common.Demand, .Logger, .MinimalFuture, .SequentialScheduler, .SequentialScheduler.CompleteRestartableTask, .Utils, java.io.IOException, java.nio.ByteBuffer, .CharBuffer, java.nio.channels.SelectionKey, java.util.concurrent.CompletableFuture, java.util.concurrent.atomic.AtomicLong, .AtomicReference, java.util.concurrent.locks.ReentrantLock, java.util.function.BiConsumer, .Supplier

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static enum	TransportImpl.ChannelState
private class	TransportImpl.ReadEvent
private class	TransportImpl.ReceiveTask
private class	TransportImpl.SendTask
private class	TransportImpl.WriteEvent

Field Summary

Modifier and Type	Field and Description
private final RawChannel	channel
private final ReentrantLock	closeLock
private final AtomicLong	counter
private ByteBuffer	data
private static final Logger	debug
private final MessageDecoder	decoder
private final Demand	demand
private final ByteBuffer	dst
private final ByteBuffer[]	dstArray
private final MessageEncoder	encoder
private boolean	inputClosed
private final MessageStreamConsumer	messageConsumer
private boolean	outputClosed
private final MessageQueue	queue
private final Frame.Reader	reader
private final RawChannel.RawEvent	readEvent
private volatile TransportImpl.ChannelState	readState
private final SequentialScheduler	receiveScheduler
private final SequentialScheduler	sendScheduler
private final RawChannel.RawEvent	writeEvent
private final AtomicReference<TransportImpl.ChannelState>	writeState

Constructor Summary

Access	Constructor and Description
public	TransportImpl(MessageQueue queue, MessageStreamConsumer consumer, RawChannel channel)

Method Summary

Modifier and Type	Method and Description
public void	acknowledgeReception() Implements jdk.internal.net.http.websocket.Transport.acknowledgeReception.
public void	closeInput() Implements jdk.internal.net.http.websocket.Transport.closeInput.
public void	closeOutput() Implements jdk.internal.net.http.websocket.Transport.closeOutput.
private ByteBuffer	createWriteBuffer()
public void	request(long n) Implements jdk.internal.net.http.websocket.Transport.request.
public <T> CompletableFuture<T>	sendBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendBinary.
public <T> CompletableFuture<T>	sendClose(int statusCode, String reason, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendClose.
public <T> CompletableFuture<T>	sendPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPing.
public <T> CompletableFuture<T>	sendPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPong.
public <T> CompletableFuture<T>	sendPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPong.
public <T> CompletableFuture<T>	sendText(CharSequence message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendText.
private boolean	write()

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

Field Detail

channel	back to summary
private final RawChannel channel

closeLock	back to summary
private final ReentrantLock closeLock

counter	back to summary
private final AtomicLong counter

data	back to summary
private ByteBuffer data

debug	back to summary
private static final Logger debug

decoder	back to summary
private final MessageDecoder decoder

demand	back to summary
private final Demand demand

dst	back to summary
private final ByteBuffer dst

dstArray	back to summary
private final ByteBuffer[] dstArray

encoder	back to summary
private final MessageEncoder encoder

inputClosed	back to summary
private boolean inputClosed

messageConsumer	back to summary
private final MessageStreamConsumer messageConsumer

outputClosed	back to summary
private boolean outputClosed

queue	back to summary
private final MessageQueue queue

reader	back to summary
private final Frame.Reader reader

readEvent	back to summary
private final RawChannel.RawEvent readEvent

readState	back to summary
private volatile TransportImpl.ChannelState readState

receiveScheduler	back to summary
private final SequentialScheduler receiveScheduler

sendScheduler	back to summary
private final SequentialScheduler sendScheduler

writeEvent	back to summary
private final RawChannel.RawEvent writeEvent

writeState	back to summary
private final AtomicReference<TransportImpl.ChannelState> writeState

Constructor Detail

TransportImpl	back to summary
public TransportImpl(MessageQueue queue, MessageStreamConsumer consumer, RawChannel channel)

Method Detail

acknowledgeReception	back to summary
public void acknowledgeReception() Implements jdk.internal.net.http.websocket.Transport.acknowledgeReception. Annotations @Override

acknowledgeReception

back to summary

public void acknowledgeReception()

Implements jdk.internal.net.http.websocket.Transport.acknowledgeReception.

Annotations

@Override

closeInput	back to summary
public void closeInput() throws IOException Implements jdk.internal.net.http.websocket.Transport.closeInput. Annotations @Override

closeInput

back to summary

public void closeInput() throws IOException

Implements jdk.internal.net.http.websocket.Transport.closeInput.

Annotations

@Override

closeOutput	back to summary
public void closeOutput() throws IOException Implements jdk.internal.net.http.websocket.Transport.closeOutput. Annotations @Override

closeOutput

back to summary

public void closeOutput() throws IOException

Implements jdk.internal.net.http.websocket.Transport.closeOutput.

Annotations

@Override

createWriteBuffer	back to summary
private ByteBuffer createWriteBuffer()

request	back to summary
public void request(long n) Implements jdk.internal.net.http.websocket.Transport.request. Annotations @Override

request

back to summary

public void request(long n)

Implements jdk.internal.net.http.websocket.Transport.request.

Annotations

@Override

sendBinary	back to summary
public <T> CompletableFuture<T> sendBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendBinary. Annotations @Override

sendBinary

back to summary

public <T> CompletableFuture<T> sendBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendBinary.

Annotations

@Override

sendClose	back to summary
public <T> CompletableFuture<T> sendClose(int statusCode, String reason, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendClose. Annotations @Override

sendClose

back to summary

public <T> CompletableFuture<T> sendClose(int statusCode, String reason, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendClose.

Annotations

@Override

sendPing	back to summary
public <T> CompletableFuture<T> sendPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPing. Annotations @Override

sendPing

back to summary

public <T> CompletableFuture<T> sendPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendPing.

Annotations

@Override

sendPong	back to summary
public <T> CompletableFuture<T> sendPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPong. Annotations @Override

sendPong

back to summary

public <T> CompletableFuture<T> sendPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendPong.

Annotations

@Override

sendPong	back to summary
public <T> CompletableFuture<T> sendPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendPong. Annotations @Override

sendPong

back to summary

public <T> CompletableFuture<T> sendPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendPong.

Annotations

@Override

sendText	back to summary
public <T> CompletableFuture<T> sendText(CharSequence message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action) Implements jdk.internal.net.http.websocket.Transport.sendText. Annotations @Override

sendText

back to summary

public <T> CompletableFuture<T> sendText(CharSequence message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action)

Implements jdk.internal.net.http.websocket.Transport.sendText.

Annotations

@Override

write	back to summary
private boolean write() throws IOException

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

pack-priv final Enum TransportImpl.ChannelState

Class Inheritance

extends Enum<TransportImpl.ChannelState>

java.lang.Object
java.lang.Enum
jdk.internal.net.http.websocket.TransportImpl.ChannelState

Field Summary

Modifier and Type	Field and Description
public static final TransportImpl.ChannelState	AVAILABLE
public static final TransportImpl.ChannelState	CLOSED
public static final TransportImpl.ChannelState	UNREGISTERED
public static final TransportImpl.ChannelState	WAITING

Constructor Summary

Access	Constructor and Description
private	ChannelState()

Method Summary

Modifier and Type	Method and Description
public static TransportImpl.ChannelState	valueOf(String name)
public static TransportImpl.ChannelState[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

AVAILABLE	back to summary
public static final TransportImpl.ChannelState AVAILABLE

CLOSED	back to summary
public static final TransportImpl.ChannelState CLOSED

UNREGISTERED	back to summary
public static final TransportImpl.ChannelState UNREGISTERED

WAITING	back to summary
public static final TransportImpl.ChannelState WAITING

Constructor Detail

ChannelState	back to summary
private ChannelState()

Method Detail

valueOf	back to summary
public static TransportImpl.ChannelState valueOf(String name)

values	back to summary
public static TransportImpl.ChannelState[] values()

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

private Class TransportImpl.ReadEvent

Class Inheritance

extends Object
implements RawEvent

java.lang.Object
jdk.internal.net.http.websocket.TransportImpl.ReadEvent

All Implemented Interfaces

jdk.internal.net.http.websocket.RawChannel.RawEvent

Constructor Summary

Access	Constructor and Description
private	ReadEvent()

Method Summary

Modifier and Type	Method and Description
public void	handle() Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.handle.
public int	interestOps() Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.interestOps.

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

Constructor Detail

ReadEvent	back to summary
private ReadEvent()

Method Detail

handle

back to summary

public void handle()

Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.handle.

Annotations

@Override

interestOps

back to summary

public int interestOps()

Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.interestOps.

Annotations

@Override

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

private Class TransportImpl.ReceiveTask

Class Inheritance

extends CompleteRestartableTask

java.lang.Object
jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask
jdk.internal.net.http.websocket.TransportImpl.ReceiveTask

Constructor Summary

Access	Constructor and Description
private	ReceiveTask()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run. The body of the task.

Inherited from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask:: run

Constructor Detail

ReceiveTask	back to summary
private ReceiveTask()

Method Detail

run

back to summary

public void run()

Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

Doc from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

The body of the task.

Annotations

@Override

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

private Class TransportImpl.SendTask

Class Inheritance

extends CompleteRestartableTask

java.lang.Object
jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask
jdk.internal.net.http.websocket.TransportImpl.SendTask

Annotations

@SuppressWarnings:rawtypes

Field Summary

Modifier and Type	Field and Description
private BiConsumer<T, U>	action
private Object	attachment
private boolean	encoded
private final MessageQueue.QueueCallback<Boolean, IOException>	encodingCallback
private boolean	firstPass
private CompletableFuture<T>	future
private final MessageQueue.QueueCallback<Boolean, RuntimeException>	loadCallback

Constructor Summary

Access	Constructor and Description
private	SendTask()

Method Summary

Modifier and Type	Method and Description
private void	removeAndComplete(Throwable error)
public void	run() Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run. The body of the task.
private boolean	tryCompleteWrite()

Inherited from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask:: run

Field Detail

action	back to summary
private BiConsumer<T, U> action

attachment	back to summary
private Object attachment

encoded	back to summary
private boolean encoded

encodingCallback	back to summary
private final MessageQueue.QueueCallback<Boolean, IOException> encodingCallback

firstPass	back to summary
private boolean firstPass

future	back to summary
private CompletableFuture<T> future

loadCallback	back to summary
private final MessageQueue.QueueCallback<Boolean, RuntimeException> loadCallback

Constructor Detail

SendTask	back to summary
private SendTask()

Method Detail

removeAndComplete	back to summary
private void removeAndComplete(Throwable error) Annotations @SuppressWarnings:unchecked

run

back to summary

public void run()

Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

Doc from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

The body of the task.

Annotations

@Override

tryCompleteWrite	back to summary
private boolean tryCompleteWrite() throws IOException

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

private Class TransportImpl.WriteEvent

Class Inheritance

extends Object
implements RawEvent

java.lang.Object
jdk.internal.net.http.websocket.TransportImpl.WriteEvent

All Implemented Interfaces

jdk.internal.net.http.websocket.RawChannel.RawEvent

Constructor Summary

Access	Constructor and Description
private	WriteEvent()

Method Summary

Modifier and Type	Method and Description
public void	handle() Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.handle.
public int	interestOps() Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.interestOps.

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

Constructor Detail

WriteEvent	back to summary
private WriteEvent()

Method Detail

handle

back to summary

public void handle()

Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.handle.

Annotations

@Override

interestOps

back to summary

public int interestOps()

Implements jdk.internal.net.http.websocket.RawChannel.RawEvent.interestOps.

Annotations

@Override