Class PlatformAtomicReference
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.datastructures.PlatformAtomicReference
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformAtomicReference extends PlatformAbstractTarget
Platform atomic reference wrapper.
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static PlatformAtomicReferencecreateInstance(PlatformContext ctx, String name, Object initVal, boolean create)Creates an instance or returns null.longprocessInLongOutLong(int type, long val)Process IN operation.longprocessInStreamOutLong(int type, BinaryRawReaderEx reader)Process IN operation.voidprocessInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer)Process IN-OUT operation.voidprocessOutStream(int type, BinaryRawWriterEx writer)Process OUT operation.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutObject, processOutObject, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Method Detail
-
createInstance
public static PlatformAtomicReference createInstance(PlatformContext ctx, String name, Object initVal, boolean create)
Creates an instance or returns null.- Parameters:
ctx- Context.name- Name.initVal- Initial value.create- Create flag.- Returns:
- Instance of a PlatformAtomicReference, or null when Ignite reference with specific name is null.
-
processOutStream
public void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess OUT operation.- Specified by:
processOutStreamin interfacePlatformTarget- Overrides:
processOutStreamin classPlatformAbstractTarget- Parameters:
type- Type.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
processInStreamOutLong
public long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedExceptionProcess IN operation.- Specified by:
processInStreamOutLongin interfacePlatformTarget- Overrides:
processInStreamOutLongin classPlatformAbstractTarget- Parameters:
type- Type.reader- Binary reader.- Returns:
- Result.
- Throws:
IgniteCheckedException- In case of exception.
-
processInStreamOutStream
public void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess IN-OUT operation.- Specified by:
processInStreamOutStreamin interfacePlatformTarget- Overrides:
processInStreamOutStreamin classPlatformAbstractTarget- Parameters:
type- Type.reader- Binary reader.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
processInLongOutLong
public long processInLongOutLong(int type, long val) throws IgniteCheckedExceptionProcess IN operation.- Specified by:
processInLongOutLongin interfacePlatformTarget- Overrides:
processInLongOutLongin classPlatformAbstractTarget- Parameters:
type- Type.val- Value.- Returns:
- Result.
- Throws:
IgniteCheckedException- In case of exception.
-
-