org.jboss.cache.marshall
Class CacheMarshaller200

java.lang.Object
  org.jboss.cache.marshall.AbstractMarshaller
      org.jboss.cache.marshall.CacheMarshaller200

All Implemented Interfaces:

Marshaller, org.jgroups.blocks.RpcDispatcher.Marshaller, org.jgroups.blocks.RpcDispatcher.Marshaller2

Direct Known Subclasses:

CacheMarshaller210

public class CacheMarshaller200
extends AbstractMarshaller

An enhanced marshaller for RPC calls between CacheImpl instances.

Author:

Manik Surtani (manik AT jboss DOT org)

Field Summary

protected CommandsFactory	commandsFactory
protected static InactiveRegionException	IRE
protected static int	MAGICNUMBER_ARRAY
protected static int	MAGICNUMBER_ARRAY_LIST
protected static int	MAGICNUMBER_BOOLEAN
protected static int	MAGICNUMBER_BYTE
protected static int	MAGICNUMBER_DEFAULT_DATA_VERSION
protected static int	MAGICNUMBER_DOUBLE
protected static int	MAGICNUMBER_EXTENDED_RESPONSE
protected static int	MAGICNUMBER_FASTCOPY_HASHMAP
protected static int	MAGICNUMBER_FLOAT
protected static int	MAGICNUMBER_FQN
protected static int	MAGICNUMBER_GRAVITATERESULT
protected static int	MAGICNUMBER_GTX
protected static int	MAGICNUMBER_HASH_MAP
protected static int	MAGICNUMBER_HASH_SET
protected static int	MAGICNUMBER_CHAR
protected static int	MAGICNUMBER_IMMUTABLE_MAPCOPY
protected static int	MAGICNUMBER_INTEGER
protected static int	MAGICNUMBER_IPADDRESS
protected static int	MAGICNUMBER_LINKED_LIST
protected static int	MAGICNUMBER_LONG
protected static int	MAGICNUMBER_MARSHALLEDVALUE
protected static int	MAGICNUMBER_METHODCALL
protected static int	MAGICNUMBER_NODEDATA
protected static int	MAGICNUMBER_NODEDATA_EXCEPTION_MARKER
protected static int	MAGICNUMBER_NODEDATA_MARKER
protected static int	MAGICNUMBER_NULL
protected static int	MAGICNUMBER_OBJECT
protected static int	MAGICNUMBER_REF
protected static int	MAGICNUMBER_REQUEST_IGNORED_RESPONSE
protected static int	MAGICNUMBER_SERIALIZABLE
protected static int	MAGICNUMBER_SHORT
protected static int	MAGICNUMBER_STRING
protected static int	MAGICNUMBER_TREE_MAP
protected static int	MAGICNUMBER_TREE_SET
protected static int	MAGICNUMBER_TXLOG_ENTRY

Fields inherited from class org.jboss.cache.marshall.AbstractMarshaller

configuration, defaultClassLoader, defaultInactive, log, regionManager, trace, useRefs, useRegionBasedMarshalling

Constructor Summary

CacheMarshaller200()

Method Summary

