Top Description Fields Constructors Methods

io.undertow.server.protocol.http

pack-priv final Class HttpReadListener

Class Inheritance

extends Object
implements ChannelListener<ConduitStreamSourceChannel>, Runnable

java.lang.Object
io.undertow.server.protocol.http.HttpReadListener

All Implemented Interfaces

java.lang.Runnable, org.xnio.ChannelListener, java.util.EventListener

Imports

io.undertow.UndertowLogger, .UndertowMessages, .UndertowOptions, io.undertow.conduits.ReadDataStreamSourceConduit, io.undertow.connector.PooledByteBuffer, io.undertow.protocols.http2.Http2Channel, io.undertow.server.ConnectorStatisticsImpl, .Connectors, .HttpServerExchange, io.undertow.server.protocol.ParseTimeoutUpdater, io.undertow.server.protocol.http2.Http2ReceiveListener, io.undertow.util.ClosingChannelExceptionHandler, .ConnectionUtils, .HeaderValues, .Headers, .HttpString, .Methods, .Protocols, .StringWriteChannelListener, org.xnio.ChannelListener, .ChannelListeners, .IoUtils, .StreamConnection, org.xnio.channels.StreamSinkChannel, .StreamSourceChannel, org.xnio.conduits.ConduitStreamSinkChannel, .ConduitStreamSourceChannel, java.io.IOException, java.nio.ByteBuffer, java.util.concurrent.Executor, java.util.concurrent.atomic.AtomicIntegerFieldUpdater

Listener which reads requests and headers off of an HTTP stream.

Author: David M. Lloyd

Field Summary

Modifier and Type	Field and Description
private final boolean	allowUnknownProtocols
private static final String	BAD_REQUEST
private final HttpServerConnection	connection
private final ConnectorStatisticsImpl	connectorStatistics
private HttpServerExchange	httpServerExchange
private final long	maxEntitySize
private final int	maxRequestSize
private final HttpRequestParser	parser
private ParseTimeoutUpdater	parseTimeoutUpdater
private static final HttpString	PRI used for HTTP2 prior knowledge support
private static final byte[]	PRI_EXPECTED
private int	read
private final boolean	recordRequestStartTime
private volatile int	requestState
private static final AtomicIntegerFieldUpdater<HttpReadListener>	requestStateUpdater
private final boolean	requireHostHeader
private final ParseState	state

Constructor Summary

Access	Constructor and Description
pack-priv	HttpReadListener(final HttpServerConnection connection, final HttpRequestParser parser, ConnectorStatisticsImpl connectorStatistics)

Method Summary

Modifier and Type	Method and Description
private boolean	doHttp2PriRead(StreamConnection connection, ByteBuffer buffer, HttpServerConnection serverConnection, PooledByteBuffer extraData)
public void	exchangeComplete(final HttpServerExchange exchange)
public void	handleEvent(final ConduitStreamSourceChannel the channel event channel) Implements org.xnio.ChannelListener.handleEvent. Handle the event on this channel.
public void	handleEventWithNoRunningRequest(final ConduitStreamSourceChannel channel)
private void	handleFailedRead(ConduitStreamSourceChannel channel, int res)
private boolean	handleHttp2PriorKnowledge(PooledByteBuffer pooled, HttpServerExchange httpServerExchange)
private void	handleHttp2PriorKnowledge(final StreamConnection connection, final HttpServerConnection serverConnection, PooledByteBuffer readData)
private boolean	isUpgradeOrConnect(HttpServerExchange exchange)
public void	newRequest()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	sendBadRequestAndClose(final StreamConnection connection, final Throwable exception)

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

Field Detail

allowUnknownProtocols	back to summary
private final boolean allowUnknownProtocols

BAD_REQUEST	back to summary
private static final String BAD_REQUEST

connection	back to summary
private final HttpServerConnection connection

connectorStatistics	back to summary
private final ConnectorStatisticsImpl connectorStatistics

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 HttpRequestParser parser

parseTimeoutUpdater	back to summary
private ParseTimeoutUpdater parseTimeoutUpdater

PRI	back to summary
private static final HttpString PRI used for HTTP2 prior knowledge support

PRI_EXPECTED	back to summary
private static final byte[] PRI_EXPECTED

read	back to summary
private int read

recordRequestStartTime	back to summary
private final boolean recordRequestStartTime

requestState	back to summary
private volatile int requestState Annotations @SuppressWarnings:unused

requestStateUpdater	back to summary
private static final AtomicIntegerFieldUpdater<HttpReadListener> requestStateUpdater

requireHostHeader	back to summary
private final boolean requireHostHeader

state	back to summary
private final ParseState state

Constructor Detail

HttpReadListener	back to summary
pack-priv HttpReadListener(final HttpServerConnection connection, final HttpRequestParser parser, ConnectorStatisticsImpl connectorStatistics)

Method Detail

doHttp2PriRead	back to summary
private boolean doHttp2PriRead(StreamConnection connection, ByteBuffer buffer, HttpServerConnection serverConnection, PooledByteBuffer extraData) throws IOException

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

handleEvent

back to summary

public void handleEvent(final ConduitStreamSourceChannel channel)

Implements org.xnio.ChannelListener.handleEvent.

Doc from org.xnio.ChannelListener.handleEvent.

Handle the event on this channel.

Parameters

channel:ConduitStreamSourceChannel: the channel event

handleEventWithNoRunningRequest	back to summary
public void handleEventWithNoRunningRequest(final ConduitStreamSourceChannel channel)

handleFailedRead	back to summary
private void handleFailedRead(ConduitStreamSourceChannel channel, int res)

handleHttp2PriorKnowledge	back to summary
private boolean handleHttp2PriorKnowledge(PooledByteBuffer pooled, HttpServerExchange httpServerExchange) throws IOException

handleHttp2PriorKnowledge	back to summary
private void handleHttp2PriorKnowledge(final StreamConnection connection, final HttpServerConnection serverConnection, PooledByteBuffer readData) throws IOException

isUpgradeOrConnect	back to summary
private boolean isUpgradeOrConnect(HttpServerExchange exchange)

newRequest	back to summary
public void newRequest()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

sendBadRequestAndClose	back to summary
private void sendBadRequestAndClose(final StreamConnection connection, final Throwable exception)