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, CloseableChannel, Configurable, StreamSourceChannel, SuspendableReadChannel

public class AjpClientResponseStreamSourceChannel
extends AbstractAjpClientStreamSourceChannel

Author:

Stuart Douglas

Field Summary

Fields inherited from interface org.xnio.channels.Configurable

EMPTY

Constructor Summary

Constructors

Constructor and Description
AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, String reasonPhrase, PooledByteBuffer frameData, int remaining)

Method Summary

Modifier and Type	Method and Description
protected void	complete() Method that is invoked when all data has been read.
HeaderMap	getHeaders()
String	getReasonPhrase()
int	getStatusCode()
protected void	handleHeaderData(FrameHeaderData headerData)
void	resumeReads() Resume reads on this channel.
void	setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
void	suspendReads() Suspend further read notifications on this channel.
protected long	updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)
void	wakeupReads() Resume reads on this channel, and force the read listener to be triggered even if the channel isn't actually readable.

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AjpClientResponseStreamSourceChannel

public AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel,
                                            HeaderMap headers,
                                            int statusCode,
                                            String reasonPhrase,
                                            PooledByteBuffer frameData,
                                            int remaining)

Method Detail

getHeaders

public HeaderMap getHeaders()

getStatusCode

public int getStatusCode()

getReasonPhrase

public String getReasonPhrase()

setFinishListener

public void setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)

handleHeaderData

protected void handleHeaderData(FrameHeaderData headerData)

Overrides:

handleHeaderData in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>

updateFrameDataRemaining

protected long updateFrameDataRemaining(PooledByteBuffer frameData,
                                        long frameDataRemaining)

Overrides:

updateFrameDataRemaining in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>

complete

protected void complete()
                 throws IOException

Description copied from class: AbstractFramedStreamSourceChannel

Method that is invoked when all data has been read.

Overrides:

complete in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>

Throws:

IOException

wakeupReads

public void wakeupReads()

Description copied from interface: SuspendableReadChannel

Resume reads on this channel, and force the read listener to be triggered even if the channel isn't actually readable.

Specified by:

wakeupReads in interface SuspendableReadChannel

Overrides:

wakeupReads in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>

resumeReads

public void resumeReads()

Description copied from interface: SuspendableReadChannel

Resume reads on this channel. The read listener will be called as soon as there is data available to be read.

Specified by:

resumeReads in interface SuspendableReadChannel

Overrides:

resumeReads in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>

suspendReads

public void suspendReads()

Description copied from interface: SuspendableReadChannel

Suspend further read notifications on this channel.

Specified by:

suspendReads in interface SuspendableReadChannel

Overrides:

suspendReads in class AbstractFramedStreamSourceChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>