Top Fields Constructors Methods
io.undertow.protocols.ajp

public Class AjpClientResponseStreamSourceChannel

extends AbstractAjpClientStreamSourceChannel
Class Inheritance
Imports
java.io.IOException, org.xnio.ChannelListener, io.undertow.connector.PooledByteBuffer, io.undertow.server.protocol.framed.FrameHeaderData, io.undertow.util.HeaderMap
Author
Stuart Douglas

Field Summary

Modifier and TypeField and Description
private ChannelListener<AjpClientResponseStreamSourceChannel>
finishListener

private final HeaderMap
headers

private final String
reasonPhrase

private final int
statusCode

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
protected void
complete()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.complete.

Method that is invoked when all data has been read.

public HeaderMap
getHeaders()

public String
getReasonPhrase()

public int
getStatusCode()

protected void
handleHeaderData(FrameHeaderData headerData)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleHeaderData.

public void
resumeReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReads.

Implements org.xnio.channels.SuspendableReadChannel.resumeReads.

Resume reads on this channel.

public void
setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)

public void
suspendReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.suspendReads.

Implements org.xnio.channels.SuspendableReadChannel.suspendReads.

Suspend further read notifications on this channel.

protected long
updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.updateFrameDataRemaining.

public void
wakeupReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.wakeupReads.

Implements org.xnio.channels.SuspendableReadChannel.wakeupReads.

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

Field Detail

finishListenerback to summary
private ChannelListener<AjpClientResponseStreamSourceChannel> finishListener
headersback to summary
private final HeaderMap headers
reasonPhraseback to summary
private final String reasonPhrase
statusCodeback to summary
private final int statusCode

Constructor Detail

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

Method Detail

completeback to summary
protected void complete() throws IOException

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.complete.

Doc from io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.complete.

Method that is invoked when all data has been read.

Annotations
@Override
getHeadersback to summary
public HeaderMap getHeaders()
getReasonPhraseback to summary
public String getReasonPhrase()
getStatusCodeback to summary
public int getStatusCode()
handleHeaderDataback to summary
protected void handleHeaderData(FrameHeaderData headerData)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.handleHeaderData.

Annotations
@Override
resumeReadsback to summary
public void resumeReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.resumeReads.

Implements org.xnio.channels.SuspendableReadChannel.resumeReads.

Doc from org.xnio.channels.SuspendableReadChannel.resumeReads.

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

Annotations
@Override
setFinishListenerback to summary
public void setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener)
suspendReadsback to summary
public void suspendReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.suspendReads.

Implements org.xnio.channels.SuspendableReadChannel.suspendReads.

Doc from org.xnio.channels.SuspendableReadChannel.suspendReads.

Suspend further read notifications on this channel.

Annotations
@Override
updateFrameDataRemainingback to summary
protected long updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining)

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.updateFrameDataRemaining.

Annotations
@Override
wakeupReadsback to summary
public void wakeupReads()

Overrides io.undertow.server.protocol.framed.AbstractFramedStreamSourceChannel.wakeupReads.

Implements org.xnio.channels.SuspendableReadChannel.wakeupReads.

Doc from org.xnio.channels.SuspendableReadChannel.wakeupReads.

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

Annotations
@Override