com.gigaspaces.lrmi.nio.filters

Class IOBlockFilterManager

java.lang.Object

com.gigaspaces.lrmi.nio.filters.IOBlockFilterManager

All Implemented Interfaces:

IOFilterManager

public class IOBlockFilterManager
extends Object
implements IOFilterManager

Constructor Summary

Constructors

Constructor and Description
IOBlockFilterManager(Reader reader, IChannelWriter writer, IOBlockFilter filter)

Method Summary

Modifier and Type	Method and Description
void	beginHandshake()
static IOFilterManager	createFilter(Reader reader, Writer writer, boolean mode, SocketChannel channel)
static IOFilterFactory	getFilterFactory()
byte[]	handleBlockingContant(byte[] bytes, int slowConsumerTimeout)
byte[]	handleNoneBlockingContant(Reader.Context ctx, byte[] bytes)
static void	setFilterFactory(IOFilterFactory _filterFactory)
void	writeBytesBlocking(ByteBuffer dataBuffer)
void	writeBytesNonBlocking(Writer.Context writeContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

IOBlockFilterManager

public IOBlockFilterManager(Reader reader,
                            IChannelWriter writer,
                            IOBlockFilter filter)

Method Detail

writeBytesNonBlocking

public void writeBytesNonBlocking(Writer.Context writeContext)
                           throws IOException,
                                  IOFilterException

Specified by:

writeBytesNonBlocking in interface IOFilterManager

Throws:

IOException

IOFilterException

handleNoneBlockingContant

public byte[] handleNoneBlockingContant(Reader.Context ctx,
                                        byte[] bytes)
                                 throws IOException,
                                        IOFilterException

Specified by:

handleNoneBlockingContant in interface IOFilterManager

Throws:

IOException

IOFilterException

handleBlockingContant

public byte[] handleBlockingContant(byte[] bytes,
                                    int slowConsumerTimeout)
                             throws ClosedChannelException,
                                    IOException,
                                    IOFilterException

Specified by:

handleBlockingContant in interface IOFilterManager

Throws:

ClosedChannelException

IOException

IOFilterException

writeBytesBlocking

public void writeBytesBlocking(ByteBuffer dataBuffer)
                        throws IOException,
                               IOFilterException

Specified by:

writeBytesBlocking in interface IOFilterManager

Throws:

IOException

IOFilterException

createFilter

public static IOFilterManager createFilter(Reader reader,
                                           Writer writer,
                                           boolean mode,
                                           SocketChannel channel)
                                    throws Exception

Throws:

Exception

beginHandshake

public void beginHandshake()
                    throws IOFilterException,
                           IOException

Specified by:

beginHandshake in interface IOFilterManager

Throws:

IOFilterException

IOException

setFilterFactory

public static void setFilterFactory(IOFilterFactory _filterFactory)

getFilterFactory

public static IOFilterFactory getFilterFactory()