http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/affinity/PlatformAffinity.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/affinity/PlatformAffinity.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/affinity/PlatformAffinity.java index 0d2098b..c4e0350 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/affinity/PlatformAffinity.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/affinity/PlatformAffinity.java @@ -25,8 +25,8 @@ import org.apache.ignite.cache.affinity.Affinity; import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.utils.PlatformUtils; @@ -114,7 +114,7 @@ public class PlatformAffinity extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) throws IgniteCheckedException { + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_PARTITION: return aff.partition(reader.readObjectDetached()); @@ -165,7 +165,7 @@ public class PlatformAffinity extends PlatformAbstractTarget { /** {@inheritDoc} */ @SuppressWarnings({"IfMayBeConditional", "ConstantConditions"}) - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_PRIMARY_PARTITIONS: {
http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java index 6c2c873..8c24d23 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java @@ -19,7 +19,7 @@ package org.apache.ignite.internal.processors.platform.cache.query; import java.util.Iterator; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.cache.query.QueryCursorEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; @@ -62,7 +62,7 @@ public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTar } /** {@inheritDoc} */ - @Override protected void processOutStream(int type, final PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processOutStream(int type, final BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_GET_BATCH: { assert iter != null : "iterator() has not been called"; @@ -157,7 +157,7 @@ public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTar * @param writer Writer. * @param val Value. */ - protected abstract void write(PortableRawWriterEx writer, T val); + protected abstract void write(BinaryRawWriterEx writer, T val); /** * Query cursor consumer. @@ -167,7 +167,7 @@ public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTar private final PlatformAbstractQueryCursor<T> cursor; /** Writer. */ - private final PortableRawWriterEx writer; + private final BinaryRawWriterEx writer; /** Count. */ private int cnt; @@ -177,7 +177,7 @@ public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTar * * @param writer Writer. */ - public Consumer(PlatformAbstractQueryCursor<T> cursor, PortableRawWriterEx writer) { + public Consumer(PlatformAbstractQueryCursor<T> cursor, BinaryRawWriterEx writer) { this.cursor = cursor; this.writer = writer; } http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryRemoteFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryRemoteFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryRemoteFilter.java index 71aa38c..9f67118 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryRemoteFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformContinuousQueryRemoteFilter.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.cache.query; import org.apache.ignite.Ignite; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; import org.apache.ignite.internal.processors.platform.memory.PlatformOutputStream; @@ -115,7 +115,7 @@ public class PlatformContinuousQueryRemoteFilter implements PlatformContinuousQu try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(filter); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformFieldsQueryCursor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformFieldsQueryCursor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformFieldsQueryCursor.java index 44a4f14..035e927 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformFieldsQueryCursor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformFieldsQueryCursor.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.cache.query; import java.util.List; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.cache.query.QueryCursorEx; import org.apache.ignite.internal.processors.platform.PlatformContext; @@ -38,7 +38,7 @@ public class PlatformFieldsQueryCursor extends PlatformAbstractQueryCursor<List< } /** {@inheritDoc} */ - @Override protected void write(PortableRawWriterEx writer, List vals) { + @Override protected void write(BinaryRawWriterEx writer, List vals) { assert vals != null; writer.writeInt(vals.size()); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformQueryCursor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformQueryCursor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformQueryCursor.java index 410e4de..fe94e65 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformQueryCursor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformQueryCursor.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.cache.query; import javax.cache.Cache; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.cache.query.QueryCursorEx; import org.apache.ignite.internal.processors.platform.PlatformContext; @@ -38,7 +38,7 @@ public class PlatformQueryCursor extends PlatformAbstractQueryCursor<Cache.Entry } /** {@inheritDoc} */ - @Override protected void write(PortableRawWriterEx writer, Cache.Entry val) { + @Override protected void write(BinaryRawWriterEx writer, Cache.Entry val) { writer.writeObjectDetached(val.getKey()); writer.writeObjectDetached(val.getValue()); } http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/store/PlatformCacheStoreCallback.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/store/PlatformCacheStoreCallback.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/store/PlatformCacheStoreCallback.java index a741f0f..45110ce 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/store/PlatformCacheStoreCallback.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/store/PlatformCacheStoreCallback.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.processors.platform.cache.store; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -45,7 +45,7 @@ public abstract class PlatformCacheStoreCallback { public void invoke(long memPtr) { if (memPtr > 0) { try (PlatformMemory mem = ctx.memory().get(memPtr)) { - PortableRawReaderEx reader = ctx.reader(mem); + BinaryRawReaderEx reader = ctx.reader(mem); invoke0(reader); } @@ -57,5 +57,5 @@ public abstract class PlatformCacheStoreCallback { * * @param reader Reader. */ - protected abstract void invoke0(PortableRawReaderEx reader); + protected abstract void invoke0(BinaryRawReaderEx reader); } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java index a1c8516..fc47a4b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java @@ -24,8 +24,8 @@ import org.apache.ignite.IgniteCluster; import org.apache.ignite.cluster.ClusterMetrics; import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.internal.cluster.ClusterGroupEx; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.utils.PlatformUtils; @@ -94,7 +94,7 @@ public class PlatformClusterGroup extends PlatformAbstractTarget { /** {@inheritDoc} */ @SuppressWarnings("deprecation") - @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_METRICS: platformCtx.writeClusterMetrics(writer, prj.metrics()); @@ -113,7 +113,7 @@ public class PlatformClusterGroup extends PlatformAbstractTarget { /** {@inheritDoc} */ @SuppressWarnings({"ConstantConditions", "deprecation"}) - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_METRICS_FILTERED: { @@ -194,7 +194,7 @@ public class PlatformClusterGroup extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) throws IgniteCheckedException { + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_PING_NODE: return pingNode(reader.readUuid()) ? TRUE : FALSE; @@ -205,7 +205,7 @@ public class PlatformClusterGroup extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected Object processInStreamOutObject(int type, PortableRawReaderEx reader) throws IgniteCheckedException { + @Override protected Object processInStreamOutObject(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_FOR_NODE_IDS: { Collection<UUID> ids = PlatformUtils.readCollection(reader); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterNodeFilterImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterNodeFilterImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterNodeFilterImpl.java index 5ba9a85..92aabd8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterNodeFilterImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterNodeFilterImpl.java @@ -19,7 +19,7 @@ package org.apache.ignite.internal.processors.platform.cluster; import org.apache.ignite.Ignite; import org.apache.ignite.cluster.ClusterNode; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractPredicate; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -56,7 +56,7 @@ public class PlatformClusterNodeFilterImpl extends PlatformAbstractPredicate imp try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(pred); ctx.writeNode(writer, clusterNode); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractJob.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractJob.java index bf9d9e4..462f2c4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractJob.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractJob.java @@ -20,7 +20,7 @@ package org.apache.ignite.internal.processors.platform.compute; import java.io.Externalizable; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.PlatformProcessor; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -105,7 +105,7 @@ public abstract class PlatformAbstractJob implements PlatformJob, Externalizable try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(job); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractTask.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractTask.java index b17dd97..c293c51 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformAbstractTask.java @@ -24,7 +24,7 @@ import org.apache.ignite.IgniteException; import org.apache.ignite.compute.ComputeJobResult; import org.apache.ignite.compute.ComputeJobResultPolicy; import org.apache.ignite.compute.ComputeTask; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.PlatformNativeException; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -86,7 +86,7 @@ public abstract class PlatformAbstractTask implements ComputeTask<Object, Void> try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeUuid(res.getNode().id()); writer.writeBoolean(res.isCancelled()); @@ -151,7 +151,7 @@ public abstract class PlatformAbstractTask implements ComputeTask<Object, Void> try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); if (e0 == null) { writer.writeBoolean(false); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformClosureJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformClosureJob.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformClosureJob.java index 9bd7d60..b35f31c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformClosureJob.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformClosureJob.java @@ -21,7 +21,7 @@ import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -69,7 +69,7 @@ public class PlatformClosureJob extends PlatformAbstractJob { in.synchronize(); - PortableRawReaderEx reader = ctx.reader(in); + BinaryRawReaderEx reader = ctx.reader(in); return PlatformUtils.readInvocationResult(ctx, reader); } http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformCompute.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformCompute.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformCompute.java index 638b4b1..05db49d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformCompute.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformCompute.java @@ -25,15 +25,15 @@ import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteCompute; import org.apache.ignite.internal.IgniteComputeImpl; import org.apache.ignite.internal.IgniteInternalFuture; -import org.apache.ignite.internal.portable.PortableObjectImpl; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryObjectImpl; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.util.typedef.C1; import org.apache.ignite.lang.IgniteFuture; import org.apache.ignite.lang.IgniteInClosure; -import org.apache.ignite.portable.PortableObject; +import org.apache.ignite.binary.BinaryObject; import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_SUBGRID; @@ -75,7 +75,7 @@ public class PlatformCompute extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) throws IgniteCheckedException { + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_UNICAST: processClosures(reader.readLong(), reader, false, false); @@ -104,7 +104,7 @@ public class PlatformCompute extends PlatformAbstractTarget { * @param reader Reader. * @param broadcast broadcast flag. */ - private void processClosures(long taskPtr, PortableRawReaderEx reader, boolean broadcast, boolean affinity) { + private void processClosures(long taskPtr, BinaryRawReaderEx reader, boolean broadcast, boolean affinity) { PlatformAbstractTask task; int size = reader.readInt(); @@ -165,12 +165,12 @@ public class PlatformCompute extends PlatformAbstractTarget { * @param reader Reader. * @return Closure job. */ - private PlatformJob nextClosureJob(PlatformAbstractTask task, PortableRawReaderEx reader) { + private PlatformJob nextClosureJob(PlatformAbstractTask task, BinaryRawReaderEx reader) { return platformCtx.createClosureJob(task, reader.readLong(), reader.readObjectDetached()); } /** {@inheritDoc} */ - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_EXEC: @@ -256,7 +256,7 @@ public class PlatformCompute extends PlatformAbstractTarget { * @param reader Reader. * @return Task result. */ - protected Object executeJavaTask(PortableRawReaderEx reader, boolean async) { + protected Object executeJavaTask(BinaryRawReaderEx reader, boolean async) { String taskName = reader.readString(); boolean keepPortable = reader.readBoolean(); Object arg = reader.readObjectDetached(); @@ -268,8 +268,8 @@ public class PlatformCompute extends PlatformAbstractTarget { if (async) compute0 = compute0.withAsync(); - if (!keepPortable && arg instanceof PortableObjectImpl) - arg = ((PortableObject)arg).deserialize(); + if (!keepPortable && arg instanceof BinaryObjectImpl) + arg = ((BinaryObject)arg).deserialize(); Object res = compute0.execute(taskName, arg); @@ -295,7 +295,7 @@ public class PlatformCompute extends PlatformAbstractTarget { * @return Result. */ private Object toPortable(Object src) { - return platformCtx.kernalContext().grid().portables().toPortable(src); + return platformCtx.kernalContext().grid().binary().toBinary(src); } /** @@ -304,7 +304,7 @@ public class PlatformCompute extends PlatformAbstractTarget { * @param reader Reader. * @return Node IDs. */ - protected Collection<UUID> readNodeIds(PortableRawReaderEx reader) { + protected Collection<UUID> readNodeIds(BinaryRawReaderEx reader) { if (reader.readBoolean()) { int len = reader.readInt(); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullJob.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullJob.java index cfed735..9302c03 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullJob.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullJob.java @@ -21,7 +21,7 @@ import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.PlatformProcessor; import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream; @@ -120,7 +120,7 @@ public class PlatformFullJob extends PlatformAbstractJob { in.synchronize(); - PortableRawReaderEx reader = ctx.reader(in); + BinaryRawReaderEx reader = ctx.reader(in); return PlatformUtils.readInvocationResult(ctx, reader); } @@ -209,7 +209,7 @@ public class PlatformFullJob extends PlatformAbstractJob { in.synchronize(); - PortableRawReaderEx reader = ctx.reader(in); + BinaryRawReaderEx reader = ctx.reader(in); if (res) job = reader.readObjectDetached(); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java index b96d445..d789003 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/compute/PlatformFullTask.java @@ -27,8 +27,8 @@ import org.apache.ignite.compute.ComputeJob; import org.apache.ignite.compute.ComputeTaskNoResultCache; import org.apache.ignite.internal.IgniteComputeImpl; import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -83,7 +83,7 @@ public final class PlatformFullTask extends PlatformAbstractTask { try (PlatformMemory outMem = memMgr.allocate()) { PlatformOutputStream out = outMem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); write(writer, nodes, subgrid); @@ -96,7 +96,7 @@ public final class PlatformFullTask extends PlatformAbstractTask { in.synchronize(); - PortableRawReaderEx reader = ctx.reader(in); + BinaryRawReaderEx reader = ctx.reader(in); return read(reader, nodes); } @@ -114,7 +114,7 @@ public final class PlatformFullTask extends PlatformAbstractTask { * @param nodes Current topology nodes. * @param subgrid Subgrid. */ - private void write(PortableRawWriterEx writer, Collection<ClusterNode> nodes, List<ClusterNode> subgrid) { + private void write(BinaryRawWriterEx writer, Collection<ClusterNode> nodes, List<ClusterNode> subgrid) { GridDiscoveryManager discoMgr = ctx.kernalContext().discovery(); long curTopVer = discoMgr.topologyVersion(); @@ -145,7 +145,7 @@ public final class PlatformFullTask extends PlatformAbstractTask { * @param nodes Current topology nodes. * @return Map result. */ - private Map<ComputeJob, ClusterNode> read(PortableRawReaderEx reader, Collection<ClusterNode> nodes) { + private Map<ComputeJob, ClusterNode> read(BinaryRawReaderEx reader, Collection<ClusterNode> nodes) { if (reader.readBoolean()) { if (!reader.readBoolean()) return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java index ef64ef9..794ab0b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java @@ -24,13 +24,14 @@ import org.apache.ignite.events.DiscoveryEvent; import org.apache.ignite.events.Event; import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager; import org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; import org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.utils.PlatformFutureUtils; import org.apache.ignite.internal.util.lang.GridMapEntry; +import org.apache.ignite.internal.util.typedef.internal.U; import static org.apache.ignite.events.EventType.EVT_NODE_FAILED; import static org.apache.ignite.events.EventType.EVT_NODE_JOINED; @@ -87,7 +88,7 @@ public class PlatformDataStreamer extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) throws IgniteCheckedException { + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_UPDATE: int plc = reader.readInt(); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformStreamReceiverImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformStreamReceiverImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformStreamReceiverImpl.java index 92250c0..5915496 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformStreamReceiverImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformStreamReceiverImpl.java @@ -20,7 +20,7 @@ package org.apache.ignite.internal.processors.platform.datastreamer; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.IgniteException; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractPredicate; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.cache.PlatformCache; @@ -76,7 +76,7 @@ public class PlatformStreamReceiverImpl extends PlatformAbstractPredicate implem try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(pred); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java index 0c2e564..25521dc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetCacheStore.java @@ -21,8 +21,8 @@ import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.cache.store.CacheStore; import org.apache.ignite.cache.store.CacheStoreSession; import org.apache.ignite.internal.GridKernalContext; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.cache.store.PlatformCacheStore; import org.apache.ignite.internal.processors.platform.cache.store.PlatformCacheStoreCallback; @@ -149,8 +149,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor try { final GridTuple<V> val = new GridTuple<>(); - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_LOAD); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -170,8 +170,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor try { final Map<K, V> loaded = new HashMap<>(); - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_LOAD_ALL); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -189,8 +189,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @Override public void loadCache(final IgniteBiInClosure<K, V> clo, final @Nullable Object... args) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_LOAD_CACHE); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -206,8 +206,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @Override public void write(final Cache.Entry<? extends K, ? extends V> entry) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_PUT); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -225,8 +225,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor @SuppressWarnings({"NullableProblems", "unchecked"}) @Override public void writeAll(final Collection<Cache.Entry<? extends K, ? extends V>> entries) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { Map<K, V> map = new AbstractMap<K, V>() { @Override public int size() { return entries.size(); @@ -266,8 +266,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @Override public void delete(final Object key) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_RMV); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -283,8 +283,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @Override public void deleteAll(final Collection<?> keys) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_RMV_ALL); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -300,8 +300,8 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @Override public void sessionEnd(final boolean commit) { try { - doInvoke(new IgniteInClosureX<PortableRawWriterEx>() { - @Override public void applyx(PortableRawWriterEx writer) throws IgniteCheckedException { + doInvoke(new IgniteInClosureX<BinaryRawWriterEx>() { + @Override public void applyx(BinaryRawWriterEx writer) throws IgniteCheckedException { writer.writeByte(OP_SES_END); writer.writeLong(session()); writer.writeString(ses.cacheName()); @@ -329,7 +329,7 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); write(writer, convertPortable); @@ -345,7 +345,7 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor * @param writer Writer. * @param convertPortable Convert portable flag. */ - protected void write(PortableRawWriterEx writer, boolean convertPortable) { + protected void write(BinaryRawWriterEx writer, boolean convertPortable) { writer.writeString(typName); writer.writeBoolean(convertPortable); writer.writeMap(props); @@ -378,12 +378,12 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor * @return Result. * @throws org.apache.ignite.IgniteCheckedException If failed. */ - protected int doInvoke(IgniteInClosureX<PortableRawWriterEx> task, @Nullable PlatformCacheStoreCallback cb) + protected int doInvoke(IgniteInClosureX<BinaryRawWriterEx> task, @Nullable PlatformCacheStoreCallback cb) throws IgniteCheckedException{ try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); task.apply(writer); @@ -425,7 +425,7 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override protected void invoke0(PortableRawReaderEx reader) { + @Override protected void invoke0(BinaryRawReaderEx reader) { val.set((V)reader.readObjectDetached()); } } @@ -451,7 +451,7 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override protected void invoke0(PortableRawReaderEx reader) { + @Override protected void invoke0(BinaryRawReaderEx reader) { loaded.put((K) reader.readObjectDetached(), (V) reader.readObjectDetached()); } } @@ -477,7 +477,7 @@ public class PlatformDotNetCacheStore<K, V> implements CacheStore<K, V>, Platfor /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override protected void invoke0(PortableRawReaderEx reader) { + @Override protected void invoke0(BinaryRawReaderEx reader) { clo.apply((K) reader.readObjectDetached(), (V) reader.readObjectDetached()); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java index 2c8664c..60c0693 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/dotnet/PlatformDotNetConfigurationClosure.java @@ -25,7 +25,7 @@ import org.apache.ignite.internal.MarshallerContextImpl; import org.apache.ignite.internal.portable.GridPortableMarshaller; import org.apache.ignite.internal.portable.PortableContext; import org.apache.ignite.internal.portable.PortableMetaDataHandler; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractConfigurationClosure; import org.apache.ignite.internal.processors.platform.lifecycle.PlatformLifecycleBean; import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream; @@ -39,8 +39,8 @@ import org.apache.ignite.marshaller.Marshaller; import org.apache.ignite.platform.dotnet.PlatformDotNetConfiguration; import org.apache.ignite.marshaller.portable.PortableMarshaller; import org.apache.ignite.platform.dotnet.PlatformDotNetLifecycleBean; -import org.apache.ignite.portable.PortableException; -import org.apache.ignite.portable.PortableMetadata; +import org.apache.ignite.binary.BinaryObjectException; +import org.apache.ignite.binary.BinaryType; import java.util.ArrayList; import java.util.Collections; @@ -137,7 +137,7 @@ public class PlatformDotNetConfigurationClosure extends PlatformAbstractConfigur try (PlatformMemory inMem = memMgr.allocate()) { PlatformOutputStream out = outMem.output(); - PortableRawWriterEx writer = marshaller().writer(out); + BinaryRawWriterEx writer = marshaller().writer(out); PlatformUtils.writeDotNetConfiguration(writer, interopCfg.unwrap()); @@ -229,15 +229,15 @@ public class PlatformDotNetConfigurationClosure extends PlatformAbstractConfigur private static GridPortableMarshaller marshaller() { try { PortableContext ctx = new PortableContext(new PortableMetaDataHandler() { - @Override public void addMeta(int typeId, PortableMetadata meta) - throws PortableException { + @Override public void addMeta(int typeId, BinaryType meta) + throws BinaryObjectException { // No-op. } - @Override public PortableMetadata metadata(int typeId) throws PortableException { + @Override public BinaryType metadata(int typeId) throws BinaryObjectException { return null; } - }, null); + }, new IgniteConfiguration()); PortableMarshaller marsh = new PortableMarshaller(); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEventFilterListenerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEventFilterListenerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEventFilterListenerImpl.java index bbcb60f..a19f07e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEventFilterListenerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEventFilterListenerImpl.java @@ -19,7 +19,7 @@ package org.apache.ignite.internal.processors.platform.events; import org.apache.ignite.events.Event; import org.apache.ignite.internal.GridKernalContext; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.PlatformEventFilterListener; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -125,7 +125,7 @@ public class PlatformEventFilterListenerImpl implements PlatformEventFilterListe try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); ctx.writeEvent(writer, evt); @@ -151,7 +151,7 @@ public class PlatformEventFilterListenerImpl implements PlatformEventFilterListe try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObjectDetached(pred); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java index 8585526..a1af469 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java @@ -24,8 +24,8 @@ import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteEvents; import org.apache.ignite.events.Event; import org.apache.ignite.events.EventAdapter; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformEventFilterListener; import org.apache.ignite.internal.processors.platform.PlatformContext; @@ -137,7 +137,7 @@ public class PlatformEvents extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_RECORD_LOCAL: @@ -168,7 +168,7 @@ public class PlatformEvents extends PlatformAbstractTarget { /** {@inheritDoc} */ @SuppressWarnings({"IfMayBeConditional", "ConstantConditions", "unchecked"}) - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_LOCAL_QUERY: { @@ -256,7 +256,7 @@ public class PlatformEvents extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_GET_ENABLED_EVENTS: writeEventTypes(events.enabledEvents(), writer); @@ -292,7 +292,7 @@ public class PlatformEvents extends PlatformAbstractTarget { * @param reader Reader * @return Event types, or null. */ - private int[] readEventTypes(PortableRawReaderEx reader) { + private int[] readEventTypes(BinaryRawReaderEx reader) { return reader.readIntArray(); } @@ -302,7 +302,7 @@ public class PlatformEvents extends PlatformAbstractTarget { * @param writer Writer * @param types Types. */ - private void writeEventTypes(int[] types, PortableRawWriterEx writer) { + private void writeEventTypes(int[] types, BinaryRawWriterEx writer) { if (types == null) { writer.writeIntArray(null); @@ -349,7 +349,7 @@ public class PlatformEvents extends PlatformAbstractTarget { } /** <inheritDoc /> */ - @Override public void write(PortableRawWriterEx writer, Object obj, Throwable err) { + @Override public void write(BinaryRawWriterEx writer, Object obj, Throwable err) { platformCtx.writeEvent(writer, (EventAdapter)obj); } @@ -379,7 +379,7 @@ public class PlatformEvents extends PlatformAbstractTarget { /** <inheritDoc /> */ @SuppressWarnings("unchecked") - @Override public void write(PortableRawWriterEx writer, Object obj, Throwable err) { + @Override public void write(BinaryRawWriterEx writer, Object obj, Throwable err) { Collection<EventAdapter> events = (Collection<EventAdapter>)obj; writer.writeInt(events.size()); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageFilterImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageFilterImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageFilterImpl.java index 67d5bbb..9e1b086 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageFilterImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageFilterImpl.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.messaging; import org.apache.ignite.internal.GridKernalContext; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractPredicate; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -62,7 +62,7 @@ public class PlatformMessageFilterImpl extends PlatformAbstractPredicate impleme try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(uuid); writer.writeObject(m); @@ -83,7 +83,7 @@ public class PlatformMessageFilterImpl extends PlatformAbstractPredicate impleme try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = ctx.writer(out); + BinaryRawWriterEx writer = ctx.writer(out); writer.writeObject(pred); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageLocalFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageLocalFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageLocalFilter.java index 50643e1..de3f255 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageLocalFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessageLocalFilter.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.messaging; import org.apache.ignite.internal.GridKernalContext; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; import org.apache.ignite.internal.processors.platform.memory.PlatformOutputStream; @@ -58,7 +58,7 @@ public class PlatformMessageLocalFilter implements PlatformMessageFilter { try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); writer.writeObject(uuid); writer.writeObject(m); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessaging.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessaging.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessaging.java index 6dfd570..603d3db 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessaging.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/messaging/PlatformMessaging.java @@ -19,8 +19,8 @@ package org.apache.ignite.internal.processors.platform.messaging; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteMessaging; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.message.PlatformMessageFilter; @@ -84,7 +84,7 @@ public class PlatformMessaging extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_SEND: @@ -135,7 +135,7 @@ public class PlatformMessaging extends PlatformAbstractTarget { /** {@inheritDoc} */ @SuppressWarnings({"IfMayBeConditional", "ConstantConditions", "unchecked"}) - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_REMOTE_LISTEN:{ http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformAbstractService.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformAbstractService.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformAbstractService.java index 0b9ee53..18ab012 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformAbstractService.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformAbstractService.java @@ -23,8 +23,8 @@ import java.io.ObjectInput; import java.io.ObjectOutput; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream; import org.apache.ignite.internal.processors.platform.memory.PlatformMemory; @@ -84,7 +84,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); writer.writeBoolean(srvKeepPortable); writer.writeObject(svc); @@ -108,7 +108,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); writer.writeBoolean(srvKeepPortable); @@ -131,7 +131,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern try (PlatformMemory mem = platformCtx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); writer.writeBoolean(srvKeepPortable); @@ -152,7 +152,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern * @param ctx Context. * @param writer Writer. */ - private void writeServiceContext(ServiceContext ctx, PortableRawWriterEx writer) { + private void writeServiceContext(ServiceContext ctx, BinaryRawWriterEx writer) { writer.writeString(ctx.name()); writer.writeUuid(ctx.executionId()); writer.writeBoolean(ctx.isCancelled()); @@ -175,7 +175,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern try (PlatformMemory outMem = platformCtx.memory().allocate()) { PlatformOutputStream out = outMem.output(); - PortableRawWriterEx writer = platformCtx.writer(out); + BinaryRawWriterEx writer = platformCtx.writer(out); writer.writeBoolean(srvKeepPortable); writer.writeString(mthdName); @@ -195,7 +195,7 @@ public abstract class PlatformAbstractService implements PlatformService, Extern try (PlatformMemory inMem = platformCtx.memory().allocate()) { PlatformInputStream in = inMem.input(); - PortableRawReaderEx reader = platformCtx.reader(in); + BinaryRawReaderEx reader = platformCtx.reader(in); platformCtx.gateway().serviceInvokeMethod(ptr, outMem.pointer(), inMem.pointer()); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java index bfa4570..320d5a9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java @@ -22,8 +22,8 @@ import java.util.Map; import java.util.UUID; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteServices; -import org.apache.ignite.internal.portable.PortableRawReaderEx; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.dotnet.PlatformDotNetService; @@ -128,7 +128,7 @@ public class PlatformServices extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected long processInStreamOutLong(int type, PortableRawReaderEx reader) + @Override protected long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedException { switch (type) { case OP_DOTNET_DEPLOY: { @@ -169,7 +169,7 @@ public class PlatformServices extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected void processInStreamOutStream(int type, PortableRawReaderEx reader, PortableRawWriterEx writer) + @Override protected void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_DOTNET_SERVICES: { @@ -177,7 +177,7 @@ public class PlatformServices extends PlatformAbstractTarget { PlatformUtils.writeNullableCollection(writer, svcs, new PlatformWriterClosure<Service>() { - @Override public void write(PortableRawWriterEx writer, Service svc) { + @Override public void write(BinaryRawWriterEx writer, Service svc) { writer.writeLong(((PlatformService) svc).pointer()); } }, @@ -197,8 +197,8 @@ public class PlatformServices extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected void processInObjectStreamOutStream(int type, Object arg, PortableRawReaderEx reader, - PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processInObjectStreamOutStream(int type, Object arg, BinaryRawReaderEx reader, + BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_DOTNET_INVOKE: { assert arg != null; @@ -235,13 +235,13 @@ public class PlatformServices extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_DESCRIPTORS: { Collection<ServiceDescriptor> descs = services.serviceDescriptors(); PlatformUtils.writeCollection(writer, descs, new PlatformWriterClosure<ServiceDescriptor>() { - @Override public void write(PortableRawWriterEx writer, ServiceDescriptor d) { + @Override public void write(BinaryRawWriterEx writer, ServiceDescriptor d) { writer.writeString(d.name()); writer.writeString(d.cacheName()); writer.writeInt(d.maxPerNodeCount()); @@ -252,7 +252,7 @@ public class PlatformServices extends PlatformAbstractTarget { Map<UUID, Integer> top = d.topologySnapshot(); PlatformUtils.writeMap(writer, top, new PlatformWriterBiClosure<UUID, Integer>() { - @Override public void write(PortableRawWriterEx writer, UUID key, Integer val) { + @Override public void write(BinaryRawWriterEx writer, UUID key, Integer val) { writer.writeUuid(key); writer.writeInt(val); } http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java index c143212..5f5f5c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java @@ -18,13 +18,12 @@ package org.apache.ignite.internal.processors.platform.transactions; import java.sql.Timestamp; -import java.util.Date; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicLong; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteTransactions; import org.apache.ignite.configuration.TransactionConfiguration; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.utils.PlatformFutureUtils; @@ -232,7 +231,7 @@ public class PlatformTransactions extends PlatformAbstractTarget { } /** {@inheritDoc} */ - @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws IgniteCheckedException { + @Override protected void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedException { switch (type) { case OP_CACHE_CONFIG_PARAMETERS: TransactionConfiguration txCfg = platformCtx.kernalContext().config().getTransactionConfiguration(); http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformFutureUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformFutureUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformFutureUtils.java index 0019986..335be4d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformFutureUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformFutureUtils.java @@ -18,7 +18,7 @@ package org.apache.ignite.internal.processors.platform.utils; import org.apache.ignite.internal.IgniteInternalFuture; -import org.apache.ignite.internal.portable.PortableRawWriterEx; +import org.apache.ignite.internal.portable.BinaryRawWriterEx; import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget; import org.apache.ignite.internal.processors.platform.PlatformContext; import org.apache.ignite.internal.processors.platform.callback.PlatformCallbackGateway; @@ -164,7 +164,7 @@ public class PlatformFutureUtils { try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx outWriter = ctx.writer(out); + BinaryRawWriterEx outWriter = ctx.writer(out); outWriter.writeObjectDetached(res); @@ -244,7 +244,7 @@ public class PlatformFutureUtils { try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx outWriter = ctx.writer(out); + BinaryRawWriterEx outWriter = ctx.writer(out); outWriter.writeString(err.getClass().getName()); outWriter.writeString(err.getMessage()); @@ -276,7 +276,7 @@ public class PlatformFutureUtils { try (PlatformMemory mem = ctx.memory().allocate()) { PlatformOutputStream out = mem.output(); - PortableRawWriterEx outWriter = ctx.writer(out); + BinaryRawWriterEx outWriter = ctx.writer(out); writer.write(outWriter, obj, err); @@ -299,7 +299,7 @@ public class PlatformFutureUtils { * @param obj Object. * @param err Error. */ - public void write(PortableRawWriterEx writer, Object obj, Throwable err); + public void write(BinaryRawWriterEx writer, Object obj, Throwable err); /** * Determines whether this writer can write given data. http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java index 79759e9..199cf72 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.processors.platform.utils; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; import org.apache.ignite.lang.IgniteBiTuple; /** @@ -30,5 +30,5 @@ public interface PlatformReaderBiClosure<T1, T2> { * @param reader Reader. * @return Object. */ - IgniteBiTuple<T1, T2> read(PortableRawReaderEx reader); + IgniteBiTuple<T1, T2> read(BinaryRawReaderEx reader); } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/b783d2b7/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java index 2d9b44a..9330606 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.processors.platform.utils; -import org.apache.ignite.internal.portable.PortableRawReaderEx; +import org.apache.ignite.internal.portable.BinaryRawReaderEx; /** * Reader closure. @@ -30,5 +30,5 @@ public interface PlatformReaderClosure<T> { * @param reader Reader. * @return Object. */ - T read(PortableRawReaderEx reader); + T read(BinaryRawReaderEx reader); } \ No newline at end of file
