io.undertow.websockets.core.protocol.version07

Class WebSocket07FrameSinkChannel

java.lang.Object

io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

io.undertow.websockets.core.StreamSinkFrameChannel

io.undertow.websockets.core.protocol.version07.WebSocket07FrameSinkChannel

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

public abstract class WebSocket07FrameSinkChannel
extends StreamSinkFrameChannel

StreamSinkFrameChannel implementation for writing WebSocket Frames on WebSocketVersion.V08 connections

Author:

Norman Maurer

Field Summary

Fields inherited from interface org.xnio.channels.Configurable

EMPTY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WebSocket07FrameSinkChannel(WebSocket07Channel wsChannel, WebSocketFrameType type, long payloadSize)

Method Summary

Modifier and Type	Method and Description
protected void	channelForciblyClosed() If a stream sink channel is closed while in the middle of sending fragmented data we need to close the connection.
protected SendFrameHeader	createFrameHeader()
protected void	handleFlushComplete(boolean finalFrame)
int	write(ByteBuffer src)
long	write(ByteBuffer[] srcs)
long	write(ByteBuffer[] srcs, int offset, int length)

Methods inherited from class io.undertow.websockets.core.StreamSinkFrameChannel

areExtensionsSupported, getRsv, getType, getWebSocketChannel, isFinalFragment, isFragmentationSupported, isLastFrame, setRsv

Methods inherited from class io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel

awaitWritable, awaitWritable, close, createFrameFooter, flush, getBuffer, getChannel, getCloseSetter, getIoThread, getOption, getWorker, getWriteSetter, getWriteThread, isBroken, isFinalFrameQueued, isFirstDataWritten, isOpen, isReadyForFlush, isWriteResumed, isWritesShutdown, markBroken, resumeWrites, resumeWritesInternal, setOption, shutdownWrites, supportsOption, suspendWrites, transferFrom, transferFrom, wakeupWrites, writeFinal, writeFinal, writeFinal

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocket07FrameSinkChannel

protected WebSocket07FrameSinkChannel(WebSocket07Channel wsChannel,
                                      WebSocketFrameType type,
                                      long payloadSize)

Method Detail

handleFlushComplete

protected void handleFlushComplete(boolean finalFrame)

Overrides:

handleFlushComplete in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

channelForciblyClosed

protected void channelForciblyClosed()
                              throws IOException

If a stream sink channel is closed while in the middle of sending fragmented data we need to close the connection.

Overrides:

channelForciblyClosed in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

Throws:

IOException

createFrameHeader

protected SendFrameHeader createFrameHeader()

Overrides:

createFrameHeader in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

write

public long write(ByteBuffer[] srcs)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Overrides:

write in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

Throws:

IOException

write

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

Specified by:

write in interface GatheringByteChannel

Overrides:

write in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Overrides:

write in class AbstractFramedStreamSinkChannel<WebSocketChannel,StreamSourceFrameChannel,StreamSinkFrameChannel>

Throws:

IOException