Package io.undertow.protocols.ajp
Class AjpClientResponseStreamSourceChannel
java.lang.Object
io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
io.undertow.protocols.ajp.AbstractAjpClientStreamSourceChannel
io.undertow.protocols.ajp.AjpClientResponseStreamSourceChannel
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Channel
,InterruptibleChannel
,ReadableByteChannel
,ScatteringByteChannel
,org.xnio.channels.CloseableChannel
,org.xnio.channels.Configurable
,org.xnio.channels.StreamSourceChannel
,org.xnio.channels.SuspendableReadChannel
- Author:
- Stuart Douglas
-
Field Summary
Fields inherited from interface org.xnio.channels.Configurable
EMPTY
-
Constructor Summary
ConstructorsConstructorDescriptionAjpClientResponseStreamSourceChannel
(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, String reasonPhrase, PooledByteBuffer frameData, int remaining) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
complete()
Method that is invoked when all data has been read.int
protected void
handleHeaderData
(FrameHeaderData headerData) void
void
setFinishListener
(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener) void
protected long
updateFrameDataRemaining
(PooledByteBuffer frameData, long frameDataRemaining) void
Methods inherited from class io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel
addCloseTask, awaitReadable, awaitReadable, channelForciblyClosed, close, dataReady, getCloseSetter, getFramedChannel, getIoThread, getMaxStreamSize, getOption, getReadFrameCount, getReadSetter, getReadThread, getWorker, isComplete, isLastFrame, isOpen, isReadResumed, lastFrame, markStreamBroken, processFrameData, read, read, read, setMaxStreamSize, setOption, shutdownReads, supportsOption, transferTo, transferTo
-
Constructor Details
-
AjpClientResponseStreamSourceChannel
public AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, String reasonPhrase, PooledByteBuffer frameData, int remaining)
-
-
Method Details
-
getHeaders
-
getStatusCode
public int getStatusCode() -
getReasonPhrase
-
setFinishListener
public void setFinishListener(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener) -
handleHeaderData
-
updateFrameDataRemaining
-
complete
Description copied from class:AbstractFramedStreamSourceChannel
Method that is invoked when all data has been read. -
wakeupReads
public void wakeupReads()- Specified by:
wakeupReads
in interfaceorg.xnio.channels.SuspendableReadChannel
- Overrides:
wakeupReads
in classAbstractFramedStreamSourceChannel<AjpClientChannel,
AbstractAjpClientStreamSourceChannel, AbstractAjpClientStreamSinkChannel>
-
resumeReads
public void resumeReads()- Specified by:
resumeReads
in interfaceorg.xnio.channels.SuspendableReadChannel
- Overrides:
resumeReads
in classAbstractFramedStreamSourceChannel<AjpClientChannel,
AbstractAjpClientStreamSourceChannel, AbstractAjpClientStreamSinkChannel>
-
suspendReads
public void suspendReads()- Specified by:
suspendReads
in interfaceorg.xnio.channels.SuspendableReadChannel
- Overrides:
suspendReads
in classAbstractFramedStreamSourceChannel<AjpClientChannel,
AbstractAjpClientStreamSourceChannel, AbstractAjpClientStreamSinkChannel>
-