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:
java.io.Closeable
,java.lang.AutoCloseable
,java.nio.channels.Channel
,java.nio.channels.InterruptibleChannel
,java.nio.channels.ReadableByteChannel
,java.nio.channels.ScatteringByteChannel
,org.xnio.channels.CloseableChannel
,org.xnio.channels.Configurable
,org.xnio.channels.StreamSourceChannel
,org.xnio.channels.SuspendableReadChannel
public class AjpClientResponseStreamSourceChannel extends AbstractAjpClientStreamSourceChannel
- Author:
- Stuart Douglas
-
-
Constructor Summary
Constructors Constructor Description AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, java.lang.String reasonPhrase, PooledByteBuffer frameData, int remaining)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
complete()
Method that is invoked when all data has been read.HeaderMap
getHeaders()
java.lang.String
getReasonPhrase()
int
getStatusCode()
protected void
handleHeaderData(FrameHeaderData headerData)
void
resumeReads()
void
setFinishListener(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
void
suspendReads()
protected long
updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
void
wakeupReads()
-
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 Detail
-
AjpClientResponseStreamSourceChannel
public AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, java.lang.String reasonPhrase, PooledByteBuffer frameData, int remaining)
-
-
Method Detail
-
getHeaders
public HeaderMap getHeaders()
-
getStatusCode
public int getStatusCode()
-
getReasonPhrase
public java.lang.String getReasonPhrase()
-
setFinishListener
public void setFinishListener(org.xnio.ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
-
handleHeaderData
protected void handleHeaderData(FrameHeaderData headerData)
-
updateFrameDataRemaining
protected long updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
-
complete
protected void complete() throws java.io.IOException
Description copied from class:AbstractFramedStreamSourceChannel
Method that is invoked when all data has been read.- Overrides:
complete
in classAbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
- Throws:
java.io.IOException
-
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>
-
-