rabbit.httpio
Class WebConnectionResourceSource

java.lang.Object
  rabbit.httpio.WebConnectionResourceSource

All Implemented Interfaces:

ReadHandler, SocketChannelHandler, ChunkDataFeeder, ResourceSource, Transferable

public class WebConnectionResourceSource
extends java.lang.Object
implements ResourceSource, ReadHandler, ChunkDataFeeder

A resource source that gets the data from a WebConnection

Author:

Robert Olofsson

Constructor Summary

WebConnectionResourceSource(ConnectionHandler con, NioHandler nioHandler, WebConnection wc, BufferHandle bufHandle, TrafficLogger tl, boolean isChunked, long dataSize, boolean strictHttp)
Create a new ConnectionResourceSource that gets the data from the network.

Method Summary

void	addBlockListener(BlockListener listener) Add a ByteBuffer listener.
void	closed()
void	finishedRead() Chunk reading has been completed.
java.lang.String	getDescription()
java.lang.Long	getTimeout()
long	length() Get the length of the resource in bytes.
void	read()
void	readMore() The chunk reader needs to read more data, compact buffer before registering.
void	register() The chunk reader needs more data.
void	release() Release any held resources.
boolean	supportsTransfer() FileChannels can not be used, will always return false.
void	timeout()
long	transferTo(long position, long count, java.nio.channels.WritableByteChannel target) Transfers bytes from this channel's file to the given writable byte channel.
boolean	useSeparateThread()

Methods inherited from class java.lang.Object

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

Constructor Detail

WebConnectionResourceSource

public WebConnectionResourceSource(ConnectionHandler con,
                                   NioHandler nioHandler,
                                   WebConnection wc,
                                   BufferHandle bufHandle,
                                   TrafficLogger tl,
                                   boolean isChunked,
                                   long dataSize,
                                   boolean strictHttp)

Create a new ConnectionResourceSource that gets the data from the network.

Parameters:

con - the Connection handling the request

nioHandler - the NioHandler to use for network and background tasks

wc - the WebConection connected to the upstream server

bufHandle - the BufferHandle to use

tl - the TrafficLogger to use for network statistics

isChunked - flag indicating if the upstream data is chunked or not

dataSize - the size of the data, may be -1 if size is unknown

strictHttp - if true strict http will be used when communcating with the upstream server

Method Detail

getDescription

public java.lang.String getDescription()

Specified by:

getDescription in interface SocketChannelHandler

supportsTransfer

public boolean supportsTransfer()

FileChannels can not be used, will always return false.

Specified by:

supportsTransfer in interface ResourceSource

Returns:

false

length

public long length()

Description copied from interface: Transferable

Get the length of the resource in bytes.

Specified by:

length in interface Transferable

Returns:

the size of the resource or -1 if unknown.

transferTo

public long transferTo(long position,
                       long count,
                       java.nio.channels.WritableByteChannel target)
                throws java.io.IOException

Description copied from interface: Transferable

Transfers bytes from this channel's file to the given writable byte channel.

Specified by:

transferTo in interface Transferable

Parameters:

position - The position within the file at which the transfer is to begin; must be non-negative

count - The maximum number of bytes to be transferred; must be non-negative

target - The target channel

Returns:

The number of bytes, possibly zero, that were actually transferred

Throws:

java.io.IOException - if data transfer fails

See Also:

transferTo

addBlockListener

public void addBlockListener(BlockListener listener)

Description copied from interface: ResourceSource

Add a ByteBuffer listener.

Specified by:

addBlockListener in interface ResourceSource

Parameters:

listener - the listener that will get notified when data is available

finishedRead

public void finishedRead()

Description copied from interface: ChunkDataFeeder

Chunk reading has been completed.

Specified by:

finishedRead in interface ChunkDataFeeder

register

public void register()

Description copied from interface: ChunkDataFeeder

The chunk reader needs more data.

Specified by:

register in interface ChunkDataFeeder

readMore

public void readMore()

Description copied from interface: ChunkDataFeeder

The chunk reader needs to read more data, compact buffer before registering.

Specified by:

readMore in interface ChunkDataFeeder

read

public void read()

Specified by:

read in interface ReadHandler

useSeparateThread

public boolean useSeparateThread()

Specified by:

useSeparateThread in interface SocketChannelHandler

closed

public void closed()

Specified by:

closed in interface SocketChannelHandler

timeout

public void timeout()

Specified by:

timeout in interface SocketChannelHandler

getTimeout

public java.lang.Long getTimeout()

Specified by:

getTimeout in interface SocketChannelHandler

release

public void release()

Description copied from interface: ResourceSource

Release any held resources.

Specified by:

release in interface ResourceSource