You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/12/08 14:17:43 UTC
[05/19] ignite git commit: Reformatting
http://git-wip-us.apache.org/repos/asf/ignite/blob/6ad92dfe/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Unmanaged/UnmanagedUtils.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Unmanaged/UnmanagedUtils.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Unmanaged/UnmanagedUtils.cs
index dd5769b..557468e 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Unmanaged/UnmanagedUtils.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Unmanaged/UnmanagedUtils.cs
@@ -32,429 +32,432 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
/** Interop factory ID for .Net. */
private const int InteropFactoryId = 1;
- #region DELEGATE MEMBERS
-
- // ReSharper disable InconsistentNaming
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteReallocate", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int REALLOCATE(long memPtr, int cap);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStart", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* IGNITION_START(void* ctx, sbyte* cfgPath, sbyte* gridName, int factoryId, long dataPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStop", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool IGNITION_STOP(void* ctx, sbyte* gridName, bool cancel);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStopAll", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void IGNITION_STOP_ALL(void* ctx, bool cancel);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorReleaseStart", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void PROCESSOR_RELEASE_START(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorProjection", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_PROJECTION(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCache", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_CACHE(void* ctx, void* obj, sbyte* name);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCreateCache", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_CREATE_CACHE(void* ctx, void* obj, sbyte* name);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorGetOrCreateCache", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_GET_OR_CREATE_CACHE(void* ctx, void* obj, sbyte* name);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorAffinity", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_AFFINITY(void* ctx, void* obj, sbyte* name);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorDataStreamer", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_DATA_STREAMER(void* ctx, void* obj, sbyte* name, bool keepBinary);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorTransactions", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_TRANSACTIONS(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCompute", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_COMPUTE(void* ctx, void* obj, void* prj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorMessage", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_MESSAGE(void* ctx, void* obj, void* prj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorEvents", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_EVENTS(void* ctx, void* obj, void* prj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorServices", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_SERVICES(void* ctx, void* obj, void* prj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorExtensions", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_EXTENSIONS(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorAtomicLong", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROCESSOR_ATOMIC_LONG(void* ctx, void* obj, sbyte* name, long initVal, bool create);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutLong", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long TARGET_IN_STREAM_OUT_LONG(void* ctx, void* target, int opType, long memPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutStream", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TARGET_IN_STREAM_OUT_STREAM(void* ctx, void* target, int opType, long inMemPtr, long outMemPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutObject", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* TARGET_IN_STREAM_OUT_OBJECT(void* ctx, void* target, int opType, long memPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInObjectStreamOutStream", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TARGET_IN_OBJECT_STREAM_OUT_STREAM(void* ctx, void* target, int opType, void* arg, long inMemPtr, long outMemPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutLong", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long TARGET_OUT_LONG(void* ctx, void* target, int opType);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutStream", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TARGET_OUT_STREAM(void* ctx, void* target, int opType, long memPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutObject", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* TARGET_OUT_OBJECT(void* ctx, void* target, int opType);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetListenFuture", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TargetListenFut(void* ctx, void* target, long futId, int typ);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetListenFutureForOperation", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TargetListenFutForOp(void* ctx, void* target, long futId, int typ, int opId);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAffinityPartitions", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int AffinityParts(void* ctx, void* target);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithSkipStore", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_WITH_SKIP_STORE(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithNoRetries", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_WITH_NO_RETRIES(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithExpiryPolicy", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_WITH_EXPIRY_POLICY(void* ctx, void* obj, long create, long update, long access);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_WITH_ASYNC(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithKeepPortable", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_WITH_KEEP_BINARY(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheClear", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_CLEAR(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheRemoveAll", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_REMOVE_ALL(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheOutOpQueryCursor", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_OUT_OP_QUERY_CURSOR(void* ctx, void* obj, int type, long memPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheOutOpContinuousQuery", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_OUT_OP_CONTINUOUS_QUERY(void* ctx, void* obj, int type, long memPtr);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheIterator", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_ITERATOR(void* ctx, void* obj);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheLocalIterator", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CACHE_LOCAL_ITERATOR(void* ctx, void* obj, int peekModes);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheEnterLock", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_ENTER_LOCK(void* ctx, void* obj, long id);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheExitLock", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_EXIT_LOCK(void* ctx, void* obj, long id);
-
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheTryEnterLock", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool CACHE_TRY_ENTER_LOCK(void* ctx, void* obj, long id, long timeout);
+ /** JNI imported methods. */
+ private static class IgniteJni
+ {
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteReallocate", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int REALLOCATE(long memPtr, int cap);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheCloseLock", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_CLOSE_LOCK(void* ctx, void* obj, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStart", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* IGNITION_START(void* ctx, sbyte* cfgPath, sbyte* gridName, int factoryId,
+ long dataPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStop", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool IGNITION_STOP(void* ctx, sbyte* gridName, bool cancel);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteIgnitionStopAll", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void IGNITION_STOP_ALL(void* ctx, bool cancel);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorReleaseStart", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void PROCESSOR_RELEASE_START(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorProjection", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_PROJECTION(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCache", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_CACHE(void* ctx, void* obj, sbyte* name);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCreateCache", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_CREATE_CACHE(void* ctx, void* obj, sbyte* name);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorGetOrCreateCache",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_GET_OR_CREATE_CACHE(void* ctx, void* obj, sbyte* name);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorAffinity", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_AFFINITY(void* ctx, void* obj, sbyte* name);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorDataStreamer", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_DATA_STREAMER(void* ctx, void* obj, sbyte* name, bool keepBinary);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorTransactions", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_TRANSACTIONS(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorCompute", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_COMPUTE(void* ctx, void* obj, void* prj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorMessage", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_MESSAGE(void* ctx, void* obj, void* prj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorEvents", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_EVENTS(void* ctx, void* obj, void* prj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorServices", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_SERVICES(void* ctx, void* obj, void* prj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorExtensions", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_EXTENSIONS(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProcessorAtomicLong", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROCESSOR_ATOMIC_LONG(void* ctx, void* obj, sbyte* name, long initVal,
+ bool create);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutLong", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long TARGET_IN_STREAM_OUT_LONG(void* ctx, void* target, int opType, long memPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutStream", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TARGET_IN_STREAM_OUT_STREAM(void* ctx, void* target, int opType, long inMemPtr,
+ long outMemPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInStreamOutObject", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* TARGET_IN_STREAM_OUT_OBJECT(void* ctx, void* target, int opType, long memPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetInObjectStreamOutStream",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TARGET_IN_OBJECT_STREAM_OUT_STREAM(void* ctx, void* target, int opType,
+ void* arg, long inMemPtr, long outMemPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutLong", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long TARGET_OUT_LONG(void* ctx, void* target, int opType);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutStream", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TARGET_OUT_STREAM(void* ctx, void* target, int opType, long memPtr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetOutObject", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* TARGET_OUT_OBJECT(void* ctx, void* target, int opType);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetListenFuture", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TargetListenFut(void* ctx, void* target, long futId, int typ);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTargetListenFutureForOperation",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TargetListenFutForOp(void* ctx, void* target, long futId, int typ, int opId);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAffinityPartitions", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int AffinityParts(void* ctx, void* target);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithSkipStore", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_WITH_SKIP_STORE(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithNoRetries", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_WITH_NO_RETRIES(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithExpiryPolicy", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_WITH_EXPIRY_POLICY(void* ctx, void* obj, long create, long update,
+ long access);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheRebalance", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_REBALANCE(void* ctx, void* obj, long futId);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithAsync", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_WITH_ASYNC(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheSize", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int CACHE_SIZE(void* ctx, void* obj, int peekModes, bool loc);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheWithKeepPortable", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_WITH_KEEP_BINARY(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheStoreCallbackInvoke", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void CACHE_STORE_CALLBACK_INVOKE(void* ctx, void* obj, long memPtr);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheClear", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_CLEAR(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeWithNoFailover", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void COMPUTE_WITH_NO_FAILOVER(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheRemoveAll", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_REMOVE_ALL(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeWithTimeout", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void COMPUTE_WITH_TIMEOUT(void* ctx, void* target, long timeout);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheOutOpQueryCursor", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_OUT_OP_QUERY_CURSOR(void* ctx, void* obj, int type, long memPtr);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeExecuteNative", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void COMPUTE_EXECUTE_NATIVE(void* ctx, void* target, long taskPtr, long topVer);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheOutOpContinuousQuery",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_OUT_OP_CONTINUOUS_QUERY(void* ctx, void* obj, int type, long memPtr);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteContinuousQueryClose", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void ContinuousQryClose(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheIterator", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_ITERATOR(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteContinuousQueryGetInitialQueryCursor", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* ContinuousQryGetInitialQueryCursor(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheLocalIterator", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CACHE_LOCAL_ITERATOR(void* ctx, void* obj, int peekModes);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerListenTopology", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DataStreamerListenTop(void* ctx, void* obj, long ptr);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheEnterLock", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_ENTER_LOCK(void* ctx, void* obj, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerAllowOverwriteGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool DATA_STREAMER_ALLOW_OVERWRITE_GET(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheExitLock", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_EXIT_LOCK(void* ctx, void* obj, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerAllowOverwriteSet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DATA_STREAMER_ALLOW_OVERWRITE_SET(void* ctx, void* obj, bool val);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheTryEnterLock", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool CACHE_TRY_ENTER_LOCK(void* ctx, void* obj, long id, long timeout);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerSkipStoreGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool DATA_STREAMER_SKIP_STORE_GET(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheCloseLock", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_CLOSE_LOCK(void* ctx, void* obj, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerSkipStoreSet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DATA_STREAMER_SKIP_STORE_SET(void* ctx, void* obj, bool val);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheRebalance", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_REBALANCE(void* ctx, void* obj, long futId);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeBufferSizeGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int DATA_STREAMER_PER_NODE_BUFFER_SIZE_GET(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheSize", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int CACHE_SIZE(void* ctx, void* obj, int peekModes, bool loc);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeBufferSizeSet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DATA_STREAMER_PER_NODE_BUFFER_SIZE_SET(void* ctx, void* obj, int val);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCacheStoreCallbackInvoke",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void CACHE_STORE_CALLBACK_INVOKE(void* ctx, void* obj, long memPtr);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeParallelOperationsGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int DataStreamerPerNodeParallelOpsGet(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeWithNoFailover", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void COMPUTE_WITH_NO_FAILOVER(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeParallelOperationsSet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DataStreamerPerNodeParallelOpsSet(void* ctx, void* obj, int val);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeWithTimeout", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void COMPUTE_WITH_TIMEOUT(void* ctx, void* target, long timeout);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteMessagingWithAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* MessagingWithAsync(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteComputeExecuteNative", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void COMPUTE_EXECUTE_NATIVE(void* ctx, void* target, long taskPtr, long topVer);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteContinuousQueryClose", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void ContinuousQryClose(void* ctx, void* target);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteContinuousQueryGetInitialQueryCursor",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* ContinuousQryGetInitialQueryCursor(void* ctx, void* target);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerListenTopology",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DataStreamerListenTop(void* ctx, void* obj, long ptr);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerAllowOverwriteGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool DATA_STREAMER_ALLOW_OVERWRITE_GET(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerAllowOverwriteSet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DATA_STREAMER_ALLOW_OVERWRITE_SET(void* ctx, void* obj, bool val);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerSkipStoreGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool DATA_STREAMER_SKIP_STORE_GET(void* ctx, void* obj);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerSkipStoreSet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DATA_STREAMER_SKIP_STORE_SET(void* ctx, void* obj, bool val);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForOthers", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_OTHERS(void* ctx, void* obj, void* prj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeBufferSizeGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int DATA_STREAMER_PER_NODE_BUFFER_SIZE_GET(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForRemotes", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_REMOTES(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeBufferSizeSet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DATA_STREAMER_PER_NODE_BUFFER_SIZE_SET(void* ctx, void* obj, int val);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForDaemons", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_DAEMONS(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeParallelOperationsGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int DataStreamerPerNodeParallelOpsGet(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForRandom", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_RANDOM(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDataStreamerPerNodeParallelOperationsSet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DataStreamerPerNodeParallelOpsSet(void* ctx, void* obj, int val);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForOldest", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_OLDEST(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteMessagingWithAsync", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* MessagingWithAsync(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForYoungest", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_FOR_YOUNGEST(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForOthers", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_OTHERS(void* ctx, void* obj, void* prj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionResetMetrics", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void PROJECTION_RESET_METRICS(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForRemotes", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_REMOTES(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionOutOpRet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* PROJECTION_OUT_OP_RET(void* ctx, void* obj, int type, long memPtr);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForDaemons", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_DAEMONS(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteQueryCursorIterator", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void QryCursorIterator(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForRandom", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_RANDOM(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteQueryCursorClose", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void QryCursorClose(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForOldest", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_OLDEST(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAcquire", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* ACQUIRE(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionForYoungest", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_FOR_YOUNGEST(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteRelease", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void RELEASE(void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionResetMetrics", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void PROJECTION_RESET_METRICS(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsStart", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long TxStart(void* ctx, void* target, int concurrency, int isolation, long timeout, int txSize);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteProjectionOutOpRet", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* PROJECTION_OUT_OP_RET(void* ctx, void* obj, int type, long memPtr);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsCommit", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int TxCommit(void* ctx, void* target, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteQueryCursorIterator", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void QryCursorIterator(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsCommitAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TxCommitAsync(void* ctx, void* target, long id, long futId);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteQueryCursorClose", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void QryCursorClose(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsRollback", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int TxRollback(void* ctx, void* target, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAcquire", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* ACQUIRE(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsRollbackAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TxRollbackAsync(void* ctx, void* target, long id, long futId);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteRelease", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void RELEASE(void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsClose", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int TxClose(void* ctx, void* target, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsStart", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long TxStart(void* ctx, void* target, int concurrency, int isolation, long timeout,
+ int txSize);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsState", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int TxState(void* ctx, void* target, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsCommit", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int TxCommit(void* ctx, void* target, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsSetRollbackOnly", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool TxSetRollbackOnly(void* ctx, void* target, long id);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsCommitAsync", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TxCommitAsync(void* ctx, void* target, long id, long futId);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsResetMetrics", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void TxResetMetrics(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsRollback", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int TxRollback(void* ctx, void* target, long id);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsRollbackAsync",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TxRollbackAsync(void* ctx, void* target, long id, long futId);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsClose", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int TxClose(void* ctx, void* target, long id);
+
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsState", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int TxState(void* ctx, void* target, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteThrowToJava", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void THROW_TO_JAVA(void* ctx, char* msg);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsSetRollbackOnly",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool TxSetRollbackOnly(void* ctx, void* target, long id);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteHandlersSize", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern int HANDLERS_SIZE();
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteTransactionsResetMetrics",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void TxResetMetrics(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCreateContext", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* CREATE_CONTEXT(void* opts, int optsLen, void* cbs);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteThrowToJava", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void THROW_TO_JAVA(void* ctx, char* msg);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDeleteContext", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DELETE_CONTEXT(void* ptr);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteHandlersSize", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern int HANDLERS_SIZE();
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDestroyJvm", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void DESTROY_JVM(void* ctx);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteCreateContext", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* CREATE_CONTEXT(void* opts, int optsLen, void* cbs);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsWithAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* EVENTS_WITH_ASYNC(void* ctx, void* obj);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDeleteContext", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DELETE_CONTEXT(void* ptr);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsStopLocalListen", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool EVENTS_STOP_LOCAL_LISTEN(void* ctx, void* obj, long hnd);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteDestroyJvm", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void DESTROY_JVM(void* ctx);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsLocalListen", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void EVENTS_LOCAL_LISTEN(void* ctx, void* obj, long hnd, int type);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsWithAsync", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* EVENTS_WITH_ASYNC(void* ctx, void* obj);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsIsEnabled", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool EVENTS_IS_ENABLED(void* ctx, void* obj, int type);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsStopLocalListen", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool EVENTS_STOP_LOCAL_LISTEN(void* ctx, void* obj, long hnd);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesWithAsync", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* SERVICES_WITH_ASYNC(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsLocalListen", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void EVENTS_LOCAL_LISTEN(void* ctx, void* obj, long hnd, int type);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesWithServerKeepPortable", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* SERVICES_WITH_SERVER_KEEP_BINARY(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteEventsIsEnabled", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool EVENTS_IS_ENABLED(void* ctx, void* obj, int type);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesCancel", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long SERVICES_CANCEL(void* ctx, void* target, char* name);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesWithAsync", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* SERVICES_WITH_ASYNC(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesCancelAll", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long SERVICES_CANCEL_ALL(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesWithServerKeepPortable",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* SERVICES_WITH_SERVER_KEEP_BINARY(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesGetServiceProxy", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void* SERVICES_GET_SERVICE_PROXY(void* ctx, void* target, char* name, bool sticky);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesCancel", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long SERVICES_CANCEL(void* ctx, void* target, char* name);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_GET(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesCancelAll", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long SERVICES_CANCEL_ALL(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongIncrementAndGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_INCREMENT_AND_GET(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteServicesGetServiceProxy", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void* SERVICES_GET_SERVICE_PROXY(void* ctx, void* target, char* name, bool sticky);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongAddAndGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_ADD_AND_GET(void* ctx, void* target, long value);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongGet", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_GET(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongDecrementAndGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_DECREMENT_AND_GET(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongIncrementAndGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_INCREMENT_AND_GET(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongGetAndSet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_GET_AND_SET(void* ctx, void* target, long value);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongAddAndGet", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_ADD_AND_GET(void* ctx, void* target, long value);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongCompareAndSetAndGet", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern long ATOMIC_LONG_COMPARE_AND_SET_AND_GET(void* ctx, void* target, long expVal, long newVal);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongDecrementAndGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_DECREMENT_AND_GET(void* ctx, void* target);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongIsClosed", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern bool ATOMIC_LONG_IS_CLOSED(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongGetAndSet", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_GET_AND_SET(void* ctx, void* target, long value);
- [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongClose", SetLastError = true,
- CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
- private static extern void ATOMIC_LONG_CLOSE(void* ctx, void* target);
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongCompareAndSetAndGet",
+ SetLastError = true, CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern long ATOMIC_LONG_COMPARE_AND_SET_AND_GET(void* ctx, void* target, long expVal,
+ long newVal);
- // ReSharper restore InconsistentNaming
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongIsClosed", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern bool ATOMIC_LONG_IS_CLOSED(void* ctx, void* target);
- #endregion
+ [DllImport(IgniteUtils.FileIgniteJniDll, EntryPoint = "IgniteAtomicLongClose", SetLastError = true,
+ CharSet = CharSet.Ansi, BestFitMapping = false, ThrowOnUnmappableChar = true)]
+ public static extern void ATOMIC_LONG_CLOSE(void* ctx, void* target);
+ }
/// <summary>
/// Initializer.
@@ -472,6 +475,14 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
}
+ /// <summary>
+ /// No-op initializer used to force type loading and static constructor call.
+ /// </summary>
+ internal static void Initialize()
+ {
+ // No-op.
+ }
+
#region NATIVE METHODS: PROCESSOR
internal static IUnmanagedTarget IgnitionStart(UnmanagedContext ctx, string cfgPath, string gridName,
@@ -486,7 +497,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = IGNITION_START(ctx.NativeContext, cfgPath0, gridName0, InteropFactoryId,
+ void* res = IgniteJni.IGNITION_START(ctx.NativeContext, cfgPath0, gridName0, InteropFactoryId,
mem.SynchronizeOutput());
return new UnmanagedTarget(ctx, res);
@@ -505,7 +516,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- return IGNITION_STOP(ctx, gridName0, cancel);
+ return IgniteJni.IGNITION_STOP(ctx, gridName0, cancel);
}
finally
{
@@ -515,17 +526,17 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static void IgnitionStopAll(void* ctx, bool cancel)
{
- IGNITION_STOP_ALL(ctx, cancel);
+ IgniteJni.IGNITION_STOP_ALL(ctx, cancel);
}
internal static void ProcessorReleaseStart(IUnmanagedTarget target)
{
- PROCESSOR_RELEASE_START(target.Context, target.Target);
+ IgniteJni.PROCESSOR_RELEASE_START(target.Context, target.Target);
}
internal static IUnmanagedTarget ProcessorProjection(IUnmanagedTarget target)
{
- void* res = PROCESSOR_PROJECTION(target.Context, target.Target);
+ void* res = IgniteJni.PROCESSOR_PROJECTION(target.Context, target.Target);
return target.ChangeTarget(res);
}
@@ -536,7 +547,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = PROCESSOR_CACHE(target.Context, target.Target, name0);
+ void* res = IgniteJni.PROCESSOR_CACHE(target.Context, target.Target, name0);
return target.ChangeTarget(res);
}
@@ -552,7 +563,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = PROCESSOR_CREATE_CACHE(target.Context, target.Target, name0);
+ void* res = IgniteJni.PROCESSOR_CREATE_CACHE(target.Context, target.Target, name0);
return target.ChangeTarget(res);
}
@@ -568,7 +579,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = PROCESSOR_GET_OR_CREATE_CACHE(target.Context, target.Target, name0);
+ void* res = IgniteJni.PROCESSOR_GET_OR_CREATE_CACHE(target.Context, target.Target, name0);
return target.ChangeTarget(res);
}
@@ -584,7 +595,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = PROCESSOR_AFFINITY(target.Context, target.Target, name0);
+ void* res = IgniteJni.PROCESSOR_AFFINITY(target.Context, target.Target, name0);
return target.ChangeTarget(res);
}
@@ -600,7 +611,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- void* res = PROCESSOR_DATA_STREAMER(target.Context, target.Target, name0, keepBinary);
+ void* res = IgniteJni.PROCESSOR_DATA_STREAMER(target.Context, target.Target, name0, keepBinary);
return target.ChangeTarget(res);
}
@@ -612,42 +623,42 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static IUnmanagedTarget ProcessorTransactions(IUnmanagedTarget target)
{
- void* res = PROCESSOR_TRANSACTIONS(target.Context, target.Target);
+ void* res = IgniteJni.PROCESSOR_TRANSACTIONS(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProcessorCompute(IUnmanagedTarget target, IUnmanagedTarget prj)
{
- void* res = PROCESSOR_COMPUTE(target.Context, target.Target, prj.Target);
+ void* res = IgniteJni.PROCESSOR_COMPUTE(target.Context, target.Target, prj.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProcessorMessage(IUnmanagedTarget target, IUnmanagedTarget prj)
{
- void* res = PROCESSOR_MESSAGE(target.Context, target.Target, prj.Target);
+ void* res = IgniteJni.PROCESSOR_MESSAGE(target.Context, target.Target, prj.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProcessorEvents(IUnmanagedTarget target, IUnmanagedTarget prj)
{
- void* res = PROCESSOR_EVENTS(target.Context, target.Target, prj.Target);
+ void* res = IgniteJni.PROCESSOR_EVENTS(target.Context, target.Target, prj.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProcessorServices(IUnmanagedTarget target, IUnmanagedTarget prj)
{
- void* res = PROCESSOR_SERVICES(target.Context, target.Target, prj.Target);
+ void* res = IgniteJni.PROCESSOR_SERVICES(target.Context, target.Target, prj.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProcessorExtensions(IUnmanagedTarget target)
{
- void* res = PROCESSOR_EXTENSIONS(target.Context, target.Target);
+ void* res = IgniteJni.PROCESSOR_EXTENSIONS(target.Context, target.Target);
return target.ChangeTarget(res);
}
@@ -659,7 +670,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
try
{
- var res = PROCESSOR_ATOMIC_LONG(target.Context, target.Target, name0, initialValue, create);
+ var res = IgniteJni.PROCESSOR_ATOMIC_LONG(target.Context, target.Target, name0, initialValue, create);
return res == null ? null : target.ChangeTarget(res);
}
@@ -675,51 +686,51 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static long TargetInStreamOutLong(IUnmanagedTarget target, int opType, long memPtr)
{
- return TARGET_IN_STREAM_OUT_LONG(target.Context, target.Target, opType, memPtr);
+ return IgniteJni.TARGET_IN_STREAM_OUT_LONG(target.Context, target.Target, opType, memPtr);
}
internal static void TargetInStreamOutStream(IUnmanagedTarget target, int opType, long inMemPtr, long outMemPtr)
{
- TARGET_IN_STREAM_OUT_STREAM(target.Context, target.Target, opType, inMemPtr, outMemPtr);
+ IgniteJni.TARGET_IN_STREAM_OUT_STREAM(target.Context, target.Target, opType, inMemPtr, outMemPtr);
}
internal static IUnmanagedTarget TargetInStreamOutObject(IUnmanagedTarget target, int opType, long inMemPtr)
{
- void* res = TARGET_IN_STREAM_OUT_OBJECT(target.Context, target.Target, opType, inMemPtr);
+ void* res = IgniteJni.TARGET_IN_STREAM_OUT_OBJECT(target.Context, target.Target, opType, inMemPtr);
return target.ChangeTarget(res);
}
internal static void TargetInObjectStreamOutStream(IUnmanagedTarget target, int opType, void* arg, long inMemPtr, long outMemPtr)
{
- TARGET_IN_OBJECT_STREAM_OUT_STREAM(target.Context, target.Target, opType, arg, inMemPtr, outMemPtr);
+ IgniteJni.TARGET_IN_OBJECT_STREAM_OUT_STREAM(target.Context, target.Target, opType, arg, inMemPtr, outMemPtr);
}
internal static long TargetOutLong(IUnmanagedTarget target, int opType)
{
- return TARGET_OUT_LONG(target.Context, target.Target, opType);
+ return IgniteJni.TARGET_OUT_LONG(target.Context, target.Target, opType);
}
internal static void TargetOutStream(IUnmanagedTarget target, int opType, long memPtr)
{
- TARGET_OUT_STREAM(target.Context, target.Target, opType, memPtr);
+ IgniteJni.TARGET_OUT_STREAM(target.Context, target.Target, opType, memPtr);
}
internal static IUnmanagedTarget TargetOutObject(IUnmanagedTarget target, int opType)
{
- void* res = TARGET_OUT_OBJECT(target.Context, target.Target, opType);
+ void* res = IgniteJni.TARGET_OUT_OBJECT(target.Context, target.Target, opType);
return target.ChangeTarget(res);
}
internal static void TargetListenFuture(IUnmanagedTarget target, long futId, int typ)
{
- TargetListenFut(target.Context, target.Target, futId, typ);
+ IgniteJni.TargetListenFut(target.Context, target.Target, futId, typ);
}
internal static void TargetListenFutureForOperation(IUnmanagedTarget target, long futId, int typ, int opId)
{
- TargetListenFutForOp(target.Context, target.Target, futId, typ, opId);
+ IgniteJni.TargetListenFutForOp(target.Context, target.Target, futId, typ, opId);
}
#endregion
@@ -728,7 +739,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static int AffinityPartitions(IUnmanagedTarget target)
{
- return AffinityParts(target.Context, target.Target);
+ return IgniteJni.AffinityParts(target.Context, target.Target);
}
#endregion
@@ -737,110 +748,110 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static IUnmanagedTarget CacheWithSkipStore(IUnmanagedTarget target)
{
- void* res = CACHE_WITH_SKIP_STORE(target.Context, target.Target);
+ void* res = IgniteJni.CACHE_WITH_SKIP_STORE(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheWithNoRetries(IUnmanagedTarget target)
{
- void* res = CACHE_WITH_NO_RETRIES(target.Context, target.Target);
+ void* res = IgniteJni.CACHE_WITH_NO_RETRIES(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheWithExpiryPolicy(IUnmanagedTarget target, long create, long update, long access)
{
- void* res = CACHE_WITH_EXPIRY_POLICY(target.Context, target.Target, create, update, access);
+ void* res = IgniteJni.CACHE_WITH_EXPIRY_POLICY(target.Context, target.Target, create, update, access);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheWithAsync(IUnmanagedTarget target)
{
- void* res = CACHE_WITH_ASYNC(target.Context, target.Target);
+ void* res = IgniteJni.CACHE_WITH_ASYNC(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheWithKeepBinary(IUnmanagedTarget target)
{
- void* res = CACHE_WITH_KEEP_BINARY(target.Context, target.Target);
+ void* res = IgniteJni.CACHE_WITH_KEEP_BINARY(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static void CacheClear(IUnmanagedTarget target)
{
- CACHE_CLEAR(target.Context, target.Target);
+ IgniteJni.CACHE_CLEAR(target.Context, target.Target);
}
internal static void CacheRemoveAll(IUnmanagedTarget target)
{
- CACHE_REMOVE_ALL(target.Context, target.Target);
+ IgniteJni.CACHE_REMOVE_ALL(target.Context, target.Target);
}
internal static IUnmanagedTarget CacheOutOpQueryCursor(IUnmanagedTarget target, int type, long memPtr)
{
- void* res = CACHE_OUT_OP_QUERY_CURSOR(target.Context, target.Target, type, memPtr);
+ void* res = IgniteJni.CACHE_OUT_OP_QUERY_CURSOR(target.Context, target.Target, type, memPtr);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheOutOpContinuousQuery(IUnmanagedTarget target, int type, long memPtr)
{
- void* res = CACHE_OUT_OP_CONTINUOUS_QUERY(target.Context, target.Target, type, memPtr);
+ void* res = IgniteJni.CACHE_OUT_OP_CONTINUOUS_QUERY(target.Context, target.Target, type, memPtr);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheIterator(IUnmanagedTarget target)
{
- void* res = CACHE_ITERATOR(target.Context, target.Target);
+ void* res = IgniteJni.CACHE_ITERATOR(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget CacheLocalIterator(IUnmanagedTarget target, int peekModes)
{
- void* res = CACHE_LOCAL_ITERATOR(target.Context, target.Target, peekModes);
+ void* res = IgniteJni.CACHE_LOCAL_ITERATOR(target.Context, target.Target, peekModes);
return target.ChangeTarget(res);
}
internal static void CacheEnterLock(IUnmanagedTarget target, long id)
{
- CACHE_ENTER_LOCK(target.Context, target.Target, id);
+ IgniteJni.CACHE_ENTER_LOCK(target.Context, target.Target, id);
}
internal static void CacheExitLock(IUnmanagedTarget target, long id)
{
- CACHE_EXIT_LOCK(target.Context, target.Target, id);
+ IgniteJni.CACHE_EXIT_LOCK(target.Context, target.Target, id);
}
internal static bool CacheTryEnterLock(IUnmanagedTarget target, long id, long timeout)
{
- return CACHE_TRY_ENTER_LOCK(target.Context, target.Target, id, timeout);
+ return IgniteJni.CACHE_TRY_ENTER_LOCK(target.Context, target.Target, id, timeout);
}
internal static void CacheCloseLock(IUnmanagedTarget target, long id)
{
- CACHE_CLOSE_LOCK(target.Context, target.Target, id);
+ IgniteJni.CACHE_CLOSE_LOCK(target.Context, target.Target, id);
}
internal static void CacheRebalance(IUnmanagedTarget target, long futId)
{
- CACHE_REBALANCE(target.Context, target.Target, futId);
+ IgniteJni.CACHE_REBALANCE(target.Context, target.Target, futId);
}
internal static void CacheStoreCallbackInvoke(IUnmanagedTarget target, long memPtr)
{
- CACHE_STORE_CALLBACK_INVOKE(target.Context, target.Target, memPtr);
+ IgniteJni.CACHE_STORE_CALLBACK_INVOKE(target.Context, target.Target, memPtr);
}
internal static int CacheSize(IUnmanagedTarget target, int modes, bool loc)
{
- return CACHE_SIZE(target.Context, target.Target, modes, loc);
+ return IgniteJni.CACHE_SIZE(target.Context, target.Target, modes, loc);
}
#endregion
@@ -849,17 +860,17 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static void ComputeWithNoFailover(IUnmanagedTarget target)
{
- COMPUTE_WITH_NO_FAILOVER(target.Context, target.Target);
+ IgniteJni.COMPUTE_WITH_NO_FAILOVER(target.Context, target.Target);
}
internal static void ComputeWithTimeout(IUnmanagedTarget target, long timeout)
{
- COMPUTE_WITH_TIMEOUT(target.Context, target.Target, timeout);
+ IgniteJni.COMPUTE_WITH_TIMEOUT(target.Context, target.Target, timeout);
}
internal static void ComputeExecuteNative(IUnmanagedTarget target, long taskPtr, long topVer)
{
- COMPUTE_EXECUTE_NATIVE(target.Context, target.Target, taskPtr, topVer);
+ IgniteJni.COMPUTE_EXECUTE_NATIVE(target.Context, target.Target, taskPtr, topVer);
}
#endregion
@@ -868,12 +879,12 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static void ContinuousQueryClose(IUnmanagedTarget target)
{
- ContinuousQryClose(target.Context, target.Target);
+ IgniteJni.ContinuousQryClose(target.Context, target.Target);
}
internal static IUnmanagedTarget ContinuousQueryGetInitialQueryCursor(IUnmanagedTarget target)
{
- void* res = ContinuousQryGetInitialQueryCursor(target.Context, target.Target);
+ void* res = IgniteJni.ContinuousQryGetInitialQueryCursor(target.Context, target.Target);
return res == null ? null : target.ChangeTarget(res);
}
@@ -884,47 +895,47 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static void DataStreamerListenTopology(IUnmanagedTarget target, long ptr)
{
- DataStreamerListenTop(target.Context, target.Target, ptr);
+ IgniteJni.DataStreamerListenTop(target.Context, target.Target, ptr);
}
internal static bool DataStreamerAllowOverwriteGet(IUnmanagedTarget target)
{
- return DATA_STREAMER_ALLOW_OVERWRITE_GET(target.Context, target.Target);
+ return IgniteJni.DATA_STREAMER_ALLOW_OVERWRITE_GET(target.Context, target.Target);
}
internal static void DataStreamerAllowOverwriteSet(IUnmanagedTarget target, bool val)
{
- DATA_STREAMER_ALLOW_OVERWRITE_SET(target.Context, target.Target, val);
+ IgniteJni.DATA_STREAMER_ALLOW_OVERWRITE_SET(target.Context, target.Target, val);
}
internal static bool DataStreamerSkipStoreGet(IUnmanagedTarget target)
{
- return DATA_STREAMER_SKIP_STORE_GET(target.Context, target.Target);
+ return IgniteJni.DATA_STREAMER_SKIP_STORE_GET(target.Context, target.Target);
}
internal static void DataStreamerSkipStoreSet(IUnmanagedTarget target, bool val)
{
- DATA_STREAMER_SKIP_STORE_SET(target.Context, target.Target, val);
+ IgniteJni.DATA_STREAMER_SKIP_STORE_SET(target.Context, target.Target, val);
}
internal static int DataStreamerPerNodeBufferSizeGet(IUnmanagedTarget target)
{
- return DATA_STREAMER_PER_NODE_BUFFER_SIZE_GET(target.Context, target.Target);
+ return IgniteJni.DATA_STREAMER_PER_NODE_BUFFER_SIZE_GET(target.Context, target.Target);
}
internal static void DataStreamerPerNodeBufferSizeSet(IUnmanagedTarget target, int val)
{
- DATA_STREAMER_PER_NODE_BUFFER_SIZE_SET(target.Context, target.Target, val);
+ IgniteJni.DATA_STREAMER_PER_NODE_BUFFER_SIZE_SET(target.Context, target.Target, val);
}
internal static int DataStreamerPerNodeParallelOperationsGet(IUnmanagedTarget target)
{
- return DataStreamerPerNodeParallelOpsGet(target.Context, target.Target);
+ return IgniteJni.DataStreamerPerNodeParallelOpsGet(target.Context, target.Target);
}
internal static void DataStreamerPerNodeParallelOperationsSet(IUnmanagedTarget target, int val)
{
- DataStreamerPerNodeParallelOpsSet(target.Context, target.Target, val);
+ IgniteJni.DataStreamerPerNodeParallelOpsSet(target.Context, target.Target, val);
}
#endregion
@@ -933,7 +944,7 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static IUnmanagedTarget MessagingWithASync(IUnmanagedTarget target)
{
- void* res = MessagingWithAsync(target.Context, target.Target);
+ void* res = IgniteJni.MessagingWithAsync(target.Context, target.Target);
return target.ChangeTarget(res);
}
@@ -944,54 +955,54 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static IUnmanagedTarget ProjectionForOthers(IUnmanagedTarget target, IUnmanagedTarget prj)
{
- void* res = PROJECTION_FOR_OTHERS(target.Context, target.Target, prj.Target);
+ void* res = IgniteJni.PROJECTION_FOR_OTHERS(target.Context, target.Target, prj.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProjectionForRemotes(IUnmanagedTarget target)
{
- void* res = PROJECTION_FOR_REMOTES(target.Context, target.Target);
+ void* res = IgniteJni.PROJECTION_FOR_REMOTES(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProjectionForDaemons(IUnmanagedTarget target)
{
- void* res = PROJECTION_FOR_DAEMONS(target.Context, target.Target);
+ void* res = IgniteJni.PROJECTION_FOR_DAEMONS(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProjectionForRandom(IUnmanagedTarget target)
{
- void* res = PROJECTION_FOR_RANDOM(target.Context, target.Target);
+ void* res = IgniteJni.PROJECTION_FOR_RANDOM(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProjectionForOldest(IUnmanagedTarget target)
{
- void* res = PROJECTION_FOR_OLDEST(target.Context, target.Target);
+ void* res = IgniteJni.PROJECTION_FOR_OLDEST(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static IUnmanagedTarget ProjectionForYoungest(IUnmanagedTarget target)
{
- void* res = PROJECTION_FOR_YOUNGEST(target.Context, target.Target);
+ void* res = IgniteJni.PROJECTION_FOR_YOUNGEST(target.Context, target.Target);
return target.ChangeTarget(res);
}
internal static void ProjectionResetMetrics(IUnmanagedTarget target)
{
- PROJECTION_RESET_METRICS(target.Context, target.Target);
+ IgniteJni.PROJECTION_RESET_METRICS(target.Context, target.Target);
}
internal static IUnmanagedTarget ProjectionOutOpRet(IUnmanagedTarget target, int type, long memPtr)
{
- void* res = PROJECTION_OUT_OP_RET(target.Context, target.Target, type, memPtr);
+ void* res = IgniteJni.PROJECTION_OUT_OP_RET(target.Context, target.Target, type, memPtr);
return target.ChangeTarget(res);
}
@@ -1002,12 +1013,12 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static void QueryCursorIterator(IUnmanagedTarget target)
{
- QryCursorIterator(target.Context, target.Target);
+ IgniteJni.QryCursorIterator(target.Context, target.Target);
}
internal static void QueryCursorClose(IUnmanagedTarget target)
{
- QryCursorClose(target.Context, target.Target);
+ IgniteJni.QryCursorClose(target.Context, target.Target);
}
#endregion
@@ -1016,47 +1027,47 @@ namespace Apache.Ignite.Core.Impl.Unmanaged
internal static long TransactionsStart(IUnmanagedTarget target, int concurrency, int isolation, long timeout, int txSize)
{
- return TxStart(target.Context, target.Target, concurrency, isolation, timeout, txSize);
+ return IgniteJni.TxStart(target.Context, target.Target, concurrency, isolation, timeout, txSize);
}
internal static int TransactionsCommit(IUnmanagedTarget target, long id)
{
- return TxCommit(target.Context, target.Target, id);
+ return IgniteJni.TxCommit(target.Context, target.Target, id);
}
internal static void TransactionsCommitAsync(IUnmanagedTarget target, long id, long futId)
{
- TxCommitAsync(target.Context, target.Target, id, futId);
+ IgniteJni.TxCommitAsync(target.Context, target.Target, id, futId);
}
internal static int TransactionsRollback(IUnmanagedTarget target, long id)
{
- return TxRollback(target.Context, target.Target, id);
+ return IgniteJni.TxRollback(target.Context, target.Target, id);
}
internal static void TransactionsRollbackAsync(IUnmanagedTarget target, long id, long futId)
{
- TxRollbackAsync(target.Context, target.Target, id, futId);
+ IgniteJni.TxRollbackAsync(target.Context, target.Target, id, futId);
}
internal static int TransactionsClose(IUnmanagedTarget target, long id)
{
- return TxClose(target.Context, target.Target, id);
+ return IgniteJni.TxClose(target.Context, target.Target, id);
}
internal static int TransactionsState(IUnmanagedTarget target, long id)
{
- return TxState(target.Context, target.Target, id);
+ return IgniteJni.TxState(target.Context, target.Target, id);
}
internal static bool TransactionsSetRollbackOnly(IUnmanagedTarget target, long id)
{
- return TxSetRollbackOnly(target.Context, target.Target, id);
+ return IgniteJni.TxSetRollbackOnly(target.Context, target.
<TRUNCATED>