Top Description Fields Constructors Methods
io.undertow.protocols.ajp

public Class AjpClientRequestClientStreamSinkChannel

extends AbstractAjpClientStreamSinkChannel
Class Inheritance
Static Imports
io.undertow.protocols.ajp.AjpConstants.ATTR_AUTH_TYPE, .AjpConstants.ATTR_QUERY_STRING, .AjpConstants.ATTR_REMOTE_USER, .AjpConstants.ATTR_ROUTE, .AjpConstants.ATTR_SECRET, .AjpConstants.ATTR_SSL_CERT, .AjpConstants.ATTR_SSL_CIPHER, .AjpConstants.ATTR_SSL_KEY_SIZE, .AjpConstants.ATTR_SSL_SESSION, .AjpConstants.ATTR_STORED_METHOD, .AjpUtils.notNull, .AjpUtils.putString
AJP stream sink channel that corresponds to a request send from the load balancer to the backend
Author
Stuart Douglas

Field Summary

Modifier and TypeField and Description
private final Attachable
attachable

private long
dataSize

public static final int
DEFAULT_MAX_DATA_SIZE

private boolean
discardMode

When we are the client and the

private final ChannelListener<AjpClientRequestClientStreamSinkChannel>
finishListener

private boolean
firstFrameWritten

private SendFrameHeader
header

Hides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.header.

private final HeaderMap
headers

private final HttpString
method

private final String
path

private final HttpString
protocol

private int
requestedChunkSize

Constructor Summary

AccessConstructor and Description
pack-priv
AjpClientRequestClientStreamSinkChannel(AjpClientChannel channel, ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener, HeaderMap headers, String path, HttpString method, HttpString protocol, Attachable attachable)

Method Summary

Modifier and TypeMethod and Description
protected void
channelForciblyClosed()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.channelForciblyClosed.

Called when a channel has been forcibly closed, and data (frames) have already been written.

pack-priv void
chunkRequested(int size)

public void
clearHeader()

protected final SendFrameHeader
createFrameHeader()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.createFrameHeader.

private SendFrameHeader
createFrameHeaderImpl()

pack-priv SendFrameHeader
generateSendFrameHeader()

protected void
handleFlushComplete(boolean finalFrame)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.handleFlushComplete.

public void
startDiscard()

Inherited from io.undertow.protocols.ajp.AbstractAjpClientStreamSinkChannel:
isLastFrame

Field Detail

attachableback to summary
private final Attachable attachable
dataSizeback to summary
private long dataSize
DEFAULT_MAX_DATA_SIZEback to summary
public static final int DEFAULT_MAX_DATA_SIZE
discardModeback to summary
private boolean discardMode

When we are the client and the

finishListenerback to summary
private final ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener
firstFrameWrittenback to summary
private boolean firstFrameWritten
headersback to summary
private final HeaderMap headers
methodback to summary
private final HttpString method
pathback to summary
private final String path
protocolback to summary
private final HttpString protocol
requestedChunkSizeback to summary
private int requestedChunkSize

Constructor Detail

AjpClientRequestClientStreamSinkChannelback to summary
pack-priv AjpClientRequestClientStreamSinkChannel(AjpClientChannel channel, ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener, HeaderMap headers, String path, HttpString method, HttpString protocol, Attachable attachable)

Method Detail

channelForciblyClosedback to summary
protected void channelForciblyClosed() throws IOException

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.channelForciblyClosed.

Doc from io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.channelForciblyClosed.

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

Annotations
@Override
chunkRequestedback to summary
pack-priv void chunkRequested(int size) throws IOException
clearHeaderback to summary
public void clearHeader()
createFrameHeaderback to summary
protected final SendFrameHeader createFrameHeader()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.createFrameHeader.

Annotations
@Override
createFrameHeaderImplback to summary
private SendFrameHeader createFrameHeaderImpl()
generateSendFrameHeaderback to summary
pack-priv SendFrameHeader generateSendFrameHeader()
handleFlushCompleteback to summary
protected void handleFlushComplete(boolean finalFrame)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSinkChannel.handleFlushComplete.

Annotations
@Override
startDiscardback to summary
public void startDiscard()