io.undertow.server.protocol.framed

Class AbstractFramedStreamSourceChannel<C extends AbstractFramedChannel<C,R,S>,R extends AbstractFramedStreamSourceChannel<C,R,S>,S extends AbstractFramedStreamSinkChannel<C,R,S>>

java.lang.Object

io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<C,R,S>

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, InterruptibleChannel, ReadableByteChannel, ScatteringByteChannel, CloseableChannel, Configurable, StreamSourceChannel, SuspendableReadChannel

Direct Known Subclasses:

AbstractAjpClientStreamSourceChannel, AbstractHttp2StreamSourceChannel, StreamSourceFrameChannel

public abstract class AbstractFramedStreamSourceChannel<C extends AbstractFramedChannel<C,R,S>,R extends AbstractFramedStreamSourceChannel<C,R,S>,S extends AbstractFramedStreamSinkChannel<C,R,S>>
extends Object
implements StreamSourceChannel

Source channel, used to receive framed messages.

Author:

Stuart Douglas

Field Summary

Fields inherited from interface org.xnio.channels.Configurable

EMPTY

Constructor Summary

Constructors

Constructor and Description
AbstractFramedStreamSourceChannel(C framedChannel)
AbstractFramedStreamSourceChannel(C framedChannel, PooledByteBuffer data, long frameDataRemaining)

Method Summary

Modifier and Type	Method and Description
void	addCloseTask(ChannelListener<R> channelListener)
void	awaitReadable() Block until this channel becomes readable again.
void	awaitReadable(long l, TimeUnit timeUnit) Block until this channel becomes readable again, or until the timeout expires.
protected void	channelForciblyClosed()
void	close() Close this channel.
protected void	complete() Method that is invoked when all data has been read.
protected void	dataReady(FrameHeaderData headerData, PooledByteBuffer frameData) Called when data has been read from the underlying channel.
ChannelListener.Setter<? extends R>	getCloseSetter() Get the setter which can be used to change the close listener for this channel.
protected C	getFramedChannel()
XnioIoThread	getIoThread() Get the I/O thread associated with this channel.
long	getMaxStreamSize()
<T> T	getOption(Option<T> tOption) Get the value of a channel option.
protected int	getReadFrameCount()
ChannelListener.Setter<? extends R>	getReadSetter() Get the setter which can be used to change the read listener for this channel.
XnioExecutor	getReadThread() Get the read thread for this channel.
XnioWorker	getWorker() Get the worker for this channel.
protected void	handleHeaderData(FrameHeaderData headerData)
protected boolean	isComplete()
protected boolean	isLastFrame()
boolean	isOpen()
boolean	isReadResumed() Determine whether reads are resumed.
protected void	lastFrame()
protected void	markStreamBroken() Called when this stream is no longer valid.
protected PooledByteBuffer	processFrameData(PooledByteBuffer data, boolean lastFragmentOfFrame)
int	read(ByteBuffer dst)
long	read(ByteBuffer[] dsts)
long	read(ByteBuffer[] dsts, int offset, int length)
void	resumeReads() Resume reads on this channel.
void	setMaxStreamSize(long maxStreamSize)
<T> T	setOption(Option<T> tOption, T t) Set an option for this channel.
void	shutdownReads() Places this readable channel at "end of stream".
boolean	supportsOption(Option<?> option) Determine whether an option is supported on this channel.
void	suspendReads() Suspend further read notifications on this channel.
long	transferTo(long count, ByteBuffer throughBuffer, StreamSinkChannel streamSinkChannel) Transfers bytes into the given channel target.
long	transferTo(long position, long count, FileChannel target) Transfers bytes into the given file from this channel.
protected long	updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
void	wakeupReads() Resume reads on this channel, and force the read listener to be triggered even if the channel isn't actually readable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractFramedStreamSourceChannel

public AbstractFramedStreamSourceChannel(C framedChannel)

AbstractFramedStreamSourceChannel

public AbstractFramedStreamSourceChannel(C framedChannel,
                                         PooledByteBuffer data,
                                         long frameDataRemaining)

Method Detail

transferTo

public long transferTo(long position,
                       long count,
                       FileChannel target)
                throws IOException

Description copied from interface: StreamSourceChannel

