io.undertow.server.protocol.framed

Class AbstractFramedStreamSinkChannel<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.AbstractFramedStreamSinkChannel<C,R,S>

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, GatheringByteChannel, InterruptibleChannel, WritableByteChannel, org.xnio.channels.CloseableChannel, org.xnio.channels.Configurable, org.xnio.channels.StreamSinkChannel, org.xnio.channels.SuspendableWriteChannel

Direct Known Subclasses:

AbstractAjpClientStreamSinkChannel, SpdyStreamSinkChannel, StreamSinkFrameChannel

public abstract class AbstractFramedStreamSinkChannel<C extends AbstractFramedChannel<C,R,S>,R extends AbstractFramedStreamSourceChannel<C,R,S>,S extends AbstractFramedStreamSinkChannel<C,R,S>>
extends Object
implements org.xnio.channels.StreamSinkChannel

Framed Stream Sink Channel.

Thread safety notes:

The general contract is that this channel is only to be used by a single thread at a time. The only exception to this is during flush. A flush will only happen when readyForFlush is set, and while this bit is set the buffer must not be modified.

Author:

Stuart Douglas

Field Summary

Fields inherited from interface org.xnio.channels.Configurable

EMPTY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFramedStreamSinkChannel(C channel)

Method Summary

Modifier and Type	Method and Description
void	awaitWritable()
void	awaitWritable(long l, TimeUnit timeUnit)
protected void	channelForciblyClosed() Called when a channel has been forcibly closed, and data (frames) have already been written.
void	close()
protected org.xnio.Pooled<ByteBuffer>	createFrameFooter()
protected SendFrameHeader	createFrameHeader()
boolean	flush()
ByteBuffer	getBuffer()
C	getChannel()
org.xnio.ChannelListener.Setter<? extends S>	getCloseSetter()
org.xnio.XnioIoThread	getIoThread()
<T> T	getOption(org.xnio.Option<T> tOption)
org.xnio.XnioWorker	getWorker()
org.xnio.ChannelListener.Setter<? extends S>	getWriteSetter()
org.xnio.XnioExecutor	getWriteThread()
protected void	handleFlushComplete(boolean finalFrame)
boolean	isBroken()
protected boolean	isFinalFrameQueued()
protected boolean	isFirstDataWritten()
protected abstract boolean	isLastFrame()
boolean	isOpen()
boolean	isReadyForFlush()
boolean	isWriteResumed()
boolean	isWritesShutdown() Returns true writes have been shutdown
void	markBroken()
void	resumeWrites()
protected void	resumeWritesInternal(boolean wakeup)
<T> T	setOption(org.xnio.Option<T> tOption, T t)
void	shutdownWrites()
boolean	supportsOption(org.xnio.Option<?> option)
void	suspendWrites()
long	transferFrom(FileChannel src, long position, long count)
long	transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer)
void	wakeupWrites()
int	write(ByteBuffer src)
long	write(ByteBuffer[] srcs)
long	write(ByteBuffer[] srcs, int offset, int length)
int	writeFinal(ByteBuffer src)
long	writeFinal(ByteBuffer[] srcs)
long	writeFinal(ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFramedStreamSinkChannel

protected AbstractFramedStreamSinkChannel(C channel)

Method Detail

transferFrom

public long transferFrom(FileChannel src,
                         long position,
                         long count)
                  throws IOException

Specified by:

transferFrom in interface org.xnio.channels.StreamSinkChannel

Throws:

IOException

transferFrom

public long transferFrom(org.xnio.channels.StreamSourceChannel source,
                         long count,
                         ByteBuffer throughBuffer)
                  throws IOException

Specified by:

transferFrom in interface org.xnio.channels.StreamSinkChannel

Throws:

IOException

suspendWrites

public void suspendWrites()

Specified by:

suspendWrites in interface org.xnio.channels.SuspendableWriteChannel

createFrameHeader

protected SendFrameHeader createFrameHeader()
                                     throws IOException

Throws:

IOException

createFrameFooter

protected org.xnio.Pooled<ByteBuffer> createFrameFooter()

isWriteResumed

public boolean isWriteResumed()

Specified by:

isWriteResumed in interface org.xnio.channels.SuspendableWriteChannel

wakeupWrites

public void wakeupWrites()

Specified by:

wakeupWrites in interface org.xnio.channels.SuspendableWriteChannel

resumeWrites

public void resumeWrites()

Specified by:

resumeWrites in interface org.xnio.channels.SuspendableWriteChannel

resumeWritesInternal

protected void resumeWritesInternal(boolean wakeup)

shutdownWrites

public void shutdownWrites()
                    throws IOException

Specified by:

shutdownWrites in interface org.xnio.channels.SuspendableWriteChannel

Throws:

IOException

isFinalFrameQueued

protected boolean isFinalFrameQueued()

awaitWritable

public void awaitWritable()
                   throws IOException

Specified by:

awaitWritable in interface org.xnio.channels.SuspendableWriteChannel

Throws:

IOException

awaitWritable

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

Specified by:

awaitWritable in interface org.xnio.channels.SuspendableWriteChannel

Throws:

IOException

getWriteThread

public org.xnio.XnioExecutor getWriteThread()

Specified by:

getWriteThread in interface org.xnio.channels.SuspendableWriteChannel

getWriteSetter

public org.xnio.ChannelListener.Setter<? extends S> getWriteSetter()

Specified by:

getWriteSetter in interface org.xnio.channels.StreamSinkChannel

Specified by:

getWriteSetter in interface org.xnio.channels.SuspendableWriteChannel

getCloseSetter

public org.xnio.ChannelListener.Setter<? extends S> getCloseSetter()

Specified by:

getCloseSetter in interface org.xnio.channels.CloseableChannel

Specified by:

getCloseSetter in interface org.xnio.channels.StreamSinkChannel

Specified by:

getCloseSetter in interface org.xnio.channels.SuspendableWriteChannel

getWorker

public org.xnio.XnioWorker getWorker()

Specified by:

getWorker in interface org.xnio.channels.CloseableChannel

getIoThread

public org.xnio.XnioIoThread getIoThread()

Specified by:

getIoThread in interface org.xnio.channels.CloseableChannel

flush

public boolean flush()
              throws IOException

Specified by:

flush in interface org.xnio.channels.SuspendableWriteChannel

Throws:

IOException

write

public long write(ByteBuffer[] srcs,
                  int offset,
                  int length)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Throws:

IOException

write

public long write(ByteBuffer[] srcs)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Throws:

IOException

writeFinal

public long writeFinal(ByteBuffer[] srcs,
                       int offset,
                       int length)
                throws IOException

Specified by:

writeFinal in interface org.xnio.channels.StreamSinkChannel

Throws:

IOException

writeFinal

public long writeFinal(ByteBuffer[] srcs)
                throws IOException

Specified by:

writeFinal in interface org.xnio.channels.StreamSinkChannel

Throws:

IOException

writeFinal

public int writeFinal(ByteBuffer src)
               throws IOException

Specified by:

writeFinal in interface org.xnio.channels.StreamSinkChannel

Throws:

IOException

isLastFrame

protected abstract boolean isLastFrame()

Returns:

true If this is the last frame that will be sent on this connection

isReadyForFlush

public boolean isReadyForFlush()

Returns:

true if the channel is ready to be flushed. When a channel is ready to be flushed nothing should modify the buffer, as it may be written out by another thread.

isWritesShutdown

public boolean isWritesShutdown()

Returns true writes have been shutdown

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

Specified by:

isOpen in interface org.xnio.channels.SuspendableWriteChannel

close

public void close()
           throws IOException

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 org.xnio.channels.CloseableChannel

Specified by:

close in interface org.xnio.channels.SuspendableWriteChannel

Throws:

IOException

channelForciblyClosed

protected void channelForciblyClosed()
                              throws IOException

Called when a channel has been forcibly closed, and data (frames) have already been written. The action this should take is protocol dependent, e.g. for SPDY a RST_STREAM should be sent, for websockets the channel should be closed. By default this will just close the underlying channel

Throws:

IOException

supportsOption

public boolean supportsOption(org.xnio.Option<?> option)

Specified by:

supportsOption in interface org.xnio.channels.Configurable

getOption

public <T> T getOption(org.xnio.Option<T> tOption)
                throws IOException

Specified by:

getOption in interface org.xnio.channels.Configurable

Throws:

IOException

setOption

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

Specified by:

setOption in interface org.xnio.channels.Configurable

Throws:

IllegalArgumentException

IOException

getBuffer

public ByteBuffer getBuffer()

handleFlushComplete

protected void handleFlushComplete(boolean finalFrame)

isFirstDataWritten

protected boolean isFirstDataWritten()

markBroken

public void markBroken()

getChannel

public C getChannel()

isBroken

public boolean isBroken()