protected static class Http11NioProtocol.Http11ConnectionHandler extends AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor> implements NioEndpoint.Handler
AbstractEndpoint.Handler.SocketState
Modifier and Type | Field and Description |
---|---|
protected Http11NioProtocol |
proto |
connections, global, recycledProcessors, registerCount
Modifier and Type | Method and Description |
---|---|
Http11NioProcessor |
createProcessor() |
protected Processor<NioChannel> |
createUpgradeProcessor(SocketWrapper<NioChannel> socket,
java.nio.ByteBuffer leftoverInput,
UpgradeToken upgradeToken) |
protected Log |
getLog() |
protected AbstractProtocol<NioChannel> |
getProtocol() |
SSLImplementation |
getSslImplementation() |
protected void |
initSsl(SocketWrapper<NioChannel> socket,
Processor<NioChannel> processor) |
protected void |
longPoll(SocketWrapper<NioChannel> socket,
Processor<NioChannel> processor) |
void |
release(java.nio.channels.SocketChannel socket)
Expected to be used by the Poller to release resources on socket
close, errors etc.
|
void |
release(SocketWrapper<NioChannel> socket)
Expected to be used by the Poller to release resources on socket
close, errors etc.
|
void |
release(SocketWrapper<NioChannel> socket,
Processor<NioChannel> processor,
boolean isSocketClosing,
boolean addToPoller)
Expected to be used by the handler once the processor is no longer
required.
|
getGlobal, process, recycle, register, unregister
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
process
getGlobal, recycle
protected Http11NioProtocol proto
protected AbstractProtocol<NioChannel> getProtocol()
getProtocol
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
protected Log getLog()
getLog
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
public SSLImplementation getSslImplementation()
getSslImplementation
in interface NioEndpoint.Handler
public void release(java.nio.channels.SocketChannel socket)
release
in interface NioEndpoint.Handler
public void release(SocketWrapper<NioChannel> socket)
release
in interface NioEndpoint.Handler
public void release(SocketWrapper<NioChannel> socket, Processor<NioChannel> processor, boolean isSocketClosing, boolean addToPoller)
release
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
socket
- processor
- isSocketClosing
- Not used in HTTPaddToPoller
- protected void initSsl(SocketWrapper<NioChannel> socket, Processor<NioChannel> processor)
initSsl
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
protected void longPoll(SocketWrapper<NioChannel> socket, Processor<NioChannel> processor)
longPoll
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
public Http11NioProcessor createProcessor()
createProcessor
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
protected Processor<NioChannel> createUpgradeProcessor(SocketWrapper<NioChannel> socket, java.nio.ByteBuffer leftoverInput, UpgradeToken upgradeToken) throws java.io.IOException
createUpgradeProcessor
in class AbstractProtocol.AbstractConnectionHandler<NioChannel,Http11NioProcessor>
java.io.IOException
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.