Package io.undertow.protocols.ajp
Class AjpClientRequestClientStreamSinkChannel
java.lang.Object
io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
io.undertow.protocols.ajp.AbstractAjpClientStreamSinkChannel
io.undertow.protocols.ajp.AjpClientRequestClientStreamSinkChannel
- 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
AJP stream sink channel that corresponds to a request send from the load balancer to the backend
- Author:
- Stuart Douglas
-
Field Summary
FieldsFields inherited from interface org.xnio.channels.Configurable
EMPTY
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
Called when a channel has been forcibly closed, and data (frames) have already been written.void
protected final SendFrameHeader
protected void
handleFlushComplete
(boolean finalFrame) void
Methods inherited from class io.undertow.protocols.ajp.AbstractAjpClientStreamSinkChannel
isLastFrame
Methods inherited from class io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel
awaitWritable, awaitWritable, close, flush, getAwaitWritableTimeout, getBuffer, getChannel, getCloseSetter, getIoThread, getOption, getWorker, getWriteSetter, getWriteThread, isBroken, isBufferFull, isFinalFrameQueued, isFirstDataWritten, isFlushRequiredOnEmptyBuffer, isOpen, isReadyForFlush, isWriteResumed, isWritesShutdown, markBroken, preWriteTransform, resumeWrites, resumeWritesInternal, safeToSend, send, sendInternal, setOption, shutdownWrites, supportsOption, suspendWrites, transferFrom, transferFrom, wakeupWrites, write, write, write, writeFinal, writeFinal, writeFinal
-
Field Details
-
DEFAULT_MAX_DATA_SIZE
public static final int DEFAULT_MAX_DATA_SIZE- See Also:
-
-
Method Details
-
startDiscard
public void startDiscard() -
createFrameHeader
-
handleFlushComplete
protected void handleFlushComplete(boolean finalFrame) -
channelForciblyClosed
Description copied from class:AbstractFramedStreamSinkChannel
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 -
clearHeader
public void clearHeader()
-