protected static class AjpProtocol.AjpConnectionHandler extends java.lang.Object implements JIoEndpoint.Handler
JIoEndpoint.Handler.SocketState
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.net.Socket,AjpProcessor> |
connections |
protected RequestGroupInfo |
global |
protected AjpProtocol |
proto |
protected java.util.concurrent.ConcurrentLinkedQueue<AjpProcessor> |
recycledProcessors |
protected java.util.concurrent.atomic.AtomicLong |
registerCount |
Constructor and Description |
---|
AjpProtocol.AjpConnectionHandler(AjpProtocol proto) |
Modifier and Type | Method and Description |
---|---|
protected AjpProcessor |
createProcessor() |
JIoEndpoint.Handler.SocketState |
event(java.net.Socket socket,
SocketStatus status) |
JIoEndpoint.Handler.SocketState |
process(java.net.Socket socket) |
protected void |
register(AjpProcessor processor) |
protected void |
unregister(AjpProcessor processor) |
protected AjpProtocol proto
protected java.util.concurrent.atomic.AtomicLong registerCount
protected RequestGroupInfo global
protected java.util.concurrent.ConcurrentHashMap<java.net.Socket,AjpProcessor> connections
protected java.util.concurrent.ConcurrentLinkedQueue<AjpProcessor> recycledProcessors
public AjpProtocol.AjpConnectionHandler(AjpProtocol proto)
public JIoEndpoint.Handler.SocketState event(java.net.Socket socket, SocketStatus status)
event
in interface JIoEndpoint.Handler
public JIoEndpoint.Handler.SocketState process(java.net.Socket socket)
process
in interface JIoEndpoint.Handler
protected AjpProcessor createProcessor()
protected void register(AjpProcessor processor)
protected void unregister(AjpProcessor processor)