org.apache.ignite.internal.processors.platform

Class PlatformTargetProxyImpl

java.lang.Object

org.apache.ignite.internal.processors.platform.PlatformTargetProxyImpl

All Implemented Interfaces:

PlatformTargetProxy

public class PlatformTargetProxyImpl
extends Object
implements PlatformTargetProxy

Platform target that is invoked via JNI and propagates calls to underlying PlatformTarget.

Field Summary

Fields

Modifier and Type	Field and Description
protected PlatformContext	platformCtx Context.

Constructor Summary

Constructors

Constructor and Description
PlatformTargetProxyImpl(PlatformTarget target, PlatformContext platformCtx)

Method Summary

Modifier and Type	Method and Description
long	inLongOutLong(int type, long val) Operation accepting long value and returning long value.
Object	inObjectStreamOutObjectStream(int type, Object arg, long inMemPtr, long outMemPtr) Operation accepting an object and a memory stream and returning result to another memory stream and an object.
void	inStreamAsync(int type, long memPtr) Asynchronous operation accepting memory stream.
long	inStreamOutLong(int type, long memPtr) Operation accepting memory stream and returning long value.
Object	inStreamOutObject(int type, long memPtr) Operation accepting memory stream and returning object.
Object	inStreamOutObjectAsync(int type, long memPtr) Asynchronous operation accepting memory stream and returning PlatformListenableTarget.
void	inStreamOutStream(int type, long inMemPtr, long outMemPtr) Operation accepting one memory stream and returning result to another memory stream.
Object	outObject(int type) Operation returning object result.
void	outStream(int type, long memPtr) Operation returning result to memory stream.
PlatformTarget	unwrap() Returns the underlying target.

Methods inherited from class java.lang.Object

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

Field Detail

platformCtx

protected final PlatformContext platformCtx

Context.

Constructor Detail

PlatformTargetProxyImpl

public PlatformTargetProxyImpl(PlatformTarget target,
                               PlatformContext platformCtx)

Parameters:

target - Platform target.

platformCtx - Platform context.

Method Detail

inLongOutLong

public long inLongOutLong(int type,
                          long val)
                   throws Exception

Operation accepting long value and returning long value.

Specified by:

inLongOutLong in interface PlatformTargetProxy

Parameters:

type - Operation type.

val - Value.

Returns:

Result.

Throws:

Exception - If case of failure.

inStreamOutLong

public long inStreamOutLong(int type,
                            long memPtr)
                     throws Exception

Operation accepting memory stream and returning long value.

Specified by:

inStreamOutLong in interface PlatformTargetProxy

Parameters:

type - Operation type.

memPtr - Memory pointer.

Returns:

Result.

Throws:

Exception - If case of failure.

inStreamOutObject

public Object inStreamOutObject(int type,
                                long memPtr)
                         throws Exception

Operation accepting memory stream and returning object.

Specified by:

inStreamOutObject in interface PlatformTargetProxy

Parameters:

type - Operation type.

memPtr - Memory pointer.

Returns:

Result.

Throws:

Exception - If case of failure.

outStream

public void outStream(int type,
                      long memPtr)
               throws Exception

Operation returning result to memory stream.

Specified by:

outStream in interface PlatformTargetProxy

Parameters:

type - Operation type.

memPtr - Memory pointer.

Throws:

Exception - In case of failure.

outObject

public Object outObject(int type)
                 throws Exception

Operation returning object result.

Specified by:

outObject in interface PlatformTargetProxy

Parameters:

type - Operation type.

Returns:

Result.

Throws:

Exception - If failed.

inStreamAsync

public void inStreamAsync(int type,
                          long memPtr)
                   throws Exception

Asynchronous operation accepting memory stream.

Specified by:

inStreamAsync in interface PlatformTargetProxy

Parameters:

type - Operation type.

memPtr - Memory pointer.

Throws:

Exception - If case of failure.

inStreamOutObjectAsync

public Object inStreamOutObjectAsync(int type,
                                     long memPtr)
                              throws Exception

Asynchronous operation accepting memory stream and returning PlatformListenableTarget. Supports cancellable async operations.

Specified by:

inStreamOutObjectAsync in interface PlatformTargetProxy

Parameters:

type - Operation type.

memPtr - Memory pointer.

Returns:

Result.

Throws:

Exception - If case of failure.

inStreamOutStream

public void inStreamOutStream(int type,
                              long inMemPtr,
                              long outMemPtr)
                       throws Exception

Operation accepting one memory stream and returning result to another memory stream.

Specified by:

inStreamOutStream in interface PlatformTargetProxy

Parameters:

type - Operation type.

inMemPtr - Input memory pointer.

outMemPtr - Output memory pointer.

Throws:

Exception - In case of failure.

inObjectStreamOutObjectStream

public Object inObjectStreamOutObjectStream(int type,
                                            Object arg,
                                            long inMemPtr,
                                            long outMemPtr)
                                     throws Exception

Operation accepting an object and a memory stream and returning result to another memory stream and an object.

Specified by:

inObjectStreamOutObjectStream in interface PlatformTargetProxy

Parameters:

type - Operation type.

arg - Argument (optional).

inMemPtr - Input memory pointer.

outMemPtr - Output memory pointer.

Returns:

Result.

Throws:

Exception - In case of failure.

unwrap

public PlatformTarget unwrap()

Returns the underlying target.

Specified by:

unwrap in interface PlatformTargetProxy

Returns:

Underlying target.