protected static class Http11Nio2Protocol.Http11ConnectionHandler extends AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor> implements Nio2Endpoint.Handler
AbstractEndpoint.Handler.SocketState
Modifier and Type | Field and Description |
---|---|
protected Http11Nio2Protocol |
proto |
connections, global, recycledProcessors, registerCount
Modifier and Type | Method and Description |
---|---|
void |
closeAll() |
Http11Nio2Processor |
createProcessor() |
protected Processor<Nio2Channel> |
createUpgradeProcessor(SocketWrapper<Nio2Channel> socket,
HttpUpgradeHandler httpUpgradeProcessor) |
protected Log |
getLog() |
protected AbstractProtocol<Nio2Channel> |
getProtocol() |
SSLImplementation |
getSslImplementation() |
protected void |
initSsl(SocketWrapper<Nio2Channel> socket,
Processor<Nio2Channel> processor) |
protected void |
longPoll(SocketWrapper<Nio2Channel> socket,
Processor<Nio2Channel> processor) |
void |
onCreateSSLEngine(SSLEngine engine) |
AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<Nio2Channel> socket,
SocketStatus status) |
void |
release(SocketWrapper<Nio2Channel> socket)
Expected to be used by the Poller to release resources on socket
close, errors etc.
|
void |
release(SocketWrapper<Nio2Channel> socket,
Processor<Nio2Channel> processor,
boolean isSocketClosing,
boolean addToPoller)
Expected to be used by the handler once the processor is no longer
required.
|
getGlobal, recycle, register, unregister
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getGlobal, recycle
protected Http11Nio2Protocol proto
protected AbstractProtocol<Nio2Channel> getProtocol()
getProtocol
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
protected Log getLog()
getLog
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
public SSLImplementation getSslImplementation()
getSslImplementation
in interface Nio2Endpoint.Handler
public void release(SocketWrapper<Nio2Channel> socket)
release
in interface Nio2Endpoint.Handler
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<Nio2Channel> socket, SocketStatus status)
process
in interface Nio2Endpoint.Handler
process
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
public void release(SocketWrapper<Nio2Channel> socket, Processor<Nio2Channel> processor, boolean isSocketClosing, boolean addToPoller)
release
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
socket
- processor
- isSocketClosing
- Not used in HTTPaddToPoller
- protected void initSsl(SocketWrapper<Nio2Channel> socket, Processor<Nio2Channel> processor)
initSsl
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
protected void longPoll(SocketWrapper<Nio2Channel> socket, Processor<Nio2Channel> processor)
longPoll
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
public Http11Nio2Processor createProcessor()
createProcessor
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
protected Processor<Nio2Channel> createUpgradeProcessor(SocketWrapper<Nio2Channel> socket, HttpUpgradeHandler httpUpgradeProcessor) throws IOException
createUpgradeProcessor
in class AbstractProtocol.AbstractConnectionHandler<Nio2Channel,Http11Nio2Processor>
IOException
public void onCreateSSLEngine(SSLEngine engine)
onCreateSSLEngine
in interface Nio2Endpoint.Handler
public void closeAll()
closeAll
in interface Nio2Endpoint.Handler
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.