org.apache.ignite.internal.processors.portable.os

Class GridOsPortableProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.portable.os.GridOsPortableProcessor

All Implemented Interfaces:

GridComponent, GridProcessor, GridPortableProcessor

public class GridOsPortableProcessor
extends GridProcessorAdapter
implements GridPortableProcessor

No-op implementation of GridPortableProcessor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridOsPortableProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
Object	affinityKey(Object obj) Gets affinity key of portable object.
Object	detachPortable(Object obj)
Object	field(Object obj, String fieldName)
boolean	hasField(Object obj, String fieldName) Checks whether field is set in the object.
boolean	isPortable(GridClientMarshaller marsh)
boolean	isPortableObject(Object obj) Checks whether object is portable object.
ByteBuffer	marshal(Object obj, boolean trim)
Object	marshalToPortable(Object obj)
void	onCacheProcessorStarted()
boolean	portableEnabled(ClusterNode node, String cacheName)
GridClientMarshaller	portableMarshaller()
int	typeId(Object obj)
int	typeId(String typeName)
Object	unmarshal(byte[] arr, int off)
Object	unmarshal(long ptr, boolean forceHeap)
Object	unwrapTemporary(Object obj) Converts temporary offheap object to heap-based.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.GridProcessor

addAttributes

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, start, stop, validateNode

Constructor Detail

GridOsPortableProcessor

public GridOsPortableProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

onCacheProcessorStarted

public void onCacheProcessorStarted()

Specified by:

onCacheProcessorStarted in interface GridPortableProcessor

typeId

public int typeId(String typeName)

Specified by:

typeId in interface GridPortableProcessor

Parameters:

typeName - Type name.

Returns:

Type ID.

marshal

public ByteBuffer marshal(@Nullable
                 Object obj,
                 boolean trim)
                   throws IgniteException

Specified by:

marshal in interface GridPortableProcessor

Parameters:

obj - Object to marshal.

trim - If true trims result byte buffer.

Returns:

Object bytes.

Throws:

IgniteException - In case of error.

unmarshal

@Nullable
public Object unmarshal(byte[] arr,
                        int off)
                 throws IgniteException

Specified by:

unmarshal in interface GridPortableProcessor

Parameters:

arr - Byte array.

off - Offset.

Returns:

Unmarshalled object.

Throws:

IgniteException - In case of error.

unmarshal

public Object unmarshal(long ptr,
               boolean forceHeap)
                 throws IgniteException

Specified by:

unmarshal in interface GridPortableProcessor

Parameters:

ptr - Offheap pointer.

forceHeap - If true creates heap-based object.

Returns:

Unmarshalled object.

Throws:

IgniteException - In case of error.

unwrapTemporary

public Object unwrapTemporary(Object obj)
                       throws IgniteException

Converts temporary offheap object to heap-based.

Specified by:

unwrapTemporary in interface GridPortableProcessor

Parameters:

obj - Object.

Returns:

Heap-based object.

Throws:

IgniteException - In case of error.

marshalToPortable

@Nullable
public Object marshalToPortable(@Nullable
                                Object obj)
                         throws IgniteException

Specified by:

marshalToPortable in interface GridPortableProcessor

Parameters:

obj - Object to marshal.

Returns:

Portable object.

Throws:

IgniteException - In case of error.

detachPortable

public Object detachPortable(@Nullable
                    Object obj)

Specified by:

detachPortable in interface GridPortableProcessor

Parameters:

obj - Object (portable or not).

Returns:

Detached portable object or original object.

portableMarshaller

@Nullable
public GridClientMarshaller portableMarshaller()

Specified by:

portableMarshaller in interface GridPortableProcessor

Returns:

Portable marshaller for client connectivity or null if it's not supported (in case of OS edition).

isPortable

public boolean isPortable(GridClientMarshaller marsh)

Specified by:

isPortable in interface GridPortableProcessor

Parameters:

marsh - Client marshaller.

Returns:

Whether marshaller is portable.

portableEnabled

public boolean portableEnabled(ClusterNode node,
                      String cacheName)

Specified by:

portableEnabled in interface GridPortableProcessor

Parameters:

node - Node to check.

cacheName - Cache name to check.

Returns:

True if portable enabled for the specified cache, false otherwise.

isPortableObject

public boolean isPortableObject(Object obj)

Checks whether object is portable object.

Specified by:

isPortableObject in interface GridPortableProcessor

Parameters:

obj - Object to check.

Returns:

True if object is already a portable object, false otherwise.

affinityKey

public Object affinityKey(Object obj)

Gets affinity key of portable object.

Specified by:

affinityKey in interface GridPortableProcessor

Parameters:

obj - Object to get affinity key for.

Returns:

Affinity key.

typeId

public int typeId(Object obj)

Specified by:

typeId in interface GridPortableProcessor

Parameters:

obj - Object to get type ID for.

Returns:

Type ID.

field

public Object field(Object obj,
           String fieldName)

Specified by:

field in interface GridPortableProcessor

Parameters:

obj - Portable object to get field from.

Returns:

Field value.

hasField

public boolean hasField(Object obj,
               String fieldName)

Checks whether field is set in the object.

Specified by:

hasField in interface GridPortableProcessor

Parameters:

obj - Object.

fieldName - Field name.

Returns:

true if field is set.