| Modifier and Type | Class and Description |
|---|---|
| private class | |
| public static class |
| Modifier and Type | Field and Description |
|---|---|
| protected final ByteBufferPool | |
| private final int | |
| protected final StreamConnection | |
| protected final List | |
| protected final AbstractServerConnection. | |
| protected HttpServerExchange | |
| protected PooledByteBuffer | extraBytes
Any extra bytes that were read from the channel. |
| protected final StreamSinkConduit | |
| protected final StreamSourceConduit | |
| private XnioBufferPoolAdaptor | poolAdaptor
References Deprecated
XnioBufferPoolAdaptor is deprecated or references (maybe indirectly) at least one deprecated element.
|
| protected final HttpHandler | |
| protected final OptionMap |
| Access | Constructor and Description |
|---|---|
| public | AbstractServerConnection(StreamConnection channel, final ByteBufferPool bufferPool, final HttpHandler rootHandler, final OptionMap undertowOptions, final int bufferSize)
|
| Modifier and Type | Method and Description |
|---|---|
| public void | addCloseListener(ServerConnection.
The close listener listenerImplements abstract io. Adds a close listener, than will be invoked with the connection is closed |
| public void | clearChannel()
Resets the channel to its original state, effectively disabling all current conduit wrappers. |
| public void | close()
Implements abstract io. Implements org. Close this channel. |
| public Pool | getBufferPool()
Implements abstract io.
References Deprecated
Pool is deprecated or references (maybe indirectly) at least one deprecated element.
|
| public int | Returns: The size of the buffers allocated by the buffer poolImplements abstract io.
|
| public ByteBufferPool | Returns: the buffer pool for this connectionImplements abstract io. Get the buffer pool for this connection. |
| public StreamConnection | |
| public ChannelListener. | getCloseSetter()
Implements org. Get the setter which can be used to change the close listener for this channel. |
| public PooledByteBuffer | |
| public XnioIoThread | getIoThread()
Implements abstract io. Implements org. Get the I/O thread associated with this channel. |
| public SocketAddress | getLocalAddress()
Implements abstract io. Implements org. Get the local address that this channel is bound to. |
| public <A extends SocketAddress> A | getLocalAddress(final Class<A>
the address type class type)Implements abstract io. Implements org. Get the local address of a given type, or |
| public <T> T | getOption(final Option<T>
the option to get option)Implements abstract io. Implements org. Get the value of a channel option. |
| public StreamSinkConduit | |
| public StreamSourceConduit | |
| public SocketAddress | getPeerAddress()
Implements abstract io. Implements org. Returns the actual address of the remote connection. |
| public <A extends SocketAddress> A | getPeerAddress(final Class<A>
The type of address to return type)Implements abstract io. Implements org. Returns the actual address of the remote connection. |
| public HttpHandler | Returns: the root HTTP handler for this connectionGet the root HTTP handler for this connection. |
| protected ConduitStreamSinkChannel | |
| protected ConduitStreamSourceChannel | |
| public OptionMap | |
| public XnioWorker | getWorker()
Implements abstract io. Implements org. Get the worker for this channel. |
| public boolean | isOpen()
Implements abstract io. Implements java. Tells whether or not this channel is open. |
| protected void | maxEntitySizeUpdated(HttpServerExchange
The current exchange exchange)Implements abstract io. Callback that is invoked if the max entity size is updated. |
| public AbstractServerConnection. | Returns: An opaque representation of the previous channel stateResets the channel to its original state, effectively disabling all current conduit wrappers. |
| public void | restoreChannel(final AbstractServerConnection.
The original state stateRestores the channel conduits to a previous state. |
| public void | |
| public <T> T | setOption(final Option<T>
the option to set option, final T the value of the option to set value)Implements abstract io. Implements org. Set an option for this channel. |
| protected void | setUpgradeListener(HttpUpgradeListener upgradeListener)
Implements abstract io.
|
| protected static StreamSinkConduit | |
| protected static StreamSourceConduit | |
| public boolean | supportsOption(final Option<?>
the option option)Implements abstract io. Implements org. Determine whether an option is supported on this channel. |
| bufferPool | back to summary |
|---|---|
| protected final ByteBufferPool bufferPool | |
| bufferSize | back to summary |
|---|---|
| private final int bufferSize | |
| channel | back to summary |
|---|---|
| protected final StreamConnection channel | |
| closeListeners | back to summary |
|---|---|
| protected final List<ServerConnection. | |
| closeSetter | back to summary |
|---|---|
| protected final AbstractServerConnection. | |
| current | back to summary |
|---|---|
| protected HttpServerExchange current | |
| extraBytes | back to summary |
|---|---|
| protected PooledByteBuffer extraBytes Any extra bytes that were read from the channel. This could be data for this requests, or the next response. | |
| originalSinkConduit | back to summary |
|---|---|
| protected final StreamSinkConduit originalSinkConduit | |
| originalSourceConduit | back to summary |
|---|---|
| protected final StreamSourceConduit originalSourceConduit | |
| poolAdaptor | back to summary |
|---|---|
| private XnioBufferPoolAdaptor poolAdaptor
References Deprecated
See corresponding docs for further information. | |
| rootHandler | back to summary |
|---|---|
| protected final HttpHandler rootHandler | |
| undertowOptions | back to summary |
|---|---|
| protected final OptionMap undertowOptions | |
| AbstractServerConnection | back to summary |
|---|---|
| public AbstractServerConnection(StreamConnection channel, final ByteBufferPool bufferPool, final HttpHandler rootHandler, final OptionMap undertowOptions, final int bufferSize) | |
| addCloseListener | back to summary |
|---|---|
| public void addCloseListener(ServerConnection. Implements abstract io. Doc from io. Adds a close listener, than will be invoked with the connection is closed
| |
| clearChannel | back to summary |
|---|---|
| public void clearChannel() Resets the channel to its original state, effectively disabling all current conduit wrappers. The current state is lost. | |
| close | back to summary |
|---|---|
| public void close() throws IOException Implements abstract io. Implements org. Doc from org. Close this channel. When a channel is closed, its close listener is invoked. Invoking this method more than once has no additional effect.
| |
| getBufferPool | back to summary |
|---|---|
| public Pool Implements abstract io. References Deprecated
See corresponding docs for further information.
| |
| getBufferSize | back to summary |
|---|---|
| public int getBufferSize() Implements abstract io.
| |
| getByteBufferPool | back to summary |
|---|---|
| public ByteBufferPool getByteBufferPool() Implements abstract io. Get the buffer pool for this connection.
| |
| getChannel | back to summary |
|---|---|
| public StreamConnection getChannel() Get the underlying channel.
| |
| getCloseSetter | back to summary |
|---|---|
| public ChannelListener. Implements org. Doc from org. Get the setter which can be used to change the close listener for this channel. If the channel is already closed, then the listener will not be called.
| |
| getExtraBytes | back to summary |
|---|---|
| public PooledByteBuffer getExtraBytes() | |
| getIoThread | back to summary |
|---|---|
| public XnioIoThread getIoThread() Implements abstract io. Implements org. Doc from org. Get the I/O thread associated with this channel.
| |
| getLocalAddress | back to summary |
|---|---|
| public SocketAddress getLocalAddress() Implements abstract io. Implements org. Doc from org. Get the local address that this channel is bound to.
| |
| getLocalAddress | back to summary |
|---|---|
| public <A extends SocketAddress> A getLocalAddress(final Class<A> type) Implements abstract io. Implements org. Doc from org. Get the local address of a given type, or | |
| getOption | back to summary |
|---|---|
| public <T> T getOption(final Option<T> option) throws IOException Implements abstract io. Implements org. Doc from org. Get the value of a channel option.
| |
| getOriginalSinkConduit | back to summary |
|---|---|
public StreamSinkConduit getOriginalSinkConduit()
| |
| getOriginalSourceConduit | back to summary |
|---|---|
public StreamSourceConduit getOriginalSourceConduit()
| |
| getPeerAddress | back to summary |
|---|---|
| public SocketAddress getPeerAddress() Implements abstract io. Implements org. Doc from io. Returns the actual address of the remote connection. This will not take things like X-Forwarded-for into account.
| |
| getPeerAddress | back to summary |
|---|---|
| public <A extends SocketAddress> A getPeerAddress(final Class<A> type) Implements abstract io. Implements org. Doc from io. Returns the actual address of the remote connection. This will not take things like X-Forwarded-for into account. | |
| getRootHandler | back to summary |
|---|---|
| public HttpHandler getRootHandler() Get the root HTTP handler for this connection.
| |
| getSinkChannel | back to summary |
|---|---|
| protected ConduitStreamSinkChannel getSinkChannel() Implements abstract io.
| |
| getSourceChannel | back to summary |
|---|---|
| protected ConduitStreamSourceChannel getSourceChannel() Implements abstract io.
| |
| getUndertowOptions | back to summary |
|---|---|
| public OptionMap getUndertowOptions() Implements abstract io.
| |
| getWorker | back to summary |
|---|---|
| public XnioWorker getWorker() Implements abstract io. Implements org. Doc from org. Get the worker for this channel.
| |
| isOpen | back to summary |
|---|---|
| public boolean isOpen() Implements abstract io. Implements java. Doc from java. Tells whether or not this channel is open.
| |
| maxEntitySizeUpdated | back to summary |
|---|---|
| protected void maxEntitySizeUpdated(HttpServerExchange exchange) Implements abstract io. Doc from io. Callback that is invoked if the max entity size is updated.
| |
| resetChannel | back to summary |
|---|---|
| public AbstractServerConnection. Resets the channel to its original state, effectively disabling all current conduit
wrappers. The current state is encapsulated inside a
| |
| restoreChannel | back to summary |
|---|---|
| public void restoreChannel(final AbstractServerConnection. Restores the channel conduits to a previous state.
| |
| setExtraBytes | back to summary |
|---|---|
| public void setExtraBytes(final PooledByteBuffer extraBytes) | |
| setOption | back to summary |
|---|---|
| public <T> T setOption(final Option<T> option, final T value) throws IllegalArgumentException, IOException Implements abstract io. Implements org. Doc from org. Set an option for this channel. Unsupported options are ignored.
| |
| setUpgradeListener | back to summary |
|---|---|
| protected void setUpgradeListener(HttpUpgradeListener upgradeListener) Implements abstract io. | |
| sink | back to summary |
|---|---|
| protected static StreamSinkConduit sink(AbstractServerConnection. | |
| source | back to summary |
|---|---|
| protected static StreamSourceConduit source(AbstractServerConnection. | |
| supportsOption | back to summary |
|---|---|
| public boolean supportsOption(final Option<?> option) Implements abstract io. Implements org. Doc from org. Determine whether an option is supported on this channel. | |
| Modifier and Type | Field and Description |
|---|---|
| private ChannelListener |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | handleEvent(StreamConnection
the channel event channel)Implements org. Handle the event on this channel. |
| public void | set(ChannelListener<? super ServerConnection>
the new listener listener)Implements org. Set the listener, or |
| listener | back to summary |
|---|---|
| private ChannelListener<? super ServerConnection> listener | |
| CloseSetter | back to summary |
|---|---|
| private CloseSetter() | |
| handleEvent | back to summary |
|---|---|
| public void handleEvent(StreamConnection channel) Implements org. Doc from org. Handle the event on this channel.
| |
| set | back to summary |
|---|---|
| public void set(ChannelListener<? super ServerConnection> listener) Implements org. Doc from org. Set the listener, or
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final StreamSinkConduit | |
| pack-priv final StreamSourceConduit |
| Access | Constructor and Description |
|---|---|
| private |
| sink | back to summary |
|---|---|
| pack-priv final StreamSinkConduit sink | |
| source | back to summary |
|---|---|
| pack-priv final StreamSourceConduit source | |
| ConduitState | back to summary |
|---|---|
| private ConduitState(final StreamSinkConduit sink, final StreamSourceConduit source) | |