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/09/18 12:04:06 UTC
[02/14] ignite git commit: IGNITE-1513: Merged Java to core module.
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
deleted file mode 100644
index 79759e9..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-import org.apache.ignite.lang.IgniteBiTuple;
-
-/**
- * Reader bi-closure.
- */
-public interface PlatformReaderBiClosure<T1, T2> {
- /**
- * Read object from reader.
- *
- * @param reader Reader.
- * @return Object.
- */
- IgniteBiTuple<T1, T2> read(PortableRawReaderEx reader);
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
deleted file mode 100644
index 2d9b44a..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-
-/**
- * Reader closure.
- */
-public interface PlatformReaderClosure<T> {
-
- /**
- * Read object from reader.
- *
- * @param reader Reader.
- * @return Object.
- */
- T read(PortableRawReaderEx reader);
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
deleted file mode 100644
index 11d8371..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
+++ /dev/null
@@ -1,812 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.Ignite;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.cache.CachePeekMode;
-import org.apache.ignite.internal.GridKernalContext;
-import org.apache.ignite.internal.IgniteKernal;
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-import org.apache.ignite.internal.processors.platform.PlatformContext;
-import org.apache.ignite.internal.processors.platform.PlatformExtendedException;
-import org.apache.ignite.internal.processors.platform.PlatformNativeException;
-import org.apache.ignite.internal.processors.platform.PlatformProcessor;
-import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream;
-import org.apache.ignite.internal.processors.platform.memory.PlatformMemory;
-import org.apache.ignite.internal.processors.platform.memory.PlatformMemoryUtils;
-import org.apache.ignite.internal.processors.platform.memory.PlatformOutputStream;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteBiTuple;
-import org.apache.ignite.lang.IgnitePredicate;
-import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.platform.dotnet.PlatformDotNetConfiguration;
-import org.apache.ignite.platform.dotnet.PlatformDotNetPortableConfiguration;
-import org.apache.ignite.platform.dotnet.PlatformDotNetPortableTypeConfiguration;
-import org.jetbrains.annotations.Nullable;
-
-import javax.cache.CacheException;
-import javax.cache.event.CacheEntryEvent;
-import javax.cache.event.CacheEntryListenerException;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PREFIX;
-
-/**
- * Platform utility methods.
- */
-@SuppressWarnings({"UnusedDeclaration", "unchecked"})
-public class PlatformUtils {
- /** Node attribute: platform. */
- public static final String ATTR_PLATFORM = ATTR_PREFIX + ".platform";
-
- /** Platform: CPP. */
- public static final String PLATFORM_CPP = "cpp";
-
- /** Platform: .Net. */
- public static final String PLATFORM_DOTNET = "dotnet";
-
- /** Operation: prepare .Net platform. */
- public static final int OP_PREPARE_DOT_NET = 1;
-
- /** Amount of peek modes available. */
- private static final int CACHE_PEEK_MODES_CNT = CachePeekMode.values().length;
-
- /** Cache peek modes. */
- private static volatile CachePeekMode[][] CACHE_PEEK_MODES;
-
- /**
- * Static initializer.
- */
- static {
- int len = 1 << CACHE_PEEK_MODES_CNT;
-
- synchronized (PlatformUtils.class) {
- CACHE_PEEK_MODES = new CachePeekMode[len][];
-
- CACHE_PEEK_MODES[0] = new CachePeekMode[0];
- }
- }
-
- /**
- * Write nullable collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- */
- public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col) {
- writeNullableCollection(writer, col, null, null);
- }
-
- /**
- * Write nullable collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- * @param writeClo Writer closure.
- */
- public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col,
- @Nullable PlatformWriterClosure<T> writeClo) {
- writeNullableCollection(writer, col, writeClo, null);
- }
-
- /**
- * Write collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- * @param writeClo Optional writer closure.
- * @param filter Optional filter.
- */
- public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col,
- @Nullable PlatformWriterClosure<T> writeClo, @Nullable IgnitePredicate<T> filter) {
- if (col != null) {
- writer.writeBoolean(true);
-
- writeCollection(writer, col, writeClo, filter);
- }
- else
- writer.writeBoolean(false);
- }
-
- /**
- * Write collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- */
- public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col) {
- writeCollection(writer, col, null, null);
- }
-
- /**
- * Write collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- * @param writeClo Writer closure.
- */
- public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col,
- @Nullable PlatformWriterClosure<T> writeClo) {
- writeCollection(writer, col, writeClo, null);
- }
-
- /**
- * Write collection to the writer.
- *
- * @param writer Writer.
- * @param col Collection to write.
- * @param writeClo Optional writer closure.
- * @param filter Optional filter.
- */
- public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col,
- @Nullable PlatformWriterClosure<T> writeClo, @Nullable IgnitePredicate<T> filter) {
- assert col != null;
-
- if (filter == null) {
- writer.writeInt(col.size());
-
- if (writeClo == null) {
- for (T entry : col)
- writer.writeObject(entry);
- }
- else {
- for (T entry : col)
- writeClo.write(writer, entry);
- }
- }
- else {
- int pos = writer.reserveInt();
- int cnt = 0;
-
- for (T entry : col) {
- if (filter.apply(entry)) {
- cnt++;
-
- if (writeClo == null)
- writer.writeObject(entry);
- else
- writeClo.write(writer, entry);
- }
- }
-
- writer.writeInt(pos, cnt);
- }
- }
-
- /**
- * Write nullable map to the writer.
- *
- * @param writer Writer.
- * @param map Map to write.
- */
- public static <K, V> void writeNullableMap(PortableRawWriterEx writer, @Nullable Map<K, V> map) {
- if (map != null) {
- writer.writeBoolean(true);
-
- writeMap(writer, map);
- }
- else
- writer.writeBoolean(false);
- }
-
- /**
- * Write nullable map to the writer.
- *
- * @param writer Writer.
- * @param map Map to write.
- */
- public static <K, V> void writeMap(PortableRawWriterEx writer, Map<K, V> map) {
- assert map != null;
-
- writeMap(writer, map, null);
- }
-
- /**
- * Write nullable map to the writer.
- *
- * @param writer Writer.
- * @param map Map to write.
- * @param writeClo Writer closure.
- */
- public static <K, V> void writeMap(PortableRawWriterEx writer, Map<K, V> map,
- @Nullable PlatformWriterBiClosure<K, V> writeClo) {
- assert map != null;
-
- writer.writeInt(map.size());
-
- if (writeClo == null) {
- for (Map.Entry<K, V> entry : map.entrySet()) {
- writer.writeObject(entry.getKey());
- writer.writeObject(entry.getValue());
- }
- }
- else {
- for (Map.Entry<K, V> entry : map.entrySet())
- writeClo.write(writer, entry.getKey(), entry.getValue());
- }
- }
-
- /**
- * Read collection.
- *
- * @param reader Reader.
- * @return List.
- */
- public static <T> List<T> readCollection(PortableRawReaderEx reader) {
- return readCollection(reader, null);
- }
-
- /**
- * Read collection.
- *
- * @param reader Reader.
- * @param readClo Optional reader closure.
- * @return List.
- */
- public static <T> List<T> readCollection(PortableRawReaderEx reader, @Nullable PlatformReaderClosure<T> readClo) {
- int cnt = reader.readInt();
-
- List<T> res = new ArrayList<>(cnt);
-
- if (readClo == null) {
- for (int i = 0; i < cnt; i++)
- res.add((T)reader.readObjectDetached());
- }
- else {
- for (int i = 0; i < cnt; i++)
- res.add(readClo.read(reader));
- }
-
- return res;
- }
-
- /**
- * Read nullable collection.
- *
- * @param reader Reader.
- * @return List.
- */
- public static <T> List<T> readNullableCollection(PortableRawReaderEx reader) {
- return readNullableCollection(reader, null);
- }
-
- /**
- * Read nullable collection.
- *
- * @param reader Reader.
- * @return List.
- */
- public static <T> List<T> readNullableCollection(PortableRawReaderEx reader,
- @Nullable PlatformReaderClosure<T> readClo) {
- if (!reader.readBoolean())
- return null;
-
- return readCollection(reader, readClo);
- }
-
- /**
- * @param reader Reader.
- * @return Set.
- */
- public static <T> Set<T> readSet(PortableRawReaderEx reader) {
- int cnt = reader.readInt();
-
- Set<T> res = U.newHashSet(cnt);
-
- for (int i = 0; i < cnt; i++)
- res.add((T)reader.readObjectDetached());
-
- return res;
- }
-
- /**
- * @param reader Reader.
- * @return Set.
- */
- public static <T> Set<T> readNullableSet(PortableRawReaderEx reader) {
- if (!reader.readBoolean())
- return null;
-
- return readSet(reader);
- }
-
- /**
- * Read map.
- *
- * @param reader Reader.
- * @return Map.
- */
- public static <K, V> Map<K, V> readMap(PortableRawReaderEx reader) {
- return readMap(reader, null);
- }
-
- /**
- * Read map.
- *
- * @param reader Reader.
- * @param readClo Reader closure.
- * @return Map.
- */
- public static <K, V> Map<K, V> readMap(PortableRawReaderEx reader,
- @Nullable PlatformReaderBiClosure<K, V> readClo) {
- int cnt = reader.readInt();
-
- Map<K, V> map = U.newHashMap(cnt);
-
- if (readClo == null) {
- for (int i = 0; i < cnt; i++)
- map.put((K)reader.readObjectDetached(), (V)reader.readObjectDetached());
- }
- else {
- for (int i = 0; i < cnt; i++) {
- IgniteBiTuple<K, V> entry = readClo.read(reader);
-
- map.put(entry.getKey(), entry.getValue());
- }
- }
-
- return map;
- }
-
- /**
- * Read nullable map.
- *
- * @param reader Reader.
- * @return Map.
- */
- public static <K, V> Map<K, V> readNullableMap(PortableRawReaderEx reader) {
- if (!reader.readBoolean())
- return null;
-
- return readMap(reader);
- }
-
- /**
- * Writes IgniteUuid to a writer.
- *
- * @param writer Writer.
- * @param val Values.
- */
- public static void writeIgniteUuid(PortableRawWriterEx writer, IgniteUuid val) {
- if (val == null)
- writer.writeUuid(null);
- else {
- writer.writeUuid(val.globalId());
- writer.writeLong(val.localId());
- }
- }
-
- /**
- * Convert native cache peek modes to Java cache peek modes.
- *
- * @param modes Encoded peek modes.
- * @return Cache peek modes.
- */
- public static CachePeekMode[] decodeCachePeekModes(int modes) {
- // 1. Try getting cache value.
- CachePeekMode[] res = CACHE_PEEK_MODES[modes];
-
- if (res == null) {
- // 2. Calculate modes from scratch.
- List<CachePeekMode> res0 = new ArrayList<>(CACHE_PEEK_MODES_CNT);
-
- for (int i = 0; i < CACHE_PEEK_MODES_CNT; i++) {
- int mask = 1 << i;
-
- if ((modes & mask) == mask)
- res0.add(CachePeekMode.fromOrdinal((byte)i));
- }
-
- res = res0.toArray(new CachePeekMode[res0.size()]);
-
- synchronized (PlatformUtils.class) {
- CACHE_PEEK_MODES[modes] = res;
- }
- }
-
- return res;
- }
-
- /**
- * Unwrap query exception.
- *
- * @param err Initial error.
- * @return Unwrapped error.
- */
- public static IgniteCheckedException unwrapQueryException(Throwable err) {
- assert err != null;
-
- Throwable parent = err;
- Throwable child = parent.getCause();
-
- while (true) {
- if (child == null || child == parent)
- break;
-
- if (child instanceof IgniteException || child instanceof IgniteCheckedException
- || child instanceof CacheException) {
- // Continue unwrapping.
- parent = child;
-
- child = parent.getCause();
-
- continue;
- }
-
- break;
- }
-
- // Specific exception found, but detailed message doesn't exist. Just pass exception name then.
- if (parent.getMessage() == null)
- return new IgniteCheckedException("Query execution failed due to exception: " +
- parent.getClass().getName(), err);
-
- return new IgniteCheckedException(parent.getMessage(), err);
- }
-
- /**
- * Apply continuous query events to listener.
- *
- * @param ctx Context.
- * @param lsnrPtr Listener pointer.
- * @param evts Events.
- * @throws javax.cache.event.CacheEntryListenerException In case of failure.
- */
- public static void applyContinuousQueryEvents(PlatformContext ctx, long lsnrPtr, Iterable<CacheEntryEvent> evts)
- throws CacheEntryListenerException {
- assert lsnrPtr != 0;
- assert evts != null;
-
- try (PlatformMemory mem = ctx.memory().allocate()) {
- PlatformOutputStream out = mem.output();
-
- PortableRawWriterEx writer = ctx.writer(out);
-
- int cntPos = writer.reserveInt();
-
- int cnt = 0;
-
- for (CacheEntryEvent evt : evts) {
- writeCacheEntryEvent(writer, evt);
-
- cnt++;
- }
-
- writer.writeInt(cntPos, cnt);
-
- out.synchronize();
-
- ctx.gateway().continuousQueryListenerApply(lsnrPtr, mem.pointer());
- }
- catch (Exception e) {
- throw toCacheEntryListenerException(e);
- }
- }
-
- /**
- * Evaluate the filter.
- *
- * @param ctx Context.
- * @param filterPtr Native filter pointer.
- * @param evt Event.
- * @return Result.
- * @throws CacheEntryListenerException In case of failure.
- */
- public static boolean evaluateContinuousQueryEvent(PlatformContext ctx, long filterPtr, CacheEntryEvent evt)
- throws CacheEntryListenerException {
- assert filterPtr != 0;
-
- try (PlatformMemory mem = ctx.memory().allocate()) {
- PlatformOutputStream out = mem.output();
-
- writeCacheEntryEvent(ctx.writer(out), evt);
-
- out.synchronize();
-
- return ctx.gateway().continuousQueryFilterApply(filterPtr, mem.pointer()) == 1;
- }
- catch (Exception e) {
- throw toCacheEntryListenerException(e);
- }
- }
-
- /**
- * Convert exception into listener exception.
- *
- * @param e Listener exception.
- * @return Exception.
- */
- private static CacheEntryListenerException toCacheEntryListenerException(Exception e) {
- assert e != null;
-
- return e instanceof CacheEntryListenerException ? (CacheEntryListenerException)e : e.getMessage() != null ?
- new CacheEntryListenerException(e.getMessage(), e) : new CacheEntryListenerException(e);
- }
-
- /**
- * Write event to the writer.
- *
- * @param writer Writer.
- * @param evt Event.
- */
- private static void writeCacheEntryEvent(PortableRawWriterEx writer, CacheEntryEvent evt) {
- writer.writeObjectDetached(evt.getKey());
- writer.writeObjectDetached(evt.getOldValue());
- writer.writeObjectDetached(evt.getValue());
- }
-
- /**
- * Writer error data.
- *
- * @param err Error.
- * @param writer Writer.
- */
- public static void writeErrorData(Throwable err, PortableRawWriterEx writer) {
- writeErrorData(err, writer, null);
- }
-
- /**
- * Write error data.
- * @param err Error.
- * @param writer Writer.
- * @param log Optional logger.
- */
- public static void writeErrorData(Throwable err, PortableRawWriterEx writer, @Nullable IgniteLogger log) {
- // Write additional data if needed.
- if (err instanceof PlatformExtendedException) {
- PlatformExtendedException err0 = (PlatformExtendedException)err;
-
- writer.writeBoolean(true); // Data exists.
-
- int pos = writer.out().position();
-
- try {
- writer.writeBoolean(true); // Optimistically assume that we will be able to write it.
- err0.writeData(writer);
- }
- catch (Exception e) {
- if (log != null)
- U.warn(log, "Failed to write interop exception data: " + e.getMessage(), e);
-
- writer.out().position(pos);
-
- writer.writeBoolean(false); // Error occurred.
- writer.writeString(e.getClass().getName());
-
- String innerMsg;
-
- try {
- innerMsg = e.getMessage();
- }
- catch (Exception innerErr) {
- innerMsg = "Exception message is not available.";
- }
-
- writer.writeString(innerMsg);
- }
- }
- else
- writer.writeBoolean(false);
- }
-
- /**
- * Get GridGain platform processor.
- *
- * @param grid Ignite instance.
- * @return Platform processor.
- */
- public static PlatformProcessor platformProcessor(Ignite grid) {
- GridKernalContext ctx = ((IgniteKernal) grid).context();
-
- return ctx.platform();
- }
-
- /**
- * Gets interop context for the grid.
- *
- * @param grid Grid
- * @return Context.
- */
- public static PlatformContext platformContext(Ignite grid) {
- return platformProcessor(grid).context();
- }
-
- /**
- * Reallocate arbitrary memory chunk.
- *
- * @param memPtr Memory pointer.
- * @param cap Capacity.
- */
- public static void reallocate(long memPtr, int cap) {
- PlatformMemoryUtils.reallocate(memPtr, cap);
- }
-
- /**
- * Get error data.
- *
- * @param err Error.
- * @return Error data.
- */
- @SuppressWarnings("UnusedDeclaration")
- public static byte[] errorData(Throwable err) {
- if (err instanceof PlatformExtendedException) {
- PlatformContext ctx = ((PlatformExtendedException)err).context();
-
- try (PlatformMemory mem = ctx.memory().allocate()) {
- // Write error data.
- PlatformOutputStream out = mem.output();
-
- PortableRawWriterEx writer = ctx.writer(out);
-
- try {
- PlatformUtils.writeErrorData(err, writer, ctx.kernalContext().log(PlatformContext.class));
- }
- finally {
- out.synchronize();
- }
-
- // Read error data into separate array.
- PlatformInputStream in = mem.input();
-
- in.synchronize();
-
- int len = in.remaining();
-
- assert len > 0;
-
- byte[] arr = in.array();
- byte[] res = new byte[len];
-
- System.arraycopy(arr, 0, res, 0, len);
-
- return res;
- }
- }
- else
- return null;
- }
-
- /**
- * Writes invocation result (of a job/service/etc) using a common protocol.
- *
- * @param writer Writer.
- * @param resObj Result.
- * @param err Error.
- */
- public static void writeInvocationResult(PortableRawWriterEx writer, Object resObj, Exception err)
- {
- if (err == null) {
- writer.writeBoolean(true);
- writer.writeObject(resObj);
- }
- else {
- writer.writeBoolean(false);
-
- PlatformNativeException nativeErr = null;
-
- if (err instanceof IgniteCheckedException)
- nativeErr = ((IgniteCheckedException)err).getCause(PlatformNativeException.class);
- else if (err instanceof IgniteException)
- nativeErr = ((IgniteException)err).getCause(PlatformNativeException.class);
-
- if (nativeErr == null) {
- writer.writeBoolean(false);
- writer.writeString(err.getClass().getName());
- writer.writeString(err.getMessage());
- }
- else {
- writer.writeBoolean(true);
- writer.writeObject(nativeErr.cause());
- }
- }
- }
-
- /**
- * Reads invocation result (of a job/service/etc) using a common protocol.
- *
- * @param ctx Platform context.
- * @param reader Reader.
- * @return Result.
- * @throws IgniteCheckedException When invocation result is an error.
- */
- public static Object readInvocationResult(PlatformContext ctx, PortableRawReaderEx reader)
- throws IgniteCheckedException {
- // 1. Read success flag.
- boolean success = reader.readBoolean();
-
- if (success)
- // 2. Return result as is.
- return reader.readObjectDetached();
- else {
- // 3. Read whether exception is in form of object or string.
- boolean hasException = reader.readBoolean();
-
- if (hasException) {
- // 4. Full exception.
- Object nativeErr = reader.readObjectDetached();
-
- assert nativeErr != null;
-
- throw ctx.createNativeException(nativeErr);
- }
- else {
- // 5. Native exception was not serializable, we have only message.
- String errMsg = reader.readString();
-
- assert errMsg != null;
-
- throw new IgniteCheckedException(errMsg);
- }
- }
- }
-
- /**
- * Write .Net configuration to the stream.
- *
- * @param writer Writer.
- * @param cfg Configuration.
- */
- public static void writeDotNetConfiguration(PortableRawWriterEx writer, PlatformDotNetConfiguration cfg) {
- // 1. Write assemblies.
- writeNullableCollection(writer, cfg.getAssemblies());
-
- PlatformDotNetPortableConfiguration portableCfg = cfg.getPortableConfiguration();
-
- if (portableCfg != null) {
- writer.writeBoolean(true);
-
- writeNullableCollection(writer, portableCfg.getTypesConfiguration(),
- new PlatformWriterClosure<PlatformDotNetPortableTypeConfiguration>() {
- @Override public void write(PortableRawWriterEx writer, PlatformDotNetPortableTypeConfiguration typ) {
- writer.writeString(typ.getAssemblyName());
- writer.writeString(typ.getTypeName());
- writer.writeString(typ.getNameMapper());
- writer.writeString(typ.getIdMapper());
- writer.writeString(typ.getSerializer());
- writer.writeString(typ.getAffinityKeyFieldName());
- writer.writeObject(typ.getMetadataEnabled());
- writer.writeObject(typ.getKeepDeserialized());
- }
- });
-
- writeNullableCollection(writer, portableCfg.getTypes());
- writer.writeString(portableCfg.getDefaultNameMapper());
- writer.writeString(portableCfg.getDefaultIdMapper());
- writer.writeString(portableCfg.getDefaultSerializer());
- writer.writeBoolean(portableCfg.isDefaultMetadataEnabled());
- writer.writeBoolean(portableCfg.isDefaultKeepDeserialized());
- }
- else
- writer.writeBoolean(false);
- }
-
- /**
- * Private constructor.
- */
- private PlatformUtils() {
- // No-op.
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
deleted file mode 100644
index 6b04ad3..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-
-/**
- * Interop writer bi-closure.
- */
-public interface PlatformWriterBiClosure<T1, T2> {
- /**
- * Write values.
- *
- * @param writer Writer.
- * @param val1 Value 1.
- * @param val2 Value 2.
- */
- public void write(PortableRawWriterEx writer, T1 val1, T2 val2);
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
deleted file mode 100644
index a67d70a..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
+++ /dev/null
@@ -1,33 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-
-/**
- * Interop writer closure.
- */
-public interface PlatformWriterClosure<T> {
- /**
- * Write value.
- *
- * @param writer Writer.
- * @param val Value.
- */
- public void write(PortableRawWriterEx writer, T val);
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
deleted file mode 100644
index 18f8a43..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.cpp;
-
-import org.apache.ignite.configuration.PlatformConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-/**
- * Platform CPP configuration.
- */
-public class PlatformCppConfiguration implements PlatformConfiguration {
- /**
- * Default constructor.
- */
- public PlatformCppConfiguration() {
- // No-op.
- }
-
- /**
- * Copying constructor.
- *
- * @param cfg Configuration to copy.
- */
- public PlatformCppConfiguration(PlatformConfiguration cfg) {
- // No-op.
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(PlatformConfiguration.class, this);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
deleted file mode 100644
index 6d745a7..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains C++ platform-related classes.
- */
-package org.apache.ignite.platform.cpp;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
deleted file mode 100644
index 97f0dce..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
+++ /dev/null
@@ -1,139 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.processors.platform.dotnet.PlatformDotNetCacheStore;
-
-import javax.cache.configuration.Factory;
-import java.util.Map;
-
-/**
- * Wrapper for .NET cache store implementations.
- * <p>
- * This wrapper should be used if you have an implementation of
- * {@code GridGain.Cache.IGridCacheStore} interface in .NET and
- * would like to configure it a persistence storage for your cache.
- * To do tis you will need to configure the wrapper via
- * {@link org.apache.ignite.configuration.CacheConfiguration#setCacheStoreFactory(javax.cache.configuration.Factory)} property
- * and provide assembly name and class name of your .NET store
- * implementation (both properties are mandatory):
- * <pre name="code" class="xml">
- * <bean class="org.apache.ignite.cache.CacheConfiguration">
- * ...
- * <property name="cacheStoreFactory">
- * <bean class="org.gridgain.grid.interop.dotnet.InteropDotNetCacheStoreFactory">
- * <property name="assemblyName" value="MyAssembly"/>
- * <property name="className" value="MyApp.MyCacheStore"/>
- * </bean>
- * </property>
- * ...
- * </bean>
- * </pre>
- * If properly configured, this wrapper will instantiate an instance
- * of your cache store in .NET and delegate all calls to that instance.
- * To create an instance, assembly name and class name are passed to
- * <a target="_blank" href="http://msdn.microsoft.com/en-us/library/d133hta4.aspx">System.Activator.CreateInstance(String, String)</a>
- * method in .NET during node startup. Refer to its documentation for
- * details.
- */
-public class PlatformDotNetCacheStoreFactory implements Factory<PlatformDotNetCacheStore> {
- /** */
- private static final long serialVersionUID = 0L;
-
- /** .Net assembly name. */
- private String assemblyName;
-
- /** .Net class name. */
- private String clsName;
-
- /** Properties. */
- private Map<String, ?> props;
-
- /** Instance. */
- private transient PlatformDotNetCacheStore instance;
-
- /**
- * Gets .NET assembly name.
- *
- * @return .NET assembly name.
- */
- public String getAssemblyName() {
- return assemblyName;
- }
-
- /**
- * Set .NET assembly name.
- *
- * @param assemblyName .NET assembly name.
- */
- public void setAssemblyName(String assemblyName) {
- this.assemblyName = assemblyName;
- }
-
- /**
- * Gets .NET class name.
- *
- * @return .NET class name.
- */
- public String getClassName() {
- return clsName;
- }
-
- /**
- * Sets .NET class name.
- *
- * @param clsName .NET class name.
- */
- public void setClassName(String clsName) {
- this.clsName = clsName;
- }
-
- /**
- * Get properties.
- *
- * @return Properties.
- */
- public Map<String, ?> getProperties() {
- return props;
- }
-
- /**
- * Set properties.
- *
- * @param props Properties.
- */
- public void setProperties(Map<String, ?> props) {
- this.props = props;
- }
-
- /** {@inheritDoc} */
- @SuppressWarnings("unchecked")
- @Override public PlatformDotNetCacheStore create() {
- synchronized (this) {
- if (instance == null) {
- instance = new PlatformDotNetCacheStore();
-
- instance.setAssemblyName(assemblyName);
- instance.setClassName(clsName);
- instance.setProperties(props);
- }
-
- return instance;
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
deleted file mode 100644
index 0550bab..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.configuration.PlatformConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Mirror of .Net class Configuration.cs
- */
-public class PlatformDotNetConfiguration implements PlatformConfiguration {
- /** */
- private PlatformDotNetPortableConfiguration portableCfg;
-
- /** */
- private List<String> assemblies;
-
- /**
- * Default constructor.
- */
- public PlatformDotNetConfiguration() {
- // No-op.
- }
-
- /**
- * Copy constructor.
- *
- * @param cfg Configuration to copy.
- */
- public PlatformDotNetConfiguration(PlatformDotNetConfiguration cfg) {
- if (cfg.getPortableConfiguration() != null)
- portableCfg = new PlatformDotNetPortableConfiguration(cfg.getPortableConfiguration());
-
- if (cfg.getAssemblies() != null)
- assemblies = new ArrayList<>(cfg.getAssemblies());
- }
-
- /**
- * @return Configuration.
- */
- public PlatformDotNetPortableConfiguration getPortableConfiguration() {
- return portableCfg;
- }
-
- /**
- * @param portableCfg Configuration.
- */
- public void setPortableConfiguration(PlatformDotNetPortableConfiguration portableCfg) {
- this.portableCfg = portableCfg;
- }
-
- /**
- * @return Assemblies.
- */
- public List<String> getAssemblies() {
- return assemblies;
- }
-
- /**
- *
- * @param assemblies Assemblies.
- */
- public void setAssemblies(List<String> assemblies) {
- this.assemblies = assemblies;
- }
-
- /**
- * @return Configuration copy.
- */
- @SuppressWarnings("UnusedDeclaration")
- private PlatformDotNetConfiguration copy() {
- return new PlatformDotNetConfiguration(this);
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(PlatformDotNetConfiguration.class, this);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
deleted file mode 100644
index 8e4b590..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
+++ /dev/null
@@ -1,109 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.processors.platform.lifecycle.PlatformLifecycleBean;
-import org.apache.ignite.lifecycle.LifecycleBean;
-
-import java.util.Map;
-
-/**
- * Lifecycle bean implementation which can be used to configure .Net lifecycle beans in Java Spring configuration.
- */
-public class PlatformDotNetLifecycleBean extends PlatformLifecycleBean implements LifecycleBean {
- /** Assembly name. */
- private String assemblyName;
-
- /** Class name. */
- private String clsName;
-
- /** Properties. */
- private Map<String, ?> props;
-
- /**
- * Constructor.
- */
- public PlatformDotNetLifecycleBean() {
- // No-op.
- }
-
- /**
- * Constructor.
- *
- * @param assemblyName Assembly name.
- * @param clsName Class name.
- */
- public PlatformDotNetLifecycleBean(String assemblyName, String clsName) {
- this.assemblyName = assemblyName;
- this.clsName = clsName;
- }
-
- /**
- * Get assembly name.
- *
- * @return Assembly name.
- */
- public String getAssemblyName() {
- return assemblyName;
- }
-
- /**
- * Set assembly name.
- *
- * @param assemblyName Assembly name.
- */
- public void setAssemblyName(String assemblyName) {
- this.assemblyName = assemblyName;
- }
-
- /**
- * Get class name.
- *
- * @return Class name.
- */
- public String getClassName() {
- return clsName;
- }
-
- /**
- * Set class name.
- *
- * @param clsName Class name.
- */
- public void setClassName(String clsName) {
- this.clsName = clsName;
- }
-
- /**
- * Get properties.
- *
- * @return Properties.
- */
- public Map<String, ?> getProperties() {
- return props;
- }
-
- /**
- * Set properties.
- *
- * @param props Properties.
- */
- public void setProperties(Map<String, ?> props) {
- this.props = props;
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
deleted file mode 100644
index dd7b988..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
+++ /dev/null
@@ -1,196 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-import java.util.ArrayList;
-import java.util.Collection;
-
-/**
- * Mirror of .Net class PortableConfiguration.cs
- */
-public class PlatformDotNetPortableConfiguration {
- /** Type cfgs. */
- private Collection<PlatformDotNetPortableTypeConfiguration> typesCfg;
-
- /** Types. */
- private Collection<String> types;
-
- /** Default name mapper. */
- private String dfltNameMapper;
-
- /** Default id mapper. */
- private String dfltIdMapper;
-
- /** Default serializer. */
- private String dfltSerializer;
-
- /** Default metadata enabled. */
- private boolean dfltMetadataEnabled = true;
-
- /** Whether to cache deserialized value in IGridPortableObject */
- private boolean dfltKeepDeserialized = true;
-
- /**
- * Default constructor.
- */
- public PlatformDotNetPortableConfiguration() {
- // No-op.
- }
-
- /**
- * Copy constructor.
- * @param cfg configuration to copy.
- */
- public PlatformDotNetPortableConfiguration(PlatformDotNetPortableConfiguration cfg) {
- if (cfg.getTypesConfiguration() != null) {
- typesCfg = new ArrayList<>();
-
- for (PlatformDotNetPortableTypeConfiguration typeCfg : cfg.getTypesConfiguration())
- typesCfg.add(new PlatformDotNetPortableTypeConfiguration(typeCfg));
- }
-
- if (cfg.getTypes() != null)
- types = new ArrayList<>(cfg.getTypes());
-
- dfltNameMapper = cfg.getDefaultNameMapper();
- dfltIdMapper = cfg.getDefaultIdMapper();
- dfltSerializer = cfg.getDefaultSerializer();
- dfltMetadataEnabled = cfg.isDefaultMetadataEnabled();
- dfltKeepDeserialized = cfg.isDefaultKeepDeserialized();
- }
-
- /**
- * @return Type cfgs.
- */
- public Collection<PlatformDotNetPortableTypeConfiguration> getTypesConfiguration() {
- return typesCfg;
- }
-
- /**
- * @param typesCfg New type cfgs.
- */
- public void setTypesConfiguration(Collection<PlatformDotNetPortableTypeConfiguration> typesCfg) {
- this.typesCfg = typesCfg;
- }
-
- /**
- * @return Types.
- */
- public Collection<String> getTypes() {
- return types;
- }
-
- /**
- * @param types New types.
- */
- public void setTypes(Collection<String> types) {
- this.types = types;
- }
-
- /**
- * @return Default name mapper.
- */
- public String getDefaultNameMapper() {
- return dfltNameMapper;
- }
-
- /**
- * @param dfltNameMapper New default name mapper.
- */
- public void setDefaultNameMapper(String dfltNameMapper) {
- this.dfltNameMapper = dfltNameMapper;
- }
-
- /**
- * @return Default id mapper.
- */
- public String getDefaultIdMapper() {
- return dfltIdMapper;
- }
-
- /**
- * @param dfltIdMapper New default id mapper.
- */
- public void setDefaultIdMapper(String dfltIdMapper) {
- this.dfltIdMapper = dfltIdMapper;
- }
-
- /**
- * @return Default serializer.
- */
- public String getDefaultSerializer() {
- return dfltSerializer;
- }
-
- /**
- * @param dfltSerializer New default serializer.
- */
- public void setDefaultSerializer(String dfltSerializer) {
- this.dfltSerializer = dfltSerializer;
- }
-
- /**
- * Gets default metadata enabled flag. See {@link #setDefaultMetadataEnabled(boolean)} for more information.
- *
- * @return Default metadata enabled flag.
- */
- public boolean isDefaultMetadataEnabled() {
- return dfltMetadataEnabled;
- }
-
- /**
- * Sets default metadata enabled flag. When set to {@code true} all portable types will save it's metadata to
- * cluster.
- * <p />
- * Can be overridden for particular type using
- * {@link PlatformDotNetPortableTypeConfiguration#setMetadataEnabled(Boolean)}.
- *
- * @param dfltMetadataEnabled Default metadata enabled flag.
- */
- public void setDefaultMetadataEnabled(boolean dfltMetadataEnabled) {
- this.dfltMetadataEnabled = dfltMetadataEnabled;
- }
-
- /**
- * Gets default keep deserialized flag. See {@link #setDefaultKeepDeserialized(boolean)} for more information.
- *
- * @return Flag indicates whether to cache deserialized value in IGridPortableObject.
- */
- public boolean isDefaultKeepDeserialized() {
- return dfltKeepDeserialized;
- }
-
- /**
- * Sets default keep deserialized flag.
- * <p />
- * Can be overridden for particular type using
- * {@link PlatformDotNetPortableTypeConfiguration#setKeepDeserialized(Boolean)}.
- *
- * @param keepDeserialized Keep deserialized flag.
- */
- public void setDefaultKeepDeserialized(boolean keepDeserialized) {
- this.dfltKeepDeserialized = keepDeserialized;
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(PlatformDotNetPortableConfiguration.class, this);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
deleted file mode 100644
index b04d2a7..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
+++ /dev/null
@@ -1,214 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.util.typedef.internal.S;
-import org.jetbrains.annotations.Nullable;
-
-/**
- * Mirror of .Net class GridDotNetPortableTypeConfiguration.cs
- */
-public class PlatformDotNetPortableTypeConfiguration {
- /** Assembly name. */
- private String assemblyName;
-
- /** Type name. */
- private String typeName;
-
- /** Name mapper. */
- private String nameMapper;
-
- /** Id mapper. */
- private String idMapper;
-
- /** Serializer. */
- private String serializer;
-
- /** Affinity key field name. */
- private String affinityKeyFieldName;
-
- /** Metadata enabled. */
- private Boolean metadataEnabled;
-
- /** Whether to cache deserialized value in IGridPortableObject. */
- private Boolean keepDeserialized;
-
- /**
- * Default constructor.
- */
- public PlatformDotNetPortableTypeConfiguration() {
- // No-op.
- }
-
- /**
- * Copy constructor.
- * @param cfg configuration to copy.
- */
- public PlatformDotNetPortableTypeConfiguration(PlatformDotNetPortableTypeConfiguration cfg) {
- assemblyName = cfg.getAssemblyName();
- typeName = cfg.getTypeName();
- nameMapper = cfg.getNameMapper();
- idMapper = cfg.getIdMapper();
- serializer = cfg.getSerializer();
- affinityKeyFieldName = cfg.getAffinityKeyFieldName();
- metadataEnabled = cfg.getMetadataEnabled();
- keepDeserialized = cfg.isKeepDeserialized();
- }
-
- /**
- * @return Assembly name.
- */
- public String getAssemblyName() {
- return assemblyName;
- }
-
- /**
- * @param assemblyName New assembly name.
- */
- public void setAssemblyName(String assemblyName) {
- this.assemblyName = assemblyName;
- }
-
- /**
- * @return Type name.
- */
- public String getTypeName() {
- return typeName;
- }
-
- /**
- * @param typeName New type name.
- */
- public void setTypeName(String typeName) {
- this.typeName = typeName;
- }
-
- /**
- * @return Name mapper.
- */
- public String getNameMapper() {
- return nameMapper;
- }
-
- /**
- * @param nameMapper New name mapper.
- */
- public void setNameMapper(String nameMapper) {
- this.nameMapper = nameMapper;
- }
-
- /**
- * @return Id mapper.
- */
- public String getIdMapper() {
- return idMapper;
- }
-
- /**
- * @param idMapper New id mapper.
- */
- public void setIdMapper(String idMapper) {
- this.idMapper = idMapper;
- }
-
- /**
- * @return Serializer.
- */
- public String getSerializer() {
- return serializer;
- }
-
- /**
- * @param serializer New serializer.
- */
- public void setSerializer(String serializer) {
- this.serializer = serializer;
- }
-
- /**
- * Gets metadata enabled flag. See {@link #setMetadataEnabled(Boolean)} for more information.
- *
- * @return Metadata enabled flag.
- */
- public Boolean getMetadataEnabled() {
- return metadataEnabled;
- }
-
- /**
- * Sets metadata enabled flag.
- * <p />
- * When set to {@code null} default value taken from
- * {@link PlatformDotNetPortableConfiguration#isDefaultMetadataEnabled()} will be used.
- *
- * @param metadataEnabled New metadata enabled.
- */
- public void setMetadataEnabled(Boolean metadataEnabled) {
- this.metadataEnabled = metadataEnabled;
- }
-
- /**
- * @return Affinity key field name.
- */
- public String getAffinityKeyFieldName() {
- return affinityKeyFieldName;
- }
-
- /**
- * @param affinityKeyFieldName Affinity key field name.
- */
- public void setAffinityKeyFieldName(String affinityKeyFieldName) {
- this.affinityKeyFieldName = affinityKeyFieldName;
- }
-
- /**
- * Gets keep deserialized flag.
- *
- * @return Flag indicates whether to cache deserialized value in IGridPortableObject.
- * @deprecated Use {@link #getKeepDeserialized()} instead.
- */
- @Deprecated
- @Nullable public Boolean isKeepDeserialized() {
- return keepDeserialized;
- }
-
- /**
- * Gets keep deserialized flag. See {@link #setKeepDeserialized(Boolean)} for more information.
- *
- * @return Flag indicates whether to cache deserialized value in IGridPortableObject.
- */
- @Nullable public Boolean getKeepDeserialized() {
- return keepDeserialized;
- }
-
- /**
- * Sets keep deserialized flag.
- * <p />
- * When set to {@code null} default value taken from
- * {@link PlatformDotNetPortableConfiguration#isDefaultKeepDeserialized()} will be used.
- *
- * @param keepDeserialized Keep deserialized flag.
- */
- public void setKeepDeserialized(@Nullable Boolean keepDeserialized) {
- this.keepDeserialized = keepDeserialized;
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(PlatformDotNetPortableTypeConfiguration.class, this);
- }
-}
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
deleted file mode 100644
index 0765e01..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains .Net platform-related classes.
- */
-package org.apache.ignite.platform.dotnet;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
deleted file mode 100644
index ac89b58..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains platform-related classes.
- */
-package org.apache.ignite.platform;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
deleted file mode 100644
index c721e16..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.Ignite;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.resources.IgniteInstanceResource;
-import org.jetbrains.annotations.Nullable;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-
-/**
- * Task collecting IDs of all nodes where it was executed.
- */
-public class PlatformComputeBroadcastTask extends ComputeTaskAdapter<Object, Collection<UUID>> {
- /** {@inheritDoc} */
- @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) {
- Map<ComputeJob, ClusterNode> jobs = new HashMap<>();
-
- for (ClusterNode node : subgrid)
- jobs.put(new BroadcastJob(), node);
-
- return jobs;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public Collection<UUID> reduce(List<ComputeJobResult> results) {
- List<UUID> ids = new ArrayList<>();
-
- for (ComputeJobResult res : results)
- ids.add((UUID)res.getData());
-
- return ids;
- }
-
- /**
- * Job.
- */
- private static class BroadcastJob extends ComputeJobAdapter {
- /** */
- @IgniteInstanceResource
- private Ignite ignite;
-
- /** {@inheritDoc} */
- @Nullable @Override public Object execute() {
- return ignite.cluster().localNode().id();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
deleted file mode 100644
index a14e481..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
+++ /dev/null
@@ -1,106 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.internal.util.typedef.F;
-import org.jetbrains.annotations.Nullable;
-
-import java.io.Externalizable;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
-import java.math.BigDecimal;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-@SuppressWarnings({"ConstantConditions", "UnusedDeclaration"})
-public class PlatformComputeDecimalTask extends ComputeTaskAdapter<Object[], BigDecimal> {
- /** {@inheritDoc} */
- @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object[] arg) {
- return Collections.singletonMap(new DecimalJob((BigDecimal)arg[0], (String)arg[1]), F.first(subgrid));
- }
-
- /** {@inheritDoc} */
- @SuppressWarnings("ThrowableResultOfMethodCallIgnored")
- @Nullable @Override public BigDecimal reduce(List<ComputeJobResult> results) {
- ComputeJobResult res = results.get(0);
-
- if (res.getException() != null)
- throw res.getException();
- else
- return results.get(0).getData();
- }
-
- /**
- * Job.
- */
- private static class DecimalJob extends ComputeJobAdapter implements Externalizable {
- /** Value. */
- private BigDecimal val;
-
- /** Value as string. */
- private String valStr;
-
- /**
- * Constructor.
- */
- public DecimalJob() {
- // No-op.
- }
-
- /**
- * Constructor.
- *
- * @param val Value.
- * @param valStr Value as string.
- */
- private DecimalJob(BigDecimal val, String valStr) {
- this.val = val;
- this.valStr = valStr;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public Object execute() {
- BigDecimal exp = new BigDecimal(valStr.replace(',', '.'));
-
- if (val != null && !exp.equals(val))
- throw new IgniteException("Actual=" + val);
-
- return exp;
- }
-
- /** {@inheritDoc} */
- @Override public void writeExternal(ObjectOutput out) throws IOException {
- out.writeObject(val);
- out.writeObject(valStr);
- }
-
- /** {@inheritDoc} */
- @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
- val = (BigDecimal)in.readObject();
- valStr = (String)in.readObject();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
deleted file mode 100644
index f64ca7d..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.internal.util.typedef.F;
-import org.jetbrains.annotations.Nullable;
-
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-/**
- * Test task producing result without any arguments.
- */
-public class PlatformComputeEchoTask extends ComputeTaskAdapter<Integer, Object> {
- /** Type: NULL. */
- private static final int TYPE_NULL = 0;
-
- /** Type: byte. */
- private static final int TYPE_BYTE = 1;
-
- /** Type: bool. */
- private static final int TYPE_BOOL = 2;
-
- /** Type: short. */
- private static final int TYPE_SHORT = 3;
-
- /** Type: char. */
- private static final int TYPE_CHAR = 4;
-
- /** Type: int. */
- private static final int TYPE_INT = 5;
-
- /** Type: long. */
- private static final int TYPE_LONG = 6;
-
- /** Type: float. */
- private static final int TYPE_FLOAT = 7;
-
- /** Type: double. */
- private static final int TYPE_DOUBLE = 8;
-
- /** Type: array. */
- private static final int TYPE_ARRAY = 9;
-
- /** Type: collection. */
- private static final int TYPE_COLLECTION = 10;
-
- /** Type: map. */
- private static final int TYPE_MAP = 11;
-
- /** Type: portable object which exists in all platforms. */
- private static final int TYPE_PORTABLE = 12;
-
- /** Type: portable object which exists only in Java. */
- private static final int TYPE_PORTABLE_JAVA = 13;
-
- /** Type: object array. */
- private static final int TYPE_OBJ_ARRAY = 14;
-
- /** Type: portable object array. */
- private static final int TYPE_PORTABLE_ARRAY = 15;
-
- /** Type: enum. */
- private static final int TYPE_ENUM = 16;
-
- /** Type: enum array. */
- private static final int TYPE_ENUM_ARRAY = 17;
-
- /** {@inheritDoc} */
- @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,
- @Nullable Integer arg) {
- return Collections.singletonMap(new EchoJob(arg), F.first(subgrid));
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public Object reduce(List<ComputeJobResult> results) {
- return results.get(0).getData();
- }
-
- /**
- * Job.
- */
- private static class EchoJob extends ComputeJobAdapter {
- /** Type. */
- private Integer type;
-
- /**
- * Constructor.
- *
- * @param type Result type.
- */
- public EchoJob(Integer type) {
- this.type = type;
- }
-
- /** {@inheritDoc} */
- @Nullable @Override public Object execute() {
- switch (type) {
- case TYPE_NULL:
- return null;
-
- case TYPE_BYTE:
- return (byte)1;
-
- case TYPE_BOOL:
- return true;
-
- case TYPE_SHORT:
- return (short)1;
-
- case TYPE_CHAR:
- return (char)1;
-
- case TYPE_INT:
- return 1;
-
- case TYPE_LONG:
- return (long)1;
-
- case TYPE_FLOAT:
- return (float)1;
-
- case TYPE_DOUBLE:
- return (double)1;
-
- case TYPE_ARRAY:
- return new int[] { 1 };
-
- case TYPE_COLLECTION:
- return Collections.singletonList(1);
-
- case TYPE_MAP:
- return Collections.singletonMap(1, 1);
-
- case TYPE_PORTABLE:
- return new PlatformComputePortable(1);
-
- case TYPE_PORTABLE_JAVA:
- return new PlatformComputeJavaPortable(1);
-
- case TYPE_OBJ_ARRAY:
- return new String[] { "foo", "bar", "baz" };
-
- case TYPE_PORTABLE_ARRAY:
- return new PlatformComputePortable[] {
- new PlatformComputePortable(1),
- new PlatformComputePortable(2),
- new PlatformComputePortable(3)
- };
-
- case TYPE_ENUM:
- return PlatformComputeEnum.BAR;
-
- case TYPE_ENUM_ARRAY:
- return new PlatformComputeEnum[] {
- PlatformComputeEnum.BAR,
- PlatformComputeEnum.BAZ,
- PlatformComputeEnum.FOO
- };
-
- default:
- throw new IgniteException("Unknown type: " + type);
- }
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
deleted file mode 100644
index 7fc0623..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Test enum.
- */
-public enum PlatformComputeEnum
-{
- FOO,
- BAR,
- BAZ
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
deleted file mode 100644
index 7a940c4..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Portable object defined only in Java.
- */
-public class PlatformComputeJavaPortable extends PlatformComputePortable {
- /**
- * Constructor.
- */
- public PlatformComputeJavaPortable() {
- // No-op.
- }
-
- /**
- * Constructor.
- *
- * @param field Field.
- */
- public PlatformComputeJavaPortable(int field) {
- super(field);
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
deleted file mode 100644
index f31f093..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Portable object for task tests.
- */
-public class PlatformComputePortable {
- /** Field. */
- public int field;
-
- /**
- * Constructor.
- */
- public PlatformComputePortable() {
- // No-op.
- }
-
- /**
- * Constructor,
- *
- * @param field Field.
- */
- public PlatformComputePortable(int field) {
- this.field = field;
- }
-}
\ No newline at end of file