Transfers bytes into the given file from this channel. Using this method in preference to FileChannel.transferFrom(ReadableByteChannel, long, long) may provide a performance advantage on some platforms.

If the current thread is interrupted when this method is called, it may throw a InterruptedIOException; however, if this exception is thrown, the InterruptedIOException.bytesTransferred field is guaranteed to be 0.

Specified by:

transferTo in interface StreamSourceChannel

Parameters:

position - the position within the file from which the transfer is to begin

count - the number of bytes to be transferred

target - the file to write to

Returns:

the number of bytes (possibly 0) that were actually transferred

Throws:

IOException - if an I/O error occurs

transferTo

public long transferTo(long count,
                       ByteBuffer throughBuffer,
                       StreamSinkChannel streamSinkChannel)
                throws IOException

Description copied from interface: StreamSourceChannel

Transfers bytes into the given channel target. On some platforms, this may avoid copying bytes between user and kernel space. On other platforms, bytes are passed through the throughBuffer parameter's buffer space. On entry, throughBuffer will be cleared. On exit, the buffer will be flipped for emptying, and may possibly be empty or may contain data. If this method returns a value less than count, then the remaining data in throughBuffer may contain data read from this channel which must be written to target to complete the operation. Note that using a direct buffer may provide an intermediate performance gain on platforms without zero-copy facilities.

If the current thread is interrupted when this method is called, it may throw a InterruptedIOException; however, if this exception is thrown, the InterruptedIOException.bytesTransferred field is guaranteed to be 0. Note that the return value is the amount of data that was actually transferred to the StreamSinkChannel. The actual amount of data read could be larger than this, and can be calculated by adding the return value and the amount of data left in throughBuffer.

Specified by:

transferTo in interface StreamSourceChannel

Parameters:

count - the number of bytes to be transferred

throughBuffer - the buffer to copy through.

streamSinkChannel - the destination to write to

Returns:

the number of bytes (possibly 0) that were actually transferred, or -1 if the end of input was reached

Throws:

IOException - if an I/O error occurs

getMaxStreamSize

public long getMaxStreamSize()

setMaxStreamSize

public void setMaxStreamSize(long maxStreamSize)

suspendReads

public void suspendReads()

Description copied from interface: SuspendableReadChannel

Suspend further read notifications on this channel.

Specified by:

suspendReads in interface SuspendableReadChannel

complete

protected void complete()
                 throws IOException

Method that is invoked when all data has been read.

Throws:

IOException

isComplete

protected boolean isComplete()

resumeReads

public void resumeReads()

Description copied from interface: SuspendableReadChannel

Resume reads on this channel. The read listener will be called as soon as there is data available to be read.

Specified by:

resumeReads in interface SuspendableReadChannel

isReadResumed

public boolean isReadResumed()

Description copied from interface: SuspendableReadChannel

Determine whether reads are resumed.

Specified by:

isReadResumed in interface SuspendableReadChannel

Returns:

true if reads are resumed, false if reads are suspended

wakeupReads

public void wakeupReads()

Description copied from interface: SuspendableReadChannel

Resume reads on this channel, and force the read listener to be triggered even if the channel isn't actually readable.

Specified by:

wakeupReads in interface SuspendableReadChannel

addCloseTask

public void addCloseTask(ChannelListener<R> channelListener)

shutdownReads

public void shutdownReads()
                   throws IOException

Description copied from interface: SuspendableReadChannel

Places this readable channel at "end of stream". Further reads will result in EOF. Shutting down all directions of a channel will cause CloseableChannel.close() to be called automatically.

Specified by:

shutdownReads in interface SuspendableReadChannel

Throws:

IOException - if an I/O error occurs

lastFrame

protected void lastFrame()

isLastFrame

protected boolean isLastFrame()

awaitReadable

public void awaitReadable()
                   throws IOException

Description copied from interface: SuspendableReadChannel

Block until this channel becomes readable again. This method may return spuriously before the channel becomes readable.

Specified by:

awaitReadable in interface SuspendableReadChannel

Throws:

InterruptedIOException - if the operation is interrupted; the thread's interrupt flag will be set as well

IOException - if an I/O error occurs

awaitReadable

public void awaitReadable(long l,
                          TimeUnit timeUnit)
                   throws IOException