void	injectCommandsFactory(CommandsFactory commandsFactory)
protected void	marshallDefaultDataVersion(DefaultDataVersion ddv, java.io.ObjectOutputStream out)
protected void	marshallFqn(Fqn fqn, java.io.ObjectOutputStream out, java.util.Map<java.lang.Object,java.lang.Integer> refMap)
protected void	marshallObject(java.lang.Object o, java.io.ObjectOutputStream out, java.util.Map<java.lang.Object,java.lang.Integer> refMap)
protected void	marshallString(java.lang.String s, java.io.ObjectOutputStream out)
java.lang.Object	objectFromObjectStream(java.io.ObjectInputStream in) Unmarshalls an object from an ObjectInputStream
protected java.lang.Object[]	objectFromObjectStreamRegionBased(java.io.ObjectInputStream in)
void	objectToObjectStream(java.lang.Object o, java.io.ObjectOutputStream out) Marshalls an object to a given ObjectOutputStream
void	objectToObjectStream(java.lang.Object o, java.io.ObjectOutputStream out, Fqn region) Overloaded form of Marshaller.objectToObjectStream(Object,java.io.ObjectOutputStream) which adds a hint to the Fqn region
protected int	readReference(java.io.ObjectInputStream in) Reads a reference from a given stream.
protected int	readUnsignedInt(java.io.ObjectInputStream in)
protected long	readUnsignedLong(java.io.ObjectInputStream in)
RegionalizedMethodCall	regionalizedMethodCallFromObjectStream(java.io.ObjectInputStream in) Returns a RegionalizedMethodCall from an object input stream.
protected java.lang.Object	unmarshallArray(java.io.ObjectInputStream in, UnmarshalledReferences refs)
protected DefaultDataVersion	unmarshallDefaultDataVersion(java.io.ObjectInputStream in)
protected Fqn	unmarshallFqn(java.io.ObjectInputStream in, UnmarshalledReferences refMap)
protected java.lang.Object	unmarshallObject(java.io.ObjectInputStream in, java.lang.ClassLoader loader, UnmarshalledReferences refMap, boolean overrideContextClassloaderOnThread)
protected java.lang.Object	unmarshallObject(java.io.ObjectInputStream in, UnmarshalledReferences refMap)
protected java.lang.String	unmarshallString(java.io.ObjectInputStream in)
protected void	writeReference(java.io.ObjectOutputStream out, int reference) Writes a reference to a given object output stream.
protected void	writeUnsignedInt(java.io.ObjectOutputStream out, int i)
protected void	writeUnsignedLong(java.io.ObjectOutputStream out, long i)

Methods inherited from class org.jboss.cache.marshall.AbstractMarshaller

extractFqn, init, initLogger, objectFromByteBuffer, objectFromByteBuffer, objectFromStream, objectToBuffer, objectToByteBuffer, regionalizedMethodCallFromByteBuffer

Methods inherited from class java.lang.Object

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

Field Detail

MAGICNUMBER_METHODCALL

protected static final int MAGICNUMBER_METHODCALL

See Also:

Constant Field Values

MAGICNUMBER_FQN

protected static final int MAGICNUMBER_FQN

See Also:

Constant Field Values

MAGICNUMBER_GTX

protected static final int MAGICNUMBER_GTX

See Also:

Constant Field Values

MAGICNUMBER_IPADDRESS

protected static final int MAGICNUMBER_IPADDRESS

See Also:

Constant Field Values

MAGICNUMBER_ARRAY_LIST

protected static final int MAGICNUMBER_ARRAY_LIST

See Also:

Constant Field Values

MAGICNUMBER_INTEGER

protected static final int MAGICNUMBER_INTEGER

See Also:

Constant Field Values

MAGICNUMBER_LONG

protected static final int MAGICNUMBER_LONG

See Also:

Constant Field Values

MAGICNUMBER_BOOLEAN

protected static final int MAGICNUMBER_BOOLEAN

See Also:

Constant Field Values

MAGICNUMBER_STRING

protected static final int MAGICNUMBER_STRING

See Also:

Constant Field Values

MAGICNUMBER_DEFAULT_DATA_VERSION

protected static final int MAGICNUMBER_DEFAULT_DATA_VERSION

See Also:

Constant Field Values

MAGICNUMBER_LINKED_LIST

protected static final int MAGICNUMBER_LINKED_LIST

See Also:

Constant Field Values

MAGICNUMBER_HASH_MAP

protected static final int MAGICNUMBER_HASH_MAP

See Also:

Constant Field Values

MAGICNUMBER_TREE_MAP

protected static final int MAGICNUMBER_TREE_MAP

See Also:

Constant Field Values

MAGICNUMBER_HASH_SET

protected static final int MAGICNUMBER_HASH_SET

See Also:

Constant Field Values

MAGICNUMBER_TREE_SET

protected static final int MAGICNUMBER_TREE_SET

See Also:

Constant Field Values

MAGICNUMBER_NODEDATA_MARKER

protected static final int MAGICNUMBER_NODEDATA_MARKER

See Also:

Constant Field Values

MAGICNUMBER_NODEDATA_EXCEPTION_MARKER

protected static final int MAGICNUMBER_NODEDATA_EXCEPTION_MARKER

