com.gigaspaces.internal.io

Class CompressedMarshObjectConvertor

java.lang.Object

com.j_spaces.kernel.pool.Resource

com.gigaspaces.internal.io.CompressedMarshObjectConvertor

All Implemented Interfaces:

IMarshObjectConvertor, MarshObjectConvertorResource, IMemoryAwareResource, IResource

public class CompressedMarshObjectConvertor
extends Resource
implements MarshObjectConvertorResource

Notice! this implementation is not Thread safe and should be use in conjunction with ResourcePool only.

Since:

4.1

Author:

Guy Korland

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	CompressedMarshObjectConvertor.CompressedMarshObjectConvertorFactory

Constructor Summary

Constructors

Constructor and Description
CompressedMarshObjectConvertor(int level)
CompressedMarshObjectConvertor(int level, IMemoryAwareResourcePool resourcePool)
CompressedMarshObjectConvertor(int level, IMemoryAwareResourcePool resourcePool, ObjectInputStreamFactory objectInputStreamFactory, boolean idempotent)

Method Summary

Modifier and Type	Method and Description
void	clear() Cleans the resource of its contents so it can be returned to the pool.
Object	fromBinary(byte[] data)
static IResourceFactory<CompressedMarshObjectConvertor>	getFactory()
protected ObjectInputStream	getObjectInputStream(InputStream is)
protected ObjectOutputStream	getObjectOutputStream(OutputStream is)
long	getUsedMemory()
protected byte[]	serializeToByteArray(Object o)
byte[]	toBinary(Object o)

Methods inherited from class com.j_spaces.kernel.pool.Resource

acquire, isAcquired, isFromPool, release, setAcquired, setFromPool

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.j_spaces.kernel.pool.IResource

acquire, isAcquired, isFromPool, release, setAcquired, setFromPool

Constructor Detail

CompressedMarshObjectConvertor

public CompressedMarshObjectConvertor(int level)

Parameters:

level - the compression level (0-9), The default setting is DEFAULT_COMPRESSION.

Throws:

IllegalArgumentException - if the compression level is invalid

CompressedMarshObjectConvertor

public CompressedMarshObjectConvertor(int level,
                                      IMemoryAwareResourcePool resourcePool)

CompressedMarshObjectConvertor

public CompressedMarshObjectConvertor(int level,
                                      IMemoryAwareResourcePool resourcePool,
                                      ObjectInputStreamFactory objectInputStreamFactory,
                                      boolean idempotent)

Method Detail

serializeToByteArray

protected byte[] serializeToByteArray(Object o)
                               throws IOException

Throws:

IOException

toBinary

public byte[] toBinary(Object o)
                throws IOException

Specified by:

toBinary in interface IMarshObjectConvertor

Throws:

IOException

fromBinary

public Object fromBinary(byte[] data)
                  throws IOException,
                         ClassNotFoundException

Specified by:

fromBinary in interface IMarshObjectConvertor

Throws:

IOException

ClassNotFoundException

getObjectOutputStream

protected ObjectOutputStream getObjectOutputStream(OutputStream is)
                                            throws IOException

Throws:

IOException

getObjectInputStream

protected ObjectInputStream getObjectInputStream(InputStream is)
                                          throws IOException

Throws:

IOException

clear

public void clear()

Description copied from interface: IResource

Cleans the resource of its contents so it can be returned to the pool.

You may use the IResource.isFromPool() indication to decide of a special action before returning a resource to the pool, or discard any actions on resources not returning to the pool.

Specified by:

clear in interface IResource

Specified by:

clear in class Resource

See Also:

IResource.release()

getFactory

public static IResourceFactory<CompressedMarshObjectConvertor> getFactory()

getUsedMemory

public long getUsedMemory()

Specified by:

getUsedMemory in interface IMemoryAwareResource