Description copied from interface: SuspendableReadChannel

Block until this channel becomes readable again, or until the timeout expires. This method may return spuriously before the channel becomes readable or the timeout expires.

Specified by:

awaitReadable in interface SuspendableReadChannel

Parameters:

l - the time to wait

timeUnit - the time unit

Throws:

InterruptedIOException - if the operation is interrupted; the thread's interrupt flag will be set as well

IOException - if an I/O error occurs

dataReady

protected void dataReady(FrameHeaderData headerData,
                         PooledByteBuffer frameData)

Called when data has been read from the underlying channel.

Parameters:

headerData - The frame header data. This may be null if the data is part of a an existing frame

frameData - The frame data

updateFrameDataRemaining

protected long updateFrameDataRemaining(PooledByteBuffer frameData,
                                        long frameDataRemaining)

processFrameData

protected PooledByteBuffer processFrameData(PooledByteBuffer data,
                                            boolean lastFragmentOfFrame)
                                     throws IOException

Throws:

IOException

handleHeaderData

protected void handleHeaderData(FrameHeaderData headerData)

getReadThread

public XnioExecutor getReadThread()

Description copied from interface: SuspendableReadChannel

Get the read thread for this channel.

Specified by:

getReadThread in interface SuspendableReadChannel

Returns:

the thread, or null if none is configured or available

getReadSetter

public ChannelListener.Setter<? extends R> getReadSetter()

Description copied from interface: StreamSourceChannel

Get the setter which can be used to change the read listener for this channel.

Specified by:

getReadSetter in interface StreamSourceChannel

Specified by:

getReadSetter in interface SuspendableReadChannel

Returns:

the setter

getCloseSetter

public ChannelListener.Setter<? extends R> getCloseSetter()

Description copied from interface: StreamSourceChannel

Get the setter which can be used to change the close listener for this channel. If the channel is already closed, then the listener will not be called.

Specified by:

getCloseSetter in interface CloseableChannel

Specified by:

getCloseSetter in interface StreamSourceChannel

Specified by:

getCloseSetter in interface SuspendableReadChannel

Returns:

the setter

getWorker

public XnioWorker getWorker()

Description copied from interface: CloseableChannel

Get the worker for this channel.

Specified by:

getWorker in interface CloseableChannel

Returns:

the worker

getIoThread

public XnioIoThread getIoThread()

Description copied from interface: CloseableChannel

Get the I/O thread associated with this channel.

Specified by:

getIoThread in interface CloseableChannel

Returns:

the I/O thread associated with this channel

supportsOption

public boolean supportsOption(Option<?> option)

Description copied from interface: Configurable

Determine whether an option is supported on this channel.

Specified by:

supportsOption in interface Configurable

Parameters:

option - the option

Returns:

true if it is supported

getOption

public <T> T getOption(Option<T> tOption)
                throws IOException

Description copied from interface: Configurable

Get the value of a channel option.

Specified by:

getOption in interface Configurable

Type Parameters:

T - the type of the option value

Parameters:

tOption - the option to get

Returns:

the value of the option, or null if it is not set

Throws:

IOException - if an I/O error occurred when reading the option

setOption

public <T> T setOption(Option<T> tOption,
                       T t)
                throws IllegalArgumentException,
                       IOException

Description copied from interface: Configurable

Set an option for this channel. Unsupported options are ignored.

Specified by:

setOption in interface Configurable

Type Parameters:

T - the type of the option value

Parameters:

tOption - the option to set

t - the value of the option to set

Returns:

the previous option value, if any

Throws:

IllegalArgumentException - if the value is not acceptable for this option

IOException - if an I/O error occurred when modifying the option

read

public long read(ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Throws:

IOException

read

public long read(ByteBuffer[] dsts)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()

Description copied from interface: CloseableChannel

Close this channel. When a channel is closed, its close listener is invoked. Invoking this method more than once has no additional effect.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface InterruptibleChannel

Specified by:

close in interface CloseableChannel

channelForciblyClosed

protected void channelForciblyClosed()

getFramedChannel

protected C getFramedChannel()

getReadFrameCount

protected int getReadFrameCount()

markStreamBroken

protected void markStreamBroken()

Called when this stream is no longer valid. Reads from the stream will result in an exception.