| Modifier and Type | Class and Description |
|---|---|
| pack-priv class | |
| pack-priv class | |
| pack-priv class | |
| pack-priv class | |
| pack-priv class |
| Modifier and Type | Field and Description |
|---|---|
| private final AjpResponseParser | |
| private boolean | |
| private boolean | |
| private final List | |
| private AjpClientRequestClientStreamSinkChannel | |
| pack-priv boolean | |
| private AjpClientResponseStreamSourceChannel | |
| pack-priv boolean |
| Access | Constructor and Description |
|---|---|
| public | AjpClientChannel(StreamConnection
The connectedStreamChannel, ByteBufferPool org. over which the WebSocket Frames should get send and received.
Be aware that it already must be "upgraded".The bufferPool, OptionMap settings)org. which will be used to acquire java.'s from.Create a new |
| Modifier and Type | Method and Description |
|---|---|
| protected void | closeSubChannels()
Implements abstract io. Method that is called when the channel is being forcibly closed, and all sub stream sink/source channels should also be forcibly closed. |
| protected AbstractAjpClientStreamSourceChannel | createChannel(FrameHeaderData
The header data, as returned by frameHeaderData, PooledByteBuffer parseFrame(java.Any additional data for the frame that has already been read. This may not be the complete frame contents frameData)Implements abstract io. Method that creates the actual stream source channel implementation that is in use. |
| protected Collection | getReceivers()
Implements abstract io.
|
| protected OptionMap | |
| protected void | handleBrokenSinkChannel(Throwable e)
Implements abstract io. Method that is invoked when then write side of a channel is broken. |
| protected void | handleBrokenSourceChannel(Throwable e)
Implements abstract io. Method that is invoked when the read side of the channel is broken. |
| protected boolean | isLastFrameReceived()
Implements abstract io. Returns true if the protocol specific final frame has been received. |
| protected boolean | isLastFrameSent()
Implements abstract io.
|
| public boolean | isOpen()
Overrides io. Implements java. Tells whether or not this channel is open. |
| protected void | lastDataRead()
Overrides io. Method than is invoked when read() returns -1. |
| protected FrameHeaderData | parseFrame(ByteBuffer
The data that has been read from the channel data)Implements abstract io. Attempts to parse an incoming frame header from the data in the buffer. |
| protected synchronized void | |
| public void | |
| public AjpClientRequestClientStreamSinkChannel | sendRequest(final HttpString method, final String path, final HttpString protocol, final HeaderMap headers, final Attachable attachable, ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener)
|
| pack-priv void | |
| pack-priv void |
| ajpParser | back to summary |
|---|---|
| private final AjpResponseParser ajpParser | |
| lastFrameReceived | back to summary |
|---|---|
| private boolean lastFrameReceived | |
| lastFrameSent | back to summary |
|---|---|
| private boolean lastFrameSent | |
| pingListeners | back to summary |
|---|---|
| private final List<ClientConnection. | |
| sink | back to summary |
|---|---|
| private AjpClientRequestClientStreamSinkChannel sink | |
| sinkDone | back to summary |
|---|---|
| pack-priv boolean sinkDone | |
| source | back to summary |
|---|---|
| private AjpClientResponseStreamSourceChannel source | |
| sourceDone | back to summary |
|---|---|
| pack-priv boolean sourceDone | |
| AjpClientChannel | back to summary |
|---|---|
| public AjpClientChannel(StreamConnection connectedStreamChannel, ByteBufferPool bufferPool, OptionMap settings) Create a new
| |
| closeSubChannels | back to summary |
|---|---|
| protected void closeSubChannels() Implements abstract io. Doc from io. Method that is called when the channel is being forcibly closed, and all sub stream sink/source channels should also be forcibly closed.
| |
| createChannel | back to summary |
|---|---|
| protected AbstractAjpClientStreamSourceChannel createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) throws IOException Implements abstract io. Doc from io. Method that creates the actual stream source channel implementation that is in use.
| |
| getReceivers | back to summary |
|---|---|
| protected Collection Implements abstract io.
| |
| getSettings | back to summary |
|---|---|
| protected OptionMap getSettings() Overrides io. | |
| handleBrokenSinkChannel | back to summary |
|---|---|
| protected void handleBrokenSinkChannel(Throwable e) Implements abstract io. Doc from io. Method that is invoked when then write side of a channel is broken. This generally happens on a protocol error.
| |
| handleBrokenSourceChannel | back to summary |
|---|---|
| protected void handleBrokenSourceChannel(Throwable e) Implements abstract io. Doc from io. Method that is invoked when the read side of the channel is broken. This generally happens on a protocol error.
| |
| isLastFrameReceived | back to summary |
|---|---|
| protected boolean isLastFrameReceived() Implements abstract io. Doc from io. Returns true if the protocol specific final frame has been received.
| |
| isLastFrameSent | back to summary |
|---|---|
| protected boolean isLastFrameSent() Implements abstract io.
| |
| isOpen | back to summary |
|---|---|
| public boolean isOpen() Overrides io. Implements java. Doc from java. Tells whether or not this channel is open.
| |
| lastDataRead | back to summary |
|---|---|
| protected void lastDataRead() Overrides io. Doc from io. Method than is invoked when read() returns -1. | |
| parseFrame | back to summary |
|---|---|
| protected FrameHeaderData parseFrame(ByteBuffer data) throws IOException Implements abstract io. Doc from io. Attempts to parse an incoming frame header from the data in the buffer.
| |
| recalculateHeldFrames | back to summary |
|---|---|
| protected synchronized void recalculateHeldFrames() throws IOException Overrides io.
| |
| sendPing | back to summary |
|---|---|
| public void sendPing(ClientConnection. | |
| sendRequest | back to summary |
|---|---|
| public AjpClientRequestClientStreamSinkChannel sendRequest(final HttpString method, final String path, final HttpString protocol, final HeaderMap headers, final Attachable attachable, ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener) | |
| sinkDone | back to summary |
|---|---|
| pack-priv void sinkDone() | |
| sourceDone | back to summary |
|---|---|
| pack-priv void sourceDone() | |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public AbstractFramedStreamSourceChannel | |
| public long |
| CpongResponse | back to summary |
|---|---|
| pack-priv CpongResponse() | |
| getExistingChannel | back to summary |
|---|---|
| public AbstractFramedStreamSourceChannel Implements io.
| |
| getFrameLength | back to summary |
|---|---|
| public long getFrameLength() Implements io.
| |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public AbstractFramedStreamSourceChannel | |
| public long |
| EndResponse | back to summary |
|---|---|
| pack-priv EndResponse() | |
| getExistingChannel | back to summary |
|---|---|
| public AbstractFramedStreamSourceChannel Implements io.
| |
| getFrameLength | back to summary |
|---|---|
| public long getFrameLength() Implements io.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public AbstractFramedStreamSourceChannel | |
| public long | |
| public int |
| length | back to summary |
|---|---|
| private final int length | |
| RequestBodyChunk | back to summary |
|---|---|
| pack-priv RequestBodyChunk(int length) | |
| getExistingChannel | back to summary |
|---|---|
| public AbstractFramedStreamSourceChannel Implements io.
| |
| getFrameLength | back to summary |
|---|---|
| public long getFrameLength() Implements io.
| |
| getLength | back to summary |
|---|---|
| public int getLength() | |
| Modifier and Type | Field and Description |
|---|---|
| private final int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public AbstractFramedStreamSourceChannel | |
| public long |
| length | back to summary |
|---|---|
| private final int length | |
| SendBodyChunk | back to summary |
|---|---|
| pack-priv SendBodyChunk(int length) | |
| getExistingChannel | back to summary |
|---|---|
| public AbstractFramedStreamSourceChannel Implements io.
| |
| getFrameLength | back to summary |
|---|---|
| public long getFrameLength() Implements io.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final HeaderMap | |
| private final String | |
| private final int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public AbstractFramedStreamSourceChannel | |
| public long |
| headers | back to summary |
|---|---|
| private final HeaderMap headers | |
| reasonPhrase | back to summary |
|---|---|
| private final String reasonPhrase | |
| statusCode | back to summary |
|---|---|
| private final int statusCode | |
| SendHeadersResponse | back to summary |
|---|---|
| pack-priv SendHeadersResponse(int statusCode, String reasonPhrase, HeaderMap headers) | |
| getExistingChannel | back to summary |
|---|---|
| public AbstractFramedStreamSourceChannel Implements io.
| |
| getFrameLength | back to summary |
|---|---|
| public long getFrameLength() Implements io.
| |