Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2D64118C4E for ; Wed, 11 Nov 2015 09:12:50 +0000 (UTC) Received: (qmail 91368 invoked by uid 500); 11 Nov 2015 09:12:50 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 91280 invoked by uid 500); 11 Nov 2015 09:12:49 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 90698 invoked by uid 99); 11 Nov 2015 09:12:48 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Nov 2015 09:12:48 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D26B6E0921; Wed, 11 Nov 2015 09:12:48 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.apache.org Date: Wed, 11 Nov 2015 09:13:10 -0000 Message-Id: In-Reply-To: <81bf422c13814119918c9c27e5d01989@git.apache.org> References: <81bf422c13814119918c9c27e5d01989@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [23/24] ignite git commit: IGNITE-1845: Adopted new binary API in .Net. http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryAbstractTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryAbstractTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryAbstractTest.cs index c4d2b36..8005e83 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryAbstractTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Query/Continuous/ContinuousQueryAbstractTest.cs @@ -24,6 +24,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous using System.Linq; using System.Runtime.Serialization; using System.Threading; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; using Apache.Ignite.Core.Cache.Event; using Apache.Ignite.Core.Cache.Query; @@ -31,7 +32,6 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Impl; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; using CQU = Apache.Ignite.Core.Impl.Cache.Query.Continuous.ContinuousQueryUtils; @@ -97,17 +97,17 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous IgniteConfigurationEx cfg = new IgniteConfigurationEx(); - PortableConfiguration portCfg = new PortableConfiguration(); + BinaryConfiguration portCfg = new BinaryConfiguration(); - ICollection portTypeCfgs = new List(); + ICollection portTypeCfgs = new List(); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableEntry))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableFilter))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(KeepPortableFilter))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableEntry))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableFilter))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(KeepPortableFilter))); portCfg.TypeConfigurations = portTypeCfgs; - cfg.PortableConfiguration = portCfg; + cfg.BinaryConfiguration = portCfg; cfg.JvmClasspath = TestUtils.CreateTestClasspath(); cfg.JvmOptions = TestUtils.TestJavaOptions(); cfg.SpringConfigUrl = "config\\cache-query-continuous.xml"; @@ -491,7 +491,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous } else { - Assert.Throws(() => + Assert.Throws(() => { using (cache1.QueryContinuous(qry)) { @@ -594,10 +594,10 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous [Test] public void TestKeepPortable() { - var cache = cache1.WithKeepPortable(); + var cache = cache1.WithKeepBinary(); - ContinuousQuery qry = new ContinuousQuery( - new Listener(), new KeepPortableFilter()); + ContinuousQuery qry = new ContinuousQuery( + new Listener(), new KeepPortableFilter()); using (cache.QueryContinuous(qry)) { @@ -610,14 +610,14 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous Assert.IsTrue(FILTER_EVTS.TryTake(out filterEvt, 500)); Assert.AreEqual(PrimaryKey(cache1), filterEvt.entry.Key); Assert.AreEqual(null, filterEvt.entry.OldValue); - Assert.AreEqual(Entry(1), (filterEvt.entry.Value as IPortableObject) + Assert.AreEqual(Entry(1), (filterEvt.entry.Value as IBinaryObject) .Deserialize()); Assert.IsTrue(CB_EVTS.TryTake(out cbEvt, 500)); Assert.AreEqual(1, cbEvt.entries.Count); Assert.AreEqual(PrimaryKey(cache1), cbEvt.entries.First().Key); Assert.AreEqual(null, cbEvt.entries.First().OldValue); - Assert.AreEqual(Entry(1), (cbEvt.entries.First().Value as IPortableObject) + Assert.AreEqual(Entry(1), (cbEvt.entries.First().Value as IBinaryObject) .Deserialize()); // 2. Remote put. @@ -626,7 +626,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous Assert.IsTrue(FILTER_EVTS.TryTake(out filterEvt, 500)); Assert.AreEqual(PrimaryKey(cache2), filterEvt.entry.Key); Assert.AreEqual(null, filterEvt.entry.OldValue); - Assert.AreEqual(Entry(2), (filterEvt.entry.Value as IPortableObject) + Assert.AreEqual(Entry(2), (filterEvt.entry.Value as IBinaryObject) .Deserialize()); Assert.IsTrue(CB_EVTS.TryTake(out cbEvt, 500)); @@ -634,7 +634,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous Assert.AreEqual(PrimaryKey(cache2), cbEvt.entries.First().Key); Assert.AreEqual(null, cbEvt.entries.First().OldValue); Assert.AreEqual(Entry(2), - (cbEvt.entries.First().Value as IPortableObject).Deserialize()); + (cbEvt.entries.First().Value as IBinaryObject).Deserialize()); } } @@ -718,13 +718,13 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous [Test] public void TestNestedCallFromCallback() { - var cache = cache1.WithKeepPortable(); + var cache = cache1.WithKeepBinary(); int key = PrimaryKey(cache1); NestedCallListener cb = new NestedCallListener(); - using (cache.QueryContinuous(new ContinuousQuery(cb))) + using (cache.QueryContinuous(new ContinuousQuery(cb))) { cache1.GetAndPut(key, Entry(key)); @@ -1021,17 +1021,17 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous /// /// Portable filter. /// - public class PortableFilter : AbstractFilter, IPortableMarshalAware + public class PortableFilter : AbstractFilter, IBinarizable { /** */ - public void WritePortable(IPortableWriter writer) + public void WriteBinary(IBinaryWriter writer) { if (marshErr) throw new Exception("Filter marshalling error."); } /** */ - public void ReadPortable(IPortableReader reader) + public void ReadBinary(IBinaryReader reader) { if (unmarshErr) throw new Exception("Filter unmarshalling error."); @@ -1074,7 +1074,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous /// /// Filter for "keep-portable" scenario. /// - public class KeepPortableFilter : AbstractFilter + public class KeepPortableFilter : AbstractFilter { // No-op. } @@ -1103,18 +1103,18 @@ namespace Apache.Ignite.Core.Tests.Cache.Query.Continuous /// /// Listener with nested Ignite API call. /// - public class NestedCallListener : ICacheEntryEventListener + public class NestedCallListener : ICacheEntryEventListener { /** Event. */ public readonly CountdownEvent countDown = new CountdownEvent(1); - public void OnEvent(IEnumerable> evts) + public void OnEvent(IEnumerable> evts) { - foreach (ICacheEntryEvent evt in evts) + foreach (ICacheEntryEvent evt in evts) { - IPortableObject val = evt.Value; + IBinaryObject val = evt.Value; - IPortableMetadata meta = val.GetMetadata(); + IBinaryType meta = val.GetBinaryType(); Assert.AreEqual(typeof(PortableEntry).Name, meta.TypeName); } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheParallelLoadStoreTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheParallelLoadStoreTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheParallelLoadStoreTest.cs index a7d9adb..4aa910c 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheParallelLoadStoreTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheParallelLoadStoreTest.cs @@ -18,8 +18,8 @@ namespace Apache.Ignite.Core.Tests.Cache.Store { using System; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; - using Apache.Ignite.Core.Portable; using NUnit.Framework; /// @@ -44,7 +44,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Store JvmClasspath = TestUtils.CreateTestClasspath(), JvmOptions = TestUtils.TestJavaOptions(), SpringConfigUrl = "config\\native-client-test-cache-parallel-store.xml", - PortableConfiguration = new PortableConfiguration + BinaryConfiguration = new BinaryConfiguration { Types = new[] {typeof (CacheTestParallelLoadStore.Record).FullName} } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheStoreTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheStoreTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheStoreTest.cs index bd0f3a7..0dc9912 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheStoreTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/Store/CacheStoreTest.cs @@ -20,9 +20,9 @@ namespace Apache.Ignite.Core.Tests.Cache.Store using System; using System.Collections; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; using Apache.Ignite.Core.Impl; - using Apache.Ignite.Core.Portable; using NUnit.Framework; /// @@ -125,11 +125,11 @@ namespace Apache.Ignite.Core.Tests.Cache.Store cfg.JvmOptions = TestUtils.TestJavaOptions(); cfg.SpringConfigUrl = "config\\native-client-test-cache-store.xml"; - PortableConfiguration portCfg = new PortableConfiguration(); + BinaryConfiguration portCfg = new BinaryConfiguration(); portCfg.Types = new List { typeof(Key).FullName, typeof(Value).FullName }; - cfg.PortableConfiguration = portCfg; + cfg.BinaryConfiguration = portCfg; Ignition.Start(cfg); } @@ -212,7 +212,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Store Assert.AreEqual(3, cache.GetSize()); - var meta = cache.WithKeepPortable().Get(new Key(0)).GetMetadata(); + var meta = cache.WithKeepBinary().Get(new Key(0)).GetBinaryType(); Assert.NotNull(meta); @@ -267,7 +267,7 @@ namespace Apache.Ignite.Core.Tests.Cache.Store Assert.AreEqual(1, map.Count); - IPortableObject v = (IPortableObject)map[1]; + IBinaryObject v = (IBinaryObject)map[1]; Assert.AreEqual(1, v.GetField("_idx")); http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/AbstractTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/AbstractTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/AbstractTaskTest.cs index 12c9992..9e96ca2 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/AbstractTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/AbstractTaskTest.cs @@ -20,7 +20,7 @@ namespace Apache.Ignite.Core.Tests.Compute using System; using System.Collections.Generic; using System.Threading; - using Apache.Ignite.Core.Portable; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Tests.Process; using NUnit.Framework; @@ -167,15 +167,15 @@ namespace Apache.Ignite.Core.Tests.Compute if (!_fork) { - PortableConfiguration portCfg = new PortableConfiguration(); + BinaryConfiguration portCfg = new BinaryConfiguration(); - ICollection portTypeCfgs = new List(); + ICollection portTypeCfgs = new List(); PortableTypeConfigurations(portTypeCfgs); portCfg.TypeConfigurations = portTypeCfgs; - cfg.PortableConfiguration = portCfg; + cfg.BinaryConfiguration = portCfg; } cfg.JvmClasspath = TestUtils.CreateTestClasspath(); @@ -209,7 +209,7 @@ namespace Apache.Ignite.Core.Tests.Compute /// Define portable types. /// /// Portable type configurations. - protected virtual void PortableTypeConfigurations(ICollection portTypeCfgs) + protected virtual void PortableTypeConfigurations(ICollection portTypeCfgs) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs index cb2c8b4..f02e67e 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs @@ -23,11 +23,11 @@ namespace Apache.Ignite.Core.Tests.Compute using System.Collections.Generic; using System.Linq; using System.Threading; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Compute; using Apache.Ignite.Core.Impl.Common; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -817,16 +817,16 @@ namespace Apache.Ignite.Core.Tests.Compute { ICompute compute = _grid1.GetCompute(); - compute.WithKeepPortable(); + compute.WithKeepBinary(); - IPortableObject res = compute.ExecuteJavaTask(EchoTask, EchoTypePortableJava); + IBinaryObject res = compute.ExecuteJavaTask(EchoTask, EchoTypePortableJava); Assert.AreEqual(1, res.GetField("field")); // This call must fail because "keepPortable" flag is reset. - Assert.Catch(typeof(PortableException), () => + Assert.Catch(typeof(BinaryObjectException), () => { - compute.ExecuteJavaTask(EchoTask, EchoTypePortableJava); + compute.ExecuteJavaTask(EchoTask, EchoTypePortableJava); }); } @@ -890,7 +890,7 @@ namespace Apache.Ignite.Core.Tests.Compute { ICompute compute = _grid1.GetCompute(); - compute.WithKeepPortable(); + compute.WithKeepBinary(); PlatformComputeNetPortable arg = new PlatformComputeNetPortable(); @@ -1095,17 +1095,17 @@ namespace Apache.Ignite.Core.Tests.Compute { IgniteConfiguration cfg = new IgniteConfiguration(); - PortableConfiguration portCfg = new PortableConfiguration(); + BinaryConfiguration portCfg = new BinaryConfiguration(); - ICollection portTypeCfgs = new List(); + ICollection portTypeCfgs = new List(); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PlatformComputePortable))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PlatformComputeNetPortable))); - portTypeCfgs.Add(new PortableTypeConfiguration(JavaPortableCls)); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputePortable))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputeNetPortable))); + portTypeCfgs.Add(new BinaryTypeConfiguration(JavaPortableCls)); portCfg.TypeConfigurations = portTypeCfgs; - cfg.PortableConfiguration = portCfg; + cfg.BinaryConfiguration = portCfg; cfg.JvmClasspath = Classpath.CreateClasspath(cfg, true); http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs index 2bd8e3a..044b5a6 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs @@ -19,9 +19,9 @@ namespace Apache.Ignite.Core.Tests.Compute { using System; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -111,9 +111,9 @@ namespace Apache.Ignite.Core.Tests.Compute } /** */ - override protected void PortableTypeConfigurations(ICollection portTypeCfgs) + override protected void PortableTypeConfigurations(ICollection portTypeCfgs) { - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(TestPortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestPortableJob))); } /// http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/IgniteExceptionTaskSelfTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/IgniteExceptionTaskSelfTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/IgniteExceptionTaskSelfTest.cs index 31286fe..55d04cd 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/IgniteExceptionTaskSelfTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/IgniteExceptionTaskSelfTest.cs @@ -21,10 +21,10 @@ namespace Apache.Ignite.Core.Tests.Compute using System.Collections.Generic; using System.Linq; using System.Runtime.Serialization; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -88,7 +88,7 @@ namespace Apache.Ignite.Core.Tests.Compute { Mode = ErrorMode.MapJobNotMarshalable; - var e = ExecuteWithError() as PortableException; + var e = ExecuteWithError() as BinaryObjectException; Assert.IsNotNull(e); } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs index 598a7ea..bca5ab6 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs @@ -19,8 +19,8 @@ namespace Apache.Ignite.Core.Tests.Compute { using System; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using NUnit.Framework; /// @@ -40,12 +40,12 @@ namespace Apache.Ignite.Core.Tests.Compute protected PortableClosureTaskTest(bool fork) : base(fork) { } /** */ - protected override void PortableTypeConfigurations(ICollection portTypeCfgs) + protected override void PortableTypeConfigurations(ICollection portTypeCfgs) { - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableOutFunc))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableFunc))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableResult))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableException))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableOutFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableResult))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableException))); } /** */ @@ -153,7 +153,7 @@ namespace Apache.Ignite.Core.Tests.Compute /// /// /// - private class PortableException : Exception, IPortableMarshalAware + private class PortableException : Exception, IBinarizable { /** */ public string Msg; @@ -176,13 +176,13 @@ namespace Apache.Ignite.Core.Tests.Compute } /** */ - public void WritePortable(IPortableWriter writer) + public void WriteBinary(IBinaryWriter writer) { writer.GetRawWriter().WriteString(Msg); } /** */ - public void ReadPortable(IPortableReader reader) + public void ReadBinary(IBinaryReader reader) { Msg = reader.GetRawReader().ReadString(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs index c63b4f0..40a0f72 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs @@ -18,9 +18,9 @@ namespace Apache.Ignite.Core.Tests.Compute { using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -61,24 +61,24 @@ namespace Apache.Ignite.Core.Tests.Compute Assert.AreEqual(400, resObj.Val); } - private static IPortableObject ToPortable(IIgnite grid, object obj) + private static IBinaryObject ToPortable(IIgnite grid, object obj) { - var cache = grid.GetCache(Cache1Name).WithKeepPortable(); + var cache = grid.GetCache(Cache1Name).WithKeepBinary(); cache.Put(1, obj); - return (IPortableObject) cache.Get(1); + return (IBinaryObject) cache.Get(1); } /** */ - override protected void PortableTypeConfigurations(ICollection portTypeCfgs) + override protected void PortableTypeConfigurations(ICollection portTypeCfgs) { - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableJobArgument))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableJobResult))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableTaskArgument))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableTaskResult))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableJob))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableWrapper))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableJobArgument))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableJobResult))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableTaskArgument))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableTaskResult))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableWrapper))); } /// @@ -263,7 +263,7 @@ namespace Apache.Ignite.Core.Tests.Compute class PortableWrapper { - public IPortableObject Item { get; set; } + public IBinaryObject Item { get; set; } } } } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs index 9b58268..57e23b8 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs @@ -19,8 +19,8 @@ namespace Apache.Ignite.Core.Tests.Compute { using System; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -99,9 +99,9 @@ namespace Apache.Ignite.Core.Tests.Compute } /** */ - override protected void PortableTypeConfigurations(ICollection portTypeCfgs) + override protected void PortableTypeConfigurations(ICollection portTypeCfgs) { - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableJob))); } /// http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs index 7108f59..20b19a1 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs @@ -19,9 +19,9 @@ namespace Apache.Ignite.Core.Tests.Compute { using System; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using NUnit.Framework; @@ -156,12 +156,12 @@ namespace Apache.Ignite.Core.Tests.Compute } /** */ - override protected void PortableTypeConfigurations(ICollection portTypeCfgs) + override protected void PortableTypeConfigurations(ICollection portTypeCfgs) { - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableResult))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(TestPortableJob))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableOutFunc))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof(PortableFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableResult))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestPortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableOutFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableFunc))); } [Test] http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-standalone.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-standalone.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-standalone.xml index bd34958..6447b4e 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-standalone.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-standalone.xml @@ -55,8 +55,8 @@ - - + + Apache.Ignite.Core.Tests.ExecutableTest+RemoteConfiguration @@ -70,10 +70,10 @@ - + - + http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml index 84f9e5a..26bf87b 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml @@ -31,8 +31,8 @@ - - + + Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64] http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query.xml index 787a921..338e7f1 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query.xml @@ -31,8 +31,8 @@ - - + + Apache.Ignite.Core.Tests.Cache.Query.QueryPerson http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-affinity.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-affinity.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-affinity.xml index f08018d..4c73ff6 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-affinity.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-affinity.xml @@ -28,11 +28,11 @@ - - + + - + http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs index c9dea5c..2f9f6c9 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs @@ -22,10 +22,10 @@ namespace Apache.Ignite.Core.Tests.Dataload using System.Diagnostics; using System.Linq; using System.Threading; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; using Apache.Ignite.Core.Datastream; using Apache.Ignite.Core.Impl; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Tests.Cache; using NUnit.Framework; @@ -441,14 +441,14 @@ namespace Apache.Ignite.Core.Tests.Dataload var cache = _grid.GetCache(CacheName); using (var ldr0 = _grid.GetDataStreamer(CacheName)) - using (var ldr = ldr0.WithKeepPortable()) + using (var ldr = ldr0.WithKeepBinary()) { ldr.Receiver = new StreamReceiverKeepPortable(); ldr.AllowOverwrite = true; for (var i = 0; i < 100; i++) - ldr.AddData(i, _grid.GetPortables().ToPortable(new PortableEntry {Val = i})); + ldr.AddData(i, _grid.GetBinary().ToBinary(new PortableEntry {Val = i})); ldr.Flush(); @@ -468,15 +468,15 @@ namespace Apache.Ignite.Core.Tests.Dataload GridName = gridName, SpringConfigUrl = "config\\native-client-test-cache.xml", JvmClasspath = TestUtils.CreateTestClasspath(), - PortableConfiguration = new PortableConfiguration + BinaryConfiguration = new BinaryConfiguration { - TypeConfigurations = new List + TypeConfigurations = new List { - new PortableTypeConfiguration(typeof (CacheTestKey)), - new PortableTypeConfiguration(typeof (TestReferenceObject)), - new PortableTypeConfiguration(typeof (StreamReceiverPortable)), - new PortableTypeConfiguration(typeof (EntryProcessorPortable)), - new PortableTypeConfiguration(typeof (PortableEntry)) + new BinaryTypeConfiguration(typeof (CacheTestKey)), + new BinaryTypeConfiguration(typeof (TestReferenceObject)), + new BinaryTypeConfiguration(typeof (StreamReceiverPortable)), + new BinaryTypeConfiguration(typeof (EntryProcessorPortable)), + new BinaryTypeConfiguration(typeof (PortableEntry)) } }, JvmOptions = TestUtils.TestJavaOptions().Concat(new[] @@ -512,15 +512,15 @@ namespace Apache.Ignite.Core.Tests.Dataload /// Test portable receiver. /// [Serializable] - private class StreamReceiverKeepPortable : IStreamReceiver + private class StreamReceiverKeepPortable : IStreamReceiver { /** */ - public void Receive(ICache cache, ICollection> entries) + public void Receive(ICache cache, ICollection> entries) { - var portables = cache.Ignite.GetPortables(); + var portables = cache.Ignite.GetBinary(); cache.PutAll(entries.ToDictionary(x => x.Key, x => - portables.ToPortable(new PortableEntry + portables.ToBinary(new PortableEntry { Val = x.Value.Deserialize().Val + 1 }))); @@ -558,7 +558,7 @@ namespace Apache.Ignite.Core.Tests.Dataload /// /// Test entry processor. /// - private class EntryProcessorPortable : ICacheEntryProcessor, IPortableMarshalAware + private class EntryProcessorPortable : ICacheEntryProcessor, IBinarizable { /** */ public int Process(IMutableCacheEntry entry, int arg) @@ -569,13 +569,13 @@ namespace Apache.Ignite.Core.Tests.Dataload } /** */ - public void WritePortable(IPortableWriter writer) + public void WriteBinary(IBinaryWriter writer) { // No-op. } /** */ - public void ReadPortable(IPortableReader reader) + public void ReadBinary(IBinaryReader reader) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs index 2dd03da..403f8a7 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs @@ -23,12 +23,12 @@ namespace Apache.Ignite.Core.Tests using System.Linq; using System.Threading; using System.Threading.Tasks; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache.Query; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Events; using Apache.Ignite.Core.Impl; using Apache.Ignite.Core.Impl.Events; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Tests.Compute; using NUnit.Framework; @@ -612,11 +612,11 @@ namespace Apache.Ignite.Core.Tests SpringConfigUrl = springConfigUrl, JvmClasspath = TestUtils.CreateTestClasspath(), JvmOptions = TestUtils.TestJavaOptions(), - PortableConfiguration = new PortableConfiguration + BinaryConfiguration = new BinaryConfiguration { - TypeConfigurations = new List + TypeConfigurations = new List { - new PortableTypeConfiguration(typeof (RemoteEventPortableFilter)) + new BinaryTypeConfiguration(typeof (RemoteEventPortableFilter)) } } }; @@ -884,7 +884,7 @@ namespace Apache.Ignite.Core.Tests /// /// Portable remote event filter. /// - public class RemoteEventPortableFilter : IEventFilter, IPortableMarshalAware + public class RemoteEventPortableFilter : IEventFilter, IBinarizable { /** */ private int _type; @@ -905,13 +905,13 @@ namespace Apache.Ignite.Core.Tests } /** */ - public void WritePortable(IPortableWriter writer) + public void WriteBinary(IBinaryWriter writer) { writer.GetRawWriter().WriteInt(_type); } /** */ - public void ReadPortable(IPortableReader reader) + public void ReadBinary(IBinaryReader reader) { _type = reader.GetRawReader().ReadInt(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs index b971876..196d8ae 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs @@ -22,11 +22,11 @@ namespace Apache.Ignite.Core.Tests using System.Linq; using System.Runtime.Serialization.Formatters.Binary; using System.Threading.Tasks; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Impl; - using Apache.Ignite.Core.Portable; using NUnit.Framework; /// @@ -118,7 +118,7 @@ namespace Apache.Ignite.Core.Tests public void TestPartialUpdateExceptionPortable() { // User type - TestPartialUpdateException(false, (x, g) => g.GetPortables().ToPortable(new PortableEntry(x))); + TestPartialUpdateException(false, (x, g) => g.GetBinary().ToBinary(new PortableEntry(x))); } /// @@ -205,7 +205,7 @@ namespace Apache.Ignite.Core.Tests [Category(TestUtils.CategoryIntensive)] public void TestPartialUpdateExceptionAsyncPortable() { - TestPartialUpdateException(true, (x, g) => g.GetPortables().ToPortable(new PortableEntry(x))); + TestPartialUpdateException(true, (x, g) => g.GetBinary().ToBinary(new PortableEntry(x))); } /// @@ -217,8 +217,8 @@ namespace Apache.Ignite.Core.Tests { var cache = grid.GetCache("partitioned_atomic").WithNoRetries(); - if (typeof (TK) == typeof (IPortableObject)) - cache = cache.WithKeepPortable(); + if (typeof (TK) == typeof (IBinaryObject)) + cache = cache.WithKeepBinary(); // Do cache puts in parallel var putTask = Task.Factory.StartNew(() => @@ -291,11 +291,11 @@ namespace Apache.Ignite.Core.Tests JvmOptions = TestUtils.TestJavaOptions(), JvmClasspath = TestUtils.CreateTestClasspath(), GridName = gridName, - PortableConfiguration = new PortableConfiguration + BinaryConfiguration = new BinaryConfiguration { TypeConfigurations = new[] { - new PortableTypeConfiguration(typeof (PortableEntry)) + new BinaryTypeConfiguration(typeof (PortableEntry)) } } }); http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExecutableTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExecutableTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExecutableTest.cs index abb296c..e34e0ba 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExecutableTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExecutableTest.cs @@ -22,9 +22,9 @@ namespace Apache.Ignite.Core.Tests using System; using System.CodeDom.Compiler; using System.Collections.Generic; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Compute; using Apache.Ignite.Core.Impl; - using Apache.Ignite.Core.Portable; using Apache.Ignite.Core.Resource; using Apache.Ignite.Core.Tests.Process; using Microsoft.CSharp; @@ -287,16 +287,16 @@ namespace Apache.Ignite.Core.Tests var cfg = new IgniteConfiguration(); - var portCfg = new PortableConfiguration(); + var portCfg = new BinaryConfiguration(); - ICollection portTypeCfgs = new List(); + ICollection portTypeCfgs = new List(); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof (RemoteConfiguration))); - portTypeCfgs.Add(new PortableTypeConfiguration(typeof (RemoteConfigurationClosure))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof (RemoteConfiguration))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof (RemoteConfigurationClosure))); portCfg.TypeConfigurations = portTypeCfgs; - cfg.PortableConfiguration = portCfg; + cfg.BinaryConfiguration = portCfg; cfg.JvmClasspath = TestUtils.CreateTestClasspath(); http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs index be5bbbc..e32f49a 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs @@ -20,9 +20,9 @@ namespace Apache.Ignite.Core.Tests using System; using System.Collections.Generic; using System.Threading; + using Apache.Ignite.Core.Binary; using Apache.Ignite.Core.Cache; using Apache.Ignite.Core.Compute; - using Apache.Ignite.Core.Portable; using NUnit.Framework; /// @@ -49,10 +49,10 @@ namespace Apache.Ignite.Core.Tests SpringConfigUrl = "config\\compute\\compute-standalone.xml", JvmClasspath = TestUtils.CreateTestClasspath(), JvmOptions = TestUtils.TestJavaOptions(), - PortableConfiguration = new PortableConfiguration + BinaryConfiguration = new BinaryConfiguration { TypeConfigurations = - new List { new PortableTypeConfiguration(typeof(Portable)) } + new List { new BinaryTypeConfiguration(typeof(Portable)) } } }); @@ -125,20 +125,20 @@ namespace Apache.Ignite.Core.Tests /// /// Portable test class. /// - private class Portable : IPortableMarshalAware + private class Portable : IBinarizable { public int A; public string B; /** */ - public void WritePortable(IPortableWriter writer) + public void WriteBinary(IBinaryWriter writer) { writer.WriteInt("a", A); writer.GetRawWriter().WriteString(B); } /** */ - public void ReadPortable(IPortableReader reader) + public void ReadBinary(IBinaryReader reader) { A = reader.ReadInt("a"); B = reader.GetRawReader().ReadString(); http://git-wip-us.apache.org/repos/asf/ignite/blob/894057e5/modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteStartStopTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteStartStopTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteStartStopTest.cs index d302046..b589b2e 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteStartStopTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteStartStopTest.cs @@ -341,7 +341,7 @@ namespace Apache.Ignite.Core.Tests var comp = ignite.GetCompute(); // ReSharper disable once RedundantAssignment - comp = comp.WithKeepPortable(); + comp = comp.WithKeepBinary(); var prj = ignite.GetCluster().ForOldest();