See Also:

Constant Field Values

MAGICNUMBER_NODEDATA

protected static final int MAGICNUMBER_NODEDATA

See Also:

Constant Field Values

MAGICNUMBER_GRAVITATERESULT

protected static final int MAGICNUMBER_GRAVITATERESULT

See Also:

Constant Field Values

MAGICNUMBER_SHORT

protected static final int MAGICNUMBER_SHORT

See Also:

Constant Field Values

MAGICNUMBER_IMMUTABLE_MAPCOPY

protected static final int MAGICNUMBER_IMMUTABLE_MAPCOPY

See Also:

Constant Field Values

MAGICNUMBER_MARSHALLEDVALUE

protected static final int MAGICNUMBER_MARSHALLEDVALUE

See Also:

Constant Field Values

MAGICNUMBER_FASTCOPY_HASHMAP

protected static final int MAGICNUMBER_FASTCOPY_HASHMAP

See Also:

Constant Field Values

MAGICNUMBER_ARRAY

protected static final int MAGICNUMBER_ARRAY

See Also:

Constant Field Values

MAGICNUMBER_BYTE

protected static final int MAGICNUMBER_BYTE

See Also:

Constant Field Values

MAGICNUMBER_CHAR

protected static final int MAGICNUMBER_CHAR

See Also:

Constant Field Values

MAGICNUMBER_FLOAT

protected static final int MAGICNUMBER_FLOAT

See Also:

Constant Field Values

MAGICNUMBER_DOUBLE

protected static final int MAGICNUMBER_DOUBLE

See Also:

Constant Field Values

MAGICNUMBER_OBJECT

protected static final int MAGICNUMBER_OBJECT

See Also:

Constant Field Values

MAGICNUMBER_TXLOG_ENTRY

protected static final int MAGICNUMBER_TXLOG_ENTRY

See Also:

Constant Field Values

MAGICNUMBER_REQUEST_IGNORED_RESPONSE

protected static final int MAGICNUMBER_REQUEST_IGNORED_RESPONSE

See Also:

Constant Field Values

MAGICNUMBER_EXTENDED_RESPONSE

protected static final int MAGICNUMBER_EXTENDED_RESPONSE

See Also:

Constant Field Values

MAGICNUMBER_NULL

protected static final int MAGICNUMBER_NULL

See Also:

Constant Field Values

MAGICNUMBER_SERIALIZABLE

protected static final int MAGICNUMBER_SERIALIZABLE

See Also:

Constant Field Values

MAGICNUMBER_REF

protected static final int MAGICNUMBER_REF

See Also:

Constant Field Values

IRE

protected static final InactiveRegionException IRE

commandsFactory

protected CommandsFactory commandsFactory

Constructor Detail

CacheMarshaller200

public CacheMarshaller200()

Method Detail

injectCommandsFactory

public void injectCommandsFactory(CommandsFactory commandsFactory)

objectToObjectStream

public void objectToObjectStream(java.lang.Object o,
                                 java.io.ObjectOutputStream out)
                          throws java.lang.Exception

Description copied from interface: Marshaller

Marshalls an object to a given ObjectOutputStream

Parameters:

o - object to marshall

out - stream to marshall to

Throws:

java.lang.Exception

regionalizedMethodCallFromObjectStream

public RegionalizedMethodCall regionalizedMethodCallFromObjectStream(java.io.ObjectInputStream in)
                                                              throws java.lang.Exception

Description copied from interface: Marshaller

Returns a RegionalizedMethodCall from an object input stream. Only use if you know that the byte buffer contains a MethodCall and that you are using region-based marshalling, otherwise use Marshaller.objectFromObjectStream(java.io.ObjectInputStream)

Specified by:

regionalizedMethodCallFromObjectStream in interface Marshaller

Overrides:

regionalizedMethodCallFromObjectStream in class AbstractMarshaller

Parameters:

in - object inout stream

Returns:

a RegionalizedMethodCall

Throws:

java.lang.Exception - if there are issues

objectFromObjectStream

public java.lang.Object objectFromObjectStream(java.io.ObjectInputStream in)
                                        throws java.lang.Exception

