com.gigaspaces.lrmi.nio.filters

Class IOBlockFilterContainer

java.lang.Object

com.gigaspaces.lrmi.nio.filters.IOBlockFilterContainer

public class IOBlockFilterContainer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static byte	MESSAGE_SUFFIX
static byte	PREFIX_PART

Constructor Summary

Constructors

Constructor and Description
IOBlockFilterContainer(Reader reader, IChannelWriter writer)

Method Summary

Modifier and Type	Method and Description
void	beginHandshake(IOFilterContext filterContext)
IOFilterContext	createContext(IOBlockFilter filter)
byte[]	handleBlockingContant(byte[] bytes, IOFilterContext filterContext, int slowConsumerTimeout)
byte[]	handleNoneBlockingContent(Reader.Context ctx, byte[] bytes, IOFilterContext filterContext)
static byte[]	toBytes(ByteBuffer buf)
static List<Byte>	toList(byte[] array)
void	unwrap(IOFilterContext context)
void	wrap(IOFilterContext context)
void	writeBytesBlocking(ByteBuffer dataBuffer, IOFilterContext filterContext)
void	writeBytesNonBlocking(Writer.Context ctx, IOFilterContext filterContext)

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_SUFFIX

public static final byte MESSAGE_SUFFIX

See Also:

Constant Field Values

PREFIX_PART

public static final byte PREFIX_PART

See Also:

Constant Field Values

Constructor Detail

IOBlockFilterContainer

public IOBlockFilterContainer(Reader reader,
                              IChannelWriter writer)

Method Detail

wrap

public void wrap(IOFilterContext context)
          throws IOFilterException

Throws:

IOFilterException

unwrap

public void unwrap(IOFilterContext context)
            throws IOFilterException

Throws:

IOFilterException

createContext

public IOFilterContext createContext(IOBlockFilter filter)

writeBytesNonBlocking

public void writeBytesNonBlocking(Writer.Context ctx,
                                  IOFilterContext filterContext)
                           throws IOFilterException,
                                  IOException

Throws:

IOFilterException

IOException

handleNoneBlockingContent

public byte[] handleNoneBlockingContent(Reader.Context ctx,
                                        byte[] bytes,
                                        IOFilterContext filterContext)
                                 throws IOFilterException

Throws:

IOFilterException

handleBlockingContant

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

Throws:

ClosedChannelException

IOFilterException

writeBytesBlocking

public void writeBytesBlocking(ByteBuffer dataBuffer,
                               IOFilterContext filterContext)
                        throws IOFilterException,
                               IOException

Throws:

IOFilterException

IOException

beginHandshake

public void beginHandshake(IOFilterContext filterContext)
                    throws IOFilterException,
                           IOException

Throws:

IOFilterException

IOException

toBytes

public static byte[] toBytes(ByteBuffer buf)

toList

public static List<Byte> toList(byte[] array)