Top Fields Constructors Methods

io.undertow.server.protocol.ajp

pack-priv final Class AjpReadListener

Class Inheritance

extends Object
implements ChannelListener<StreamSourceChannel>

java.lang.Object
io.undertow.server.protocol.ajp.AjpReadListener

All Implemented Interfaces

org.xnio.ChannelListener, java.util.EventListener

Imports

io.undertow.UndertowLogger, .UndertowMessages, .UndertowOptions, io.undertow.conduits.ConduitListener, .EmptyStreamSourceConduit, .ReadDataStreamSourceConduit, io.undertow.server.AbstractServerConnection, .ConnectorStatisticsImpl, .Connectors, .HttpServerExchange, io.undertow.server.protocol.ParseTimeoutUpdater, io.undertow.util.HeaderMap, .Headers, .HttpString, .Methods, .StatusCodes, .BadRequestException, org.xnio.ChannelListener, .StreamConnection, io.undertow.connector.PooledByteBuffer, org.xnio.channels.StreamSinkChannel, .StreamSourceChannel, org.xnio.conduits.ConduitStreamSinkChannel, .ConduitStreamSourceChannel, .StreamSourceConduit, .WriteReadyHandler, java.io.IOException, java.nio.ByteBuffer

Author: Stuart Douglas

Field Summary

Modifier and Type	Field and Description
private final AjpServerConnection	connection
private final ConnectorStatisticsImpl	connectorStatistics
private static final byte[]	CPONG
private static final byte[]	END_RESPONSE
private HttpServerExchange	httpServerExchange
private final long	maxEntitySize
private final int	maxRequestSize
private final AjpRequestParser	parser
private ParseTimeoutUpdater	parseTimeoutUpdater
private volatile int	read
private final boolean	recordRequestStartTime
private final String	scheme
private static final byte[]	SEND_HEADERS_BAD_REQUEST_MSG
private static final byte[]	SEND_HEADERS_INTERNAL_SERVER_ERROR_MSG
private AjpRequestParseState	state
private WriteReadyHandler.ChannelListenerHandler<ConduitStreamSinkChannel>	writeReadyHandler

Constructor Summary

Access	Constructor and Description
pack-priv	AjpReadListener(final AjpServerConnection connection, final String scheme, AjpRequestParser parser, ConnectorStatisticsImpl connectorStatistics)

Method Summary

Modifier and Type	Method and Description
private StreamSourceConduit	createSourceConduit(StreamSourceConduit underlyingConduit, AjpServerResponseConduit responseConduit, final HttpServerExchange exchange)
public void	exchangeComplete(final HttpServerExchange exchange)
private void	handleBadRequest()
private void	handleCPing()
public void	handleEvent(final StreamSourceChannel the channel event channel) Implements org.xnio.ChannelListener.handleEvent. Handle the event on this channel.
private void	handleInternalServerError()
private boolean	sendMessages(final byte[]... rawMessages)
public void	startRequest()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connection	back to summary
private final AjpServerConnection connection

connectorStatistics	back to summary
private final ConnectorStatisticsImpl connectorStatistics

CPONG	back to summary
private static final byte[] CPONG

END_RESPONSE	back to summary
private static final byte[] END_RESPONSE

httpServerExchange	back to summary
private HttpServerExchange httpServerExchange

maxEntitySize	back to summary
private final long maxEntitySize

maxRequestSize	back to summary
private final int maxRequestSize

parser	back to summary
private final AjpRequestParser parser

parseTimeoutUpdater	back to summary
private ParseTimeoutUpdater parseTimeoutUpdater

read	back to summary
private volatile int read

recordRequestStartTime	back to summary
private final boolean recordRequestStartTime

scheme	back to summary
private final String scheme

SEND_HEADERS_BAD_REQUEST_MSG	back to summary
private static final byte[] SEND_HEADERS_BAD_REQUEST_MSG

SEND_HEADERS_INTERNAL_SERVER_ERROR_MSG	back to summary
private static final byte[] SEND_HEADERS_INTERNAL_SERVER_ERROR_MSG

state	back to summary
private AjpRequestParseState state

writeReadyHandler	back to summary
private WriteReadyHandler.ChannelListenerHandler<ConduitStreamSinkChannel> writeReadyHandler

Constructor Detail

AjpReadListener	back to summary
pack-priv AjpReadListener(final AjpServerConnection connection, final String scheme, AjpRequestParser parser, ConnectorStatisticsImpl connectorStatistics)

Method Detail

createSourceConduit	back to summary
private StreamSourceConduit createSourceConduit(StreamSourceConduit underlyingConduit, AjpServerResponseConduit responseConduit, final HttpServerExchange exchange) throws BadRequestException

exchangeComplete	back to summary
public void exchangeComplete(final HttpServerExchange exchange)

handleBadRequest	back to summary
private void handleBadRequest()

handleCPing	back to summary
private void handleCPing()

handleEvent

back to summary

public void handleEvent(final StreamSourceChannel channel)

Implements org.xnio.ChannelListener.handleEvent.

Doc from org.xnio.ChannelListener.handleEvent.

Handle the event on this channel.

Parameters

channel:StreamSourceChannel: the channel event

handleInternalServerError	back to summary
private void handleInternalServerError()

sendMessages	back to summary
private boolean sendMessages(final byte[]... rawMessages)

startRequest	back to summary
public void startRequest()