Description copied from interface: Marshaller

Unmarshalls an object from an ObjectInputStream

Parameters:

in - stream to unmarshall from

Throws:

java.lang.Exception

objectToObjectStream

public void objectToObjectStream(java.lang.Object o,
                                 java.io.ObjectOutputStream out,
                                 Fqn region)
                          throws java.lang.Exception

Description copied from interface: Marshaller

Overloaded form of Marshaller.objectToObjectStream(Object,java.io.ObjectOutputStream) which adds a hint to the Fqn region

Parameters:

o - object to marshall

out - stream to marshall to

region - fqn that this object pertains to

Throws:

java.lang.Exception

objectFromObjectStreamRegionBased

protected java.lang.Object[] objectFromObjectStreamRegionBased(java.io.ObjectInputStream in)
                                                        throws java.lang.Exception

Parameters:

in -

Returns:

a 2-object array. The first one is the unmarshalled object and the 2nd is an Fqn that relates to the region used. If region-based marshalling is not used, the 2nd value is null.

Throws:

java.lang.Exception

marshallObject

protected void marshallObject(java.lang.Object o,
                              java.io.ObjectOutputStream out,
                              java.util.Map<java.lang.Object,java.lang.Integer> refMap)
                       throws java.lang.Exception

Throws:

java.lang.Exception

marshallString

protected void marshallString(java.lang.String s,
                              java.io.ObjectOutputStream out)
                       throws java.lang.Exception

Throws:

java.lang.Exception

marshallFqn

protected void marshallFqn(Fqn fqn,
                           java.io.ObjectOutputStream out,
                           java.util.Map<java.lang.Object,java.lang.Integer> refMap)
                    throws java.lang.Exception

Throws:

java.lang.Exception

unmarshallObject

protected java.lang.Object unmarshallObject(java.io.ObjectInputStream in,
                                            java.lang.ClassLoader loader,
                                            UnmarshalledReferences refMap,
                                            boolean overrideContextClassloaderOnThread)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

unmarshallObject

protected java.lang.Object unmarshallObject(java.io.ObjectInputStream in,
                                            UnmarshalledReferences refMap)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

unmarshallString

protected java.lang.String unmarshallString(java.io.ObjectInputStream in)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

unmarshallFqn

protected Fqn unmarshallFqn(java.io.ObjectInputStream in,
                            UnmarshalledReferences refMap)
                     throws java.lang.Exception

Throws:

java.lang.Exception

marshallDefaultDataVersion

protected void marshallDefaultDataVersion(DefaultDataVersion ddv,
                                          java.io.ObjectOutputStream out)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

unmarshallDefaultDataVersion

protected DefaultDataVersion unmarshallDefaultDataVersion(java.io.ObjectInputStream in)
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

readReference

protected int readReference(java.io.ObjectInputStream in)
                     throws java.io.IOException

Reads a reference from a given stream.

Parameters:

in - the stream to read from

Returns:

an int representing a reference in RefMap.

Throws:

java.io.IOException - propagated from the OIS

writeReference

protected void writeReference(java.io.ObjectOutputStream out,
                              int reference)
                       throws java.io.IOException

Writes a reference to a given object output stream.

Parameters:

out - the stream to write to

reference - the reference to write

Throws:

java.io.IOException - propagated from the OOS

readUnsignedInt

protected int readUnsignedInt(java.io.ObjectInputStream in)
                       throws java.io.IOException

Throws:

java.io.IOException

writeUnsignedInt

protected void writeUnsignedInt(java.io.ObjectOutputStream out,
                                int i)
                         throws java.io.IOException

Throws:

java.io.IOException

readUnsignedLong

protected long readUnsignedLong(java.io.ObjectInputStream in)
                         throws java.io.IOException

Throws:

java.io.IOException

writeUnsignedLong

protected void writeUnsignedLong(java.io.ObjectOutputStream out,
                                 long i)
                          throws java.io.IOException

Throws:

java.io.IOException

unmarshallArray

protected java.lang.Object unmarshallArray(java.io.ObjectInputStream in,
                                           UnmarshalledReferences refs)
                                    throws java.lang.Exception

Throws:

java.lang.Exception