com.gigaspaces.lrmi.nio.filters

Class IOInternalFilterManager

java.lang.Object

com.gigaspaces.lrmi.nio.filters.IOInternalFilterManager

All Implemented Interfaces:

IOFilterManager

public class IOInternalFilterManager
extends Object
implements IOFilterManager

Since:

9.5

Author:

Dan Kilman

Constructor Summary

Constructors

Constructor and Description
IOInternalFilterManager(Reader reader, Writer writer, IOInternalFilter filter)

Method Summary

Modifier and Type	Method and Description
void	beginHandshake()
byte[]	handleBlockingContant(byte[] buffer, int slowConsumerTimeout)
byte[]	handleNoneBlockingContant(Reader.Context ctx, byte[] bytes)
void	writeBytesBlocking(ByteBuffer dataBuffer)
void	writeBytesNonBlocking(Writer.Context ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

IOInternalFilterManager

public IOInternalFilterManager(Reader reader,
                               Writer writer,
                               IOInternalFilter filter)

Method Detail

writeBytesNonBlocking

public void writeBytesNonBlocking(Writer.Context ctx)
                           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[] buffer,
                                    int slowConsumerTimeout)
                             throws ClosedChannelException,
                                    IOException,
                                    IOFilterException

Specified by:

handleBlockingContant in interface IOFilterManager

Throws:

ClosedChannelException

IOException

IOFilterException

writeBytesBlocking

public void writeBytesBlocking(ByteBuffer dataBuffer)
                        throws ClosedChannelException,
                               SlowConsumerException,
                               IOException,
                               IOFilterException

Specified by:

writeBytesBlocking in interface IOFilterManager

Throws:

ClosedChannelException

SlowConsumerException

IOException

IOFilterException

beginHandshake

public void beginHandshake()
                    throws IOFilterException,
                           IOException

Specified by:

beginHandshake in interface IOFilterManager

Throws:

IOFilterException

IOException