http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 cb582b7..68616ab 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs @@ -39,8 +39,8 @@ namespace Apache.Ignite.Core.Tests.Compute /** Echo task name. */ private const string EchoTask = "org.apache.ignite.platform.PlatformComputeEchoTask"; - /** Portable argument task name. */ - private const string PortableArgTask = "org.apache.ignite.platform.PlatformComputePortableArgTask"; + /** Binary argument task name. */ + private const string BinaryArgTask = "org.apache.ignite.platform.PlatformComputeBinarizableArgTask"; /** Broadcast task name. */ private const string BroadcastTask = "org.apache.ignite.platform.PlatformComputeBroadcastTask"; @@ -48,8 +48,8 @@ namespace Apache.Ignite.Core.Tests.Compute /** Broadcast task name. */ private const string DecimalTask = "org.apache.ignite.platform.PlatformComputeDecimalTask"; - /** Java portable class name. */ - private const string JavaPortableCls = "GridInteropComputeJavaPortable"; + /** Java binary class name. */ + private const string JavaBinaryCls = "PlatformComputeJavaBinarizable"; /** Echo type: null. */ private const int EchoTypeNull = 0; @@ -87,17 +87,17 @@ namespace Apache.Ignite.Core.Tests.Compute /** Echo type: map. */ private const int EchoTypeMap = 11; - /** Echo type: portable. */ - private const int EchoTypePortable = 12; + /** Echo type: binarizable. */ + private const int EchoTypeBinarizable = 12; - /** Echo type: portable (Java only). */ - private const int EchoTypePortableJava = 13; + /** Echo type: binary (Java only). */ + private const int EchoTypeBinarizableJava = 13; /** Type: object array. */ private const int EchoTypeObjArray = 14; - /** Type: portable object array. */ - private const int EchoTypePortableArray = 15; + /** Type: binary object array. */ + private const int EchoTypeBinarizableArray = 15; /** Type: enum. */ private const int EchoTypeEnum = 16; @@ -799,34 +799,34 @@ namespace Apache.Ignite.Core.Tests.Compute } /// <summary> - /// Test echo task returning portable object. + /// Test echo task returning binary object. /// </summary> [Test] - public void TestEchoTaskPortable() + public void TestEchoTaskBinarizable() { - PlatformComputePortable res = _grid1.GetCompute().ExecuteJavaTask<PlatformComputePortable>(EchoTask, EchoTypePortable); + var res = _grid1.GetCompute().ExecuteJavaTask<PlatformComputeBinarizable>(EchoTask, EchoTypeBinarizable); Assert.AreEqual(1, res.Field); } /// <summary> - /// Test echo task returning portable object with no corresponding class definition. + /// Test echo task returning binary object with no corresponding class definition. /// </summary> [Test] - public void TestEchoTaskPortableNoClass() + public void TestEchoTaskBinarizableNoClass() { ICompute compute = _grid1.GetCompute(); compute.WithKeepBinary(); - IBinaryObject res = compute.ExecuteJavaTask<IBinaryObject>(EchoTask, EchoTypePortableJava); + IBinaryObject res = compute.ExecuteJavaTask<IBinaryObject>(EchoTask, EchoTypeBinarizableJava); Assert.AreEqual(1, res.GetField<int>("field")); - // This call must fail because "keepPortable" flag is reset. + // This call must fail because "keepBinary" flag is reset. Assert.Catch(typeof(BinaryObjectException), () => { - compute.ExecuteJavaTask<IBinaryObject>(EchoTask, EchoTypePortableJava); + compute.ExecuteJavaTask<IBinaryObject>(EchoTask, EchoTypeBinarizableJava); }); } @@ -842,17 +842,17 @@ namespace Apache.Ignite.Core.Tests.Compute } /// <summary> - /// Tests the echo task returning portable array. + /// Tests the echo task returning binary array. /// </summary> [Test] - public void TestEchoTaskPortableArray() + public void TestEchoTaskBinarizableArray() { - var res = _grid1.GetCompute().ExecuteJavaTask<object[]>(EchoTask, EchoTypePortableArray); + var res = _grid1.GetCompute().ExecuteJavaTask<object[]>(EchoTask, EchoTypeBinarizableArray); Assert.AreEqual(3, res.Length); for (var i = 0; i < res.Length; i++) - Assert.AreEqual(i + 1, ((PlatformComputePortable) res[i]).Field); + Assert.AreEqual(i + 1, ((PlatformComputeBinarizable) res[i]).Field); } /// <summary> @@ -883,20 +883,20 @@ namespace Apache.Ignite.Core.Tests.Compute } /// <summary> - /// Test for portable argument in Java. + /// Test for binary argument in Java. /// </summary> [Test] - public void TestPortableArgTask() + public void TestBinarizableArgTask() { ICompute compute = _grid1.GetCompute(); compute.WithKeepBinary(); - PlatformComputeNetPortable arg = new PlatformComputeNetPortable(); + PlatformComputeNetBinarizable arg = new PlatformComputeNetBinarizable(); arg.Field = 100; - int res = compute.ExecuteJavaTask<int>(PortableArgTask, arg); + int res = compute.ExecuteJavaTask<int>(BinaryArgTask, arg); Assert.AreEqual(arg.Field, res); } @@ -1109,9 +1109,9 @@ namespace Apache.Ignite.Core.Tests.Compute ICollection<BinaryTypeConfiguration> portTypeCfgs = new List<BinaryTypeConfiguration>(); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputePortable))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputeNetPortable))); - portTypeCfgs.Add(new BinaryTypeConfiguration(JavaPortableCls)); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputeBinarizable))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PlatformComputeNetBinarizable))); + portTypeCfgs.Add(new BinaryTypeConfiguration(JavaBinaryCls)); portCfg.TypeConfigurations = portTypeCfgs; @@ -1127,7 +1127,7 @@ namespace Apache.Ignite.Core.Tests.Compute } } - class PlatformComputePortable + class PlatformComputeBinarizable { public int Field { @@ -1136,7 +1136,7 @@ namespace Apache.Ignite.Core.Tests.Compute } } - class PlatformComputeNetPortable : PlatformComputePortable + class PlatformComputeNetBinarizable : PlatformComputeBinarizable { }
http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 044b5a6..34a1573 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/FailoverTaskSelfTest.cs @@ -73,10 +73,10 @@ namespace Apache.Ignite.Core.Tests.Compute } /// <summary> - /// Test for GridComputeJobFailoverException with portable job. + /// Test for GridComputeJobFailoverException with binary job. /// </summary> [Test] - public void TestTaskAdapterFailoverExceptionPortable() + public void TestTaskAdapterFailoverExceptionBinarizable() { TestTaskAdapterFailoverException(false); } @@ -111,9 +111,9 @@ namespace Apache.Ignite.Core.Tests.Compute } /** <inheritDoc /> */ - override protected void PortableTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) + override protected void GetBinaryTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) { - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestPortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestBinarizableJob))); } /// <summary> @@ -138,7 +138,7 @@ namespace Apache.Ignite.Core.Tests.Compute if (serializable) job = new TestSerializableJob(); else - job = new TestPortableJob(); + job = new TestBinarizableJob(); foreach (IClusterNode node in subgrid) { bool add = local ? node.IsLocal : !node.IsLocal; @@ -172,7 +172,7 @@ namespace Apache.Ignite.Core.Tests.Compute class TestClosure : IComputeFunc<int> { [InstanceResource] - private IIgnite _grid = null; + private readonly IIgnite _grid = null; /** <inheritDoc /> */ public int Invoke() @@ -188,7 +188,7 @@ namespace Apache.Ignite.Core.Tests.Compute class TestSerializableJob : IComputeJob<int> { [InstanceResource] - private IIgnite _grid = null; + private readonly IIgnite _grid = null; /** <inheritDoc /> */ public int Execute() @@ -206,10 +206,10 @@ namespace Apache.Ignite.Core.Tests.Compute /// <summary> /// /// </summary> - class TestPortableJob : IComputeJob<int> + class TestBinarizableJob : IComputeJob<int> { [InstanceResource] - private IIgnite _grid = null; + private readonly IIgnite _grid = null; /** <inheritDoc /> */ public int Execute() http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedBinarizableClosureTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedBinarizableClosureTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedBinarizableClosureTaskTest.cs new file mode 100644 index 0000000..315bbbe --- /dev/null +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedBinarizableClosureTaskTest.cs @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +namespace Apache.Ignite.Core.Tests.Compute.Forked +{ + /// <summary> + /// Forked closure execution tests for binary objects. + /// </summary> + public class ForkedBinarizableClosureTaskTest : BinarizableClosureTaskTest + { + /// <summary> + /// Constructor. + /// </summary> + public ForkedBinarizableClosureTaskTest() : base(true) { } + } +} http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedPortableClosureTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedPortableClosureTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedPortableClosureTaskTest.cs deleted file mode 100644 index 4ce917b..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedPortableClosureTaskTest.cs +++ /dev/null @@ -1,30 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -namespace Apache.Ignite.Core.Tests.Compute.Forked -{ - /// <summary> - /// Forked closure execution tests for portable objects. - /// </summary> - public class ForkedPortableClosureTaskTest : PortableClosureTaskTest - { - /// <summary> - /// Constructor. - /// </summary> - public ForkedPortableClosureTaskTest() : base(true) { } - } -} http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedResourceTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedResourceTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedResourceTaskTest.cs index 84c1ba2..a16db03 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedResourceTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedResourceTaskTest.cs @@ -17,12 +17,9 @@ namespace Apache.Ignite.Core.Tests.Compute.Forked { - using NUnit.Framework; - /// <summary> /// Forked resource task test. /// </summary> - [Ignore("IGNITE-1381")] public class ForkedResourceTaskTest : ResourceTaskTest { /// <summary> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedSerializableClosureTaskTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedSerializableClosureTaskTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedSerializableClosureTaskTest.cs index 0324125..c6582ad 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedSerializableClosureTaskTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/Forked/ForkedSerializableClosureTaskTest.cs @@ -17,12 +17,9 @@ namespace Apache.Ignite.Core.Tests.Compute.Forked { - using NUnit.Framework; - /// <summary> /// Forked closure execution tests for serializable objects. /// </summary> - [Ignore("IGNITE-1381")] public class ForkedSerializableClosureTaskTest : SerializableClosureTaskTest { /// <summary> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 deleted file mode 100644 index bca5ab6..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableClosureTaskTest.cs +++ /dev/null @@ -1,217 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -namespace Apache.Ignite.Core.Tests.Compute -{ - using System; - using System.Collections.Generic; - using Apache.Ignite.Core.Binary; - using Apache.Ignite.Core.Compute; - using NUnit.Framework; - - /// <summary> - /// Closure execution tests for portable objects. - /// </summary> - public class PortableClosureTaskTest : ClosureTaskTest - { - /// <summary> - /// Constructor. - /// </summary> - public PortableClosureTaskTest() : base(false) { } - - /// <summary> - /// Constructor. - /// </summary> - /// <param name="fork">Fork flag.</param> - protected PortableClosureTaskTest(bool fork) : base(fork) { } - - /** <inheritDoc /> */ - protected override void PortableTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) - { - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableOutFunc))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableFunc))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableResult))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableException))); - } - - /** <inheritDoc /> */ - protected override IComputeFunc<object> OutFunc(bool err) - { - return new PortableOutFunc(err); - } - - /** <inheritDoc /> */ - protected override IComputeFunc<object, object> Func(bool err) - { - return new PortableFunc(err); - } - - /** <inheritDoc /> */ - protected override void CheckResult(object res) - { - Assert.IsTrue(res != null); - - PortableResult res0 = res as PortableResult; - - Assert.IsTrue(res0 != null); - Assert.AreEqual(1, res0.Res); - } - - /** <inheritDoc /> */ - protected override void CheckError(Exception err) - { - Assert.IsTrue(err != null); - - PortableException err0 = err as PortableException; - - Assert.IsTrue(err0 != null); - Assert.AreEqual(ErrMsg, err0.Msg); - } - - /// <summary> - /// - /// </summary> - private class PortableOutFunc : IComputeFunc<object> - { - /** Error. */ - private bool _err; - - /// <summary> - /// - /// </summary> - public PortableOutFunc() - { - // No-op. - } - - /// <summary> - /// - /// </summary> - /// <param name="err"></param> - public PortableOutFunc(bool err) - { - _err = err; - } - - /** <inheritDoc /> */ - public object Invoke() - { - if (_err) - throw new PortableException(ErrMsg); - return new PortableResult(1); - } - } - - /// <summary> - /// - /// </summary> - private class PortableFunc : IComputeFunc<object, object> - { - /** Error. */ - private bool _err; - - /// <summary> - /// - /// </summary> - public PortableFunc() - { - // No-op. - } - - /// <summary> - /// - /// </summary> - /// <param name="err"></param> - public PortableFunc(bool err) - { - _err = err; - } - - /** <inheritDoc /> */ - public object Invoke(object arg) - { - if (_err) - throw new PortableException(ErrMsg); - return new PortableResult(1); - } - } - - /// <summary> - /// - /// </summary> - private class PortableException : Exception, IBinarizable - { - /** */ - public string Msg; - - /// <summary> - /// - /// </summary> - public PortableException() - { - // No-op. - } - - /// <summary> - /// - /// </summary> - /// <param name="msg"></param> - public PortableException(string msg) : this() - { - Msg = msg; - } - - /** <inheritDoc /> */ - public void WriteBinary(IBinaryWriter writer) - { - writer.GetRawWriter().WriteString(Msg); - } - - /** <inheritDoc /> */ - public void ReadBinary(IBinaryReader reader) - { - Msg = reader.GetRawReader().ReadString(); - } - } - - /// <summary> - /// - /// </summary> - private class PortableResult - { - /** */ - public int Res; - - /// <summary> - /// - /// </summary> - public PortableResult() - { - // No-op. - } - - /// <summary> - /// - /// </summary> - /// <param name="res"></param> - public PortableResult(int res) - { - Res = res; - } - } - } -} http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 deleted file mode 100644 index 40a0f72..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/PortableTaskTest.cs +++ /dev/null @@ -1,269 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -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.Resource; - using NUnit.Framework; - - /// <summary> - /// Task test result. - /// </summary> - public class PortableTaskTest : AbstractTaskTest - { - /// <summary> - /// Constructor. - /// </summary> - public PortableTaskTest() : base(false) { } - - /// <summary> - /// Constructor. - /// </summary> - /// <param name="fork">Fork flag.</param> - protected PortableTaskTest(bool fork) : base(fork) { } - - /// <summary> - /// Test for task result. - /// </summary> - [Test] - public void TestPortableObjectInTask() - { - var taskArg = new PortableWrapper {Item = ToPortable(Grid1, new PortableTaskArgument(100))}; - - TestTask task = new TestTask(Grid1, taskArg); - - var res = Grid1.GetCompute().Execute(task, taskArg).Item; - - Assert.NotNull(res); - - Assert.AreEqual(400, res.GetField<int>("val")); - - PortableTaskResult resObj = res.Deserialize<PortableTaskResult>(); - - Assert.AreEqual(400, resObj.Val); - } - - private static IBinaryObject ToPortable(IIgnite grid, object obj) - { - var cache = grid.GetCache<object, object>(Cache1Name).WithKeepBinary<object, object>(); - - cache.Put(1, obj); - - return (IBinaryObject) cache.Get(1); - } - - /** <inheritDoc /> */ - override protected void PortableTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) - { - 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))); - } - - /// <summary> - /// Test task. - /// </summary> - class TestTask : ComputeTaskAdapter<PortableWrapper, PortableWrapper, PortableWrapper> - { - /** */ - private readonly IIgnite _grid; - - private readonly PortableWrapper _taskArgField; - - public TestTask(IIgnite grid, PortableWrapper taskArgField) - { - _grid = grid; - _taskArgField = taskArgField; - } - - /** <inheritDoc /> */ - override public IDictionary<IComputeJob<PortableWrapper>, IClusterNode> Map(IList<IClusterNode> subgrid, PortableWrapper arg) - { - Assert.AreEqual(3, subgrid.Count); - Assert.NotNull(_grid); - - var taskArg = arg; - - CheckTaskArgument(taskArg); - - CheckTaskArgument(_taskArgField); - - var jobs = new Dictionary<IComputeJob<PortableWrapper>, IClusterNode>(); - - - foreach (IClusterNode node in subgrid) - { - if (!Grid3Name.Equals(node.GetAttribute<string>("org.apache.ignite.ignite.name"))) // Grid3 does not have cache. - { - var job = new PortableJob - { - Arg = new PortableWrapper {Item = ToPortable(_grid, new PortableJobArgument(200))} - }; - - jobs.Add(job, node); - } - } - - Assert.AreEqual(2, jobs.Count); - - return jobs; - } - - private void CheckTaskArgument(PortableWrapper arg) - { - Assert.IsNotNull(arg); - - var taskArg = arg.Item; - - Assert.IsNotNull(taskArg); - - Assert.AreEqual(100, taskArg.GetField<int>("val")); - - PortableTaskArgument taskArgObj = taskArg.Deserialize<PortableTaskArgument>(); - - Assert.AreEqual(100, taskArgObj.Val); - } - - /** <inheritDoc /> */ - override public PortableWrapper Reduce(IList<IComputeJobResult<PortableWrapper>> results) - { - Assert.NotNull(_grid); - - Assert.AreEqual(2, results.Count); - - foreach (var res in results) - { - var jobRes = res.Data.Item; - - Assert.NotNull(jobRes); - - Assert.AreEqual(300, jobRes.GetField<int>("val")); - - PortableJobResult jobResObj = jobRes.Deserialize<PortableJobResult>(); - - Assert.AreEqual(300, jobResObj.Val); - } - - return new PortableWrapper {Item = ToPortable(_grid, new PortableTaskResult(400))}; - } - } - - /// <summary> - /// - /// </summary> - class PortableJobArgument - { - /** */ - public int Val; - - public PortableJobArgument(int val) - { - Val = val; - } - } - - /// <summary> - /// - /// </summary> - class PortableJobResult - { - /** */ - public int Val; - - public PortableJobResult(int val) - { - Val = val; - } - } - - /// <summary> - /// - /// </summary> - class PortableTaskArgument - { - /** */ - public int Val; - - public PortableTaskArgument(int val) - { - Val = val; - } - } - - /// <summary> - /// - /// </summary> - class PortableTaskResult - { - /** */ - public int Val; - - public PortableTaskResult(int val) - { - Val = val; - } - } - - /// <summary> - /// - /// </summary> - class PortableJob : IComputeJob<PortableWrapper> - { - [InstanceResource] - private IIgnite _grid = null; - - /** */ - public PortableWrapper Arg; - - /** <inheritDoc /> */ - - public PortableWrapper Execute() - { - Assert.IsNotNull(Arg); - - var arg = Arg.Item; - - Assert.IsNotNull(arg); - - Assert.AreEqual(200, arg.GetField<int>("val")); - - PortableJobArgument argObj = arg.Deserialize<PortableJobArgument>(); - - Assert.AreEqual(200, argObj.Val); - - return new PortableWrapper {Item = ToPortable(_grid, new PortableJobResult(300))}; - } - - public void Cancel() - { - // No-op. - } - } - - class PortableWrapper - { - public IBinaryObject Item { get; set; } - } - } -} http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 57e23b8..8418306 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskAdapterTest.cs @@ -88,7 +88,7 @@ namespace Apache.Ignite.Core.Tests.Compute /// Test for job adapter. /// </summary> [Test] - public void TestPortableJobAdapter() + public void TestBinarizableJobAdapter() { for (int i = 0; i < 10; i++) { @@ -99,9 +99,9 @@ namespace Apache.Ignite.Core.Tests.Compute } /** <inheritDoc /> */ - override protected void PortableTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) + override protected void GetBinaryTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) { - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(BinarizableJob))); } /// <summary> @@ -158,7 +158,7 @@ namespace Apache.Ignite.Core.Tests.Compute if (serializable) jobs.Add(new SerializableJob(100, "str")); else - jobs.Add(new PortableJob(100, "str")); + jobs.Add(new BinarizableJob(100, "str")); return jobs; } @@ -236,14 +236,14 @@ namespace Apache.Ignite.Core.Tests.Compute } /// <summary> - /// Test portable job. + /// Test binary job. /// </summary> - public class PortableJob : ComputeJobAdapter<bool> + public class BinarizableJob : ComputeJobAdapter<bool> { [InstanceResource] private IIgnite _grid = null; - public PortableJob(params object[] args) : base(args) + public BinarizableJob(params object[] args) : base(args) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 20b19a1..4bf1e21 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/TaskResultTest.cs @@ -99,19 +99,19 @@ namespace Apache.Ignite.Core.Tests.Compute /// Test for task result. /// </summary> [Test] - public void TestTaskResultPortable() + public void TestTaskResultBinarizable() { - TestTask<PortableResult> task = new TestTask<PortableResult>(); + TestTask<BinarizableResult> task = new TestTask<BinarizableResult>(); - PortableResult val = new PortableResult(100); + BinarizableResult val = new BinarizableResult(100); - PortableResult res = Grid1.GetCompute().Execute(task, new Tuple<bool, PortableResult>(true, val)); + BinarizableResult res = Grid1.GetCompute().Execute(task, new Tuple<bool, BinarizableResult>(true, val)); Assert.AreEqual(val.Val, res.Val); val.Val = 101; - res = Grid1.GetCompute().Execute(task, new Tuple<bool, PortableResult>(false, val)); + res = Grid1.GetCompute().Execute(task, new Tuple<bool, BinarizableResult>(false, val)); Assert.AreEqual(val.Val, res.Val); } @@ -156,18 +156,18 @@ namespace Apache.Ignite.Core.Tests.Compute } /** <inheritDoc /> */ - override protected void PortableTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) + override protected void GetBinaryTypeConfigurations(ICollection<BinaryTypeConfiguration> portTypeCfgs) { - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableResult))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestPortableJob))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableOutFunc))); - portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(PortableFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(BinarizableResult))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(TestBinarizableJob))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(BinarizableOutFunc))); + portTypeCfgs.Add(new BinaryTypeConfiguration(typeof(BinarizableFunc))); } [Test] public void TestOutFuncResultPrimitive1() { - ICollection<int> res = Grid1.GetCompute().Broadcast(new PortableOutFunc()); + ICollection<int> res = Grid1.GetCompute().Broadcast(new BinarizableOutFunc()); Assert.AreEqual(3, res.Count); @@ -189,7 +189,7 @@ namespace Apache.Ignite.Core.Tests.Compute [Test] public void TestFuncResultPrimitive1() { - ICollection<int> res = Grid1.GetCompute().Broadcast(new PortableFunc(), 10); + ICollection<int> res = Grid1.GetCompute().Broadcast(new BinarizableFunc(), 10); Assert.AreEqual(3, res.Count); @@ -216,7 +216,7 @@ namespace Apache.Ignite.Core.Tests.Compute /// <summary> /// Test function. /// </summary> - public class PortableFunc : IComputeFunc<int, int>, IUserInterface<int, int> + public class BinarizableFunc : IComputeFunc<int, int>, IUserInterface<int, int> { int IComputeFunc<int, int>.Invoke(int arg) { @@ -252,7 +252,7 @@ namespace Apache.Ignite.Core.Tests.Compute /// <summary> /// Test function. /// </summary> - public class PortableOutFunc : IComputeFunc<int> + public class BinarizableOutFunc : IComputeFunc<int> { public int Invoke() { @@ -291,9 +291,9 @@ namespace Apache.Ignite.Core.Tests.Compute IComputeJob<T> job; - if (res is PortableResult) + if (res is BinarizableResult) { - TestPortableJob job0 = new TestPortableJob(); + TestBinarizableJob job0 = new TestBinarizableJob(); job0.SetArguments(res); @@ -365,12 +365,12 @@ namespace Apache.Ignite.Core.Tests.Compute /// <summary> /// /// </summary> - class PortableResult + class BinarizableResult { /** */ public int Val; - public PortableResult(int val) + public BinarizableResult(int val) { Val = val; } @@ -398,7 +398,7 @@ namespace Apache.Ignite.Core.Tests.Compute class TestJob<T> : ComputeJobAdapter<T> { [InstanceResource] - private IIgnite _grid = null; + private readonly IIgnite _grid = null; /** <inheritDoc /> */ override public T Execute() @@ -416,19 +416,19 @@ namespace Apache.Ignite.Core.Tests.Compute /// <summary> /// /// </summary> - class TestPortableJob : ComputeJobAdapter<PortableResult> + class TestBinarizableJob : ComputeJobAdapter<BinarizableResult> { [InstanceResource] - private IIgnite _grid = null; + private readonly IIgnite _grid = null; /** <inheritDoc /> */ - override public PortableResult Execute() + override public BinarizableResult Execute() { Assert.IsNotNull(_grid); _gridName = _grid.Name; - PortableResult res = GetArgument<PortableResult>(0); + BinarizableResult res = GetArgument<BinarizableResult>(0); return res; } http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-grid1.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-grid1.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-grid1.xml index 0ad0070..e373b89 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-grid1.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/Compute/compute-grid1.xml @@ -67,16 +67,16 @@ </bean> </property> - <!-- Portable marshaller configuration --> + <!-- Binary marshaller configuration --> <property name="marshaller"> <bean class="org.apache.ignite.marshaller.portable.PortableMarshaller"> <property name="typeConfigurations"> <list> <bean class="org.apache.ignite.binary.BinaryTypeConfiguration"> - <property name="className" value="org.apache.ignite.platform.PlatformComputePortable"/> + <property name="className" value="org.apache.ignite.platform.PlatformComputeBinarizable"/> </bean> <bean class="org.apache.ignite.binary.BinaryTypeConfiguration"> - <property name="className" value="org.apache.ignite.platform.PlatformComputeJavaPortable"/> + <property name="className" value="org.apache.ignite.platform.PlatformComputeJavaBinarizable"/> </bean> <bean class="org.apache.ignite.binary.BinaryTypeConfiguration"> <property name="className" value="org.apache.ignite.platform.PlatformComputeEnum"/> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 6447b4e..ddedf40 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 @@ -61,20 +61,20 @@ <list> <value>Apache.Ignite.Core.Tests.ExecutableTest+RemoteConfiguration</value> <value>Apache.Ignite.Core.Tests.ExecutableTest+RemoteConfigurationClosure</value> - <value>Apache.Ignite.Core.Tests.Compute.TaskAdapterTest+PortableJob</value> - <value>Apache.Ignite.Core.Tests.Compute.PortableClosureTaskTest+PortableOutFunc</value> - <value>Apache.Ignite.Core.Tests.Compute.PortableClosureTaskTest+PortableFunc</value> - <value>Apache.Ignite.Core.Tests.Compute.PortableClosureTaskTest+PortableResult</value> - <value>Apache.Ignite.Core.Tests.Compute.PortableClosureTaskTest+PortableException</value> + <value>Apache.Ignite.Core.Tests.Compute.TaskAdapterTest+BinarizableJob</value> + <value>Apache.Ignite.Core.Tests.Compute.BinarizableClosureTaskTest+BinarizableOutFunc</value> + <value>Apache.Ignite.Core.Tests.Compute.BinarizableClosureTaskTest+BinarizableFunc</value> + <value>Apache.Ignite.Core.Tests.Compute.BinarizableClosureTaskTest+BinarizableResult</value> + <value>Apache.Ignite.Core.Tests.Compute.BinarizableClosureTaskTest+BinarizableException</value> </list> </property> <property name="typesConfiguration"> <list> <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetBinaryTypeConfiguration"> - <property name="typeName" value="org.apache.ignite.platform.PlatformComputePortable"/> + <property name="typeName" value="org.apache.ignite.platform.PlatformComputeBinarizable"/> </bean> <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetBinaryTypeConfiguration"> - <property name="typeName" value="org.apache.ignite.platform.PlatformComputeJavaPortable"/> + <property name="typeName" value="org.apache.ignite.platform.PlatformComputeJavaBinarizable"/> </bean> </list> </property> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/binary.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/binary.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/binary.xml new file mode 100644 index 0000000..f013749 --- /dev/null +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/binary.xml @@ -0,0 +1,56 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd"> + <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="localHost" value="127.0.0.1"/> + <property name="connectorConfiguration"><null/></property> + + <property name="gridName" value="grid"/> + + <property name="metricsUpdateFrequency" value="1000"/> + <property name="metricsLogFrequency" value="0"/> + + <property name="cacheConfiguration"> + <list> + <bean class="org.apache.ignite.configuration.CacheConfiguration"> + <property name="name" value="cache"/> + </bean> + </list> + </property> + + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses"> + <list> + <!-- In distributed environment, replace with actual host IP address. --> + <value>127.0.0.1:47500..47502</value> + </list> + </property> + </bean> + </property> + </bean> + </property> + </bean> +</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-binarizables.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-binarizables.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-binarizables.xml new file mode 100644 index 0000000..a31a450 --- /dev/null +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-binarizables.xml @@ -0,0 +1,78 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xmlns:util="http://www.springframework.org/schema/util" + xsi:schemaLocation=" + http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd + http://www.springframework.org/schema/util + http://www.springframework.org/schema/util/spring-util.xsd"> + <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="localHost" value="127.0.0.1"/> + <property name="connectorConfiguration"><null/></property> + + <property name="platformConfiguration"> + <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetConfiguration"> + <property name="binaryConfiguration"> + <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetBinaryConfiguration"> + <property name="types"> + <list> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Type]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64]]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Collections.Generic.List[System.Tuple[System.Int64,System.String]]]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64,System.String]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64,Apache.Ignite.Core.Tests.TestGenericBinarizable[System.String]]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64,System.String,System.Type]</value> + <value>Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64,System.String,Apache.Ignite.Core.Tests.TestGenericBinarizable[System.Int64,System.String,System.Type]]</value> + </list> + </property> + </bean> + </property> + </bean> + </property> + + <property name="includeEventTypes"> + <util:constant static-field="org.apache.ignite.events.EventType.EVTS_CACHE"/> + </property> + + <property name="cacheConfiguration"> + <list> + <bean class="org.apache.ignite.configuration.CacheConfiguration" /> + </list> + </property> + + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses"> + <list> + <!-- In distributed environment, replace with actual host IP address. --> + <value>127.0.0.1:47500..47501</value> + </list> + </property> + </bean> + </property> + </bean> + </property> + </bean> +</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 deleted file mode 100644 index 26bf87b..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-portables.xml +++ /dev/null @@ -1,78 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> - -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---> - -<beans xmlns="http://www.springframework.org/schema/beans" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xmlns:util="http://www.springframework.org/schema/util" - xsi:schemaLocation=" - http://www.springframework.org/schema/beans - http://www.springframework.org/schema/beans/spring-beans.xsd - http://www.springframework.org/schema/util - http://www.springframework.org/schema/util/spring-util.xsd"> - <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> - <property name="localHost" value="127.0.0.1"/> - <property name="connectorConfiguration"><null/></property> - - <property name="platformConfiguration"> - <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetConfiguration"> - <property name="binaryConfiguration"> - <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetBinaryConfiguration"> - <property name="types"> - <list> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Type]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64]]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Collections.Generic.List[System.Tuple[System.Int64,System.String]]]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64,System.String]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64,Apache.Ignite.Core.Tests.TestGenericPortable[System.String]]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64,System.String,System.Type]</value> - <value>Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64,System.String,Apache.Ignite.Core.Tests.TestGenericPortable[System.Int64,System.String,System.Type]]</value> - </list> - </property> - </bean> - </property> - </bean> - </property> - - <property name="includeEventTypes"> - <util:constant static-field="org.apache.ignite.events.EventType.EVTS_CACHE"/> - </property> - - <property name="cacheConfiguration"> - <list> - <bean class="org.apache.ignite.configuration.CacheConfiguration" /> - </list> - </property> - - <property name="discoverySpi"> - <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> - <property name="ipFinder"> - <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> - <property name="addresses"> - <list> - <!-- In distributed environment, replace with actual host IP address. --> - <value>127.0.0.1:47500..47501</value> - </list> - </property> - </bean> - </property> - </bean> - </property> - </bean> -</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query-continuous.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query-continuous.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query-continuous.xml index 7f9ce40..86a46e4 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query-continuous.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/cache-query-continuous.xml @@ -40,7 +40,7 @@ <property name="typeMetadata"> <list> <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="PortableEntry"/> + <property name="valueType" value="BinarizableEntry"/> <property name="ascendingFields"> <map> <entry key="val" value="java.lang.Integer"/> @@ -70,7 +70,7 @@ <property name="typeMetadata"> <list> <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="PortableEntry"/> + <property name="valueType" value="BinarizableEntry"/> <property name="ascendingFields"> <map> <entry key="val" value="java.lang.Integer"/> @@ -100,7 +100,7 @@ <property name="typeMetadata"> <list> <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="PortableEntry"/> + <property name="valueType" value="BinarizableEntry"/> <property name="ascendingFields"> <map> <entry key="val" value="java.lang.Integer"/> @@ -130,7 +130,7 @@ <property name="typeMetadata"> <list> <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="PortableEntry"/> + <property name="valueType" value="BinarizableEntry"/> <property name="ascendingFields"> <map> <entry key="val" value="java.lang.Integer"/> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-explicit.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-explicit.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-explicit.xml new file mode 100644 index 0000000..11b87bd --- /dev/null +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-explicit.xml @@ -0,0 +1,47 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd"> + <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="localHost" value="127.0.0.1"/> + <property name="connectorConfiguration"><null/></property> + + <property name="marshaller"> + <bean class="org.apache.ignite.marshaller.portable.PortableMarshaller" /> + </property> + + <property name="discoverySpi"> + <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses"> + <list> + <!-- In distributed environment, replace with actual host IP address. --> + <value>127.0.0.1:47500..47502</value> + </list> + </property> + </bean> + </property> + </bean> + </property> + </bean> +</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-portable.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-portable.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-portable.xml deleted file mode 100644 index 753fad1..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/marshaller-portable.xml +++ /dev/null @@ -1,43 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> - -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---> - -<beans xmlns="http://www.springframework.org/schema/beans" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://www.springframework.org/schema/beans - http://www.springframework.org/schema/beans/spring-beans.xsd"> - <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> - <property name="localHost" value="127.0.0.1"/> - <property name="connectorConfiguration"><null/></property> - - <property name="discoverySpi"> - <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> - <property name="ipFinder"> - <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> - <property name="addresses"> - <list> - <!-- In distributed environment, replace with actual host IP address. --> - <value>127.0.0.1:47500..47502</value> - </list> - </property> - </bean> - </property> - </bean> - </property> - </bean> -</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml index 6845a3c..c2bf78c 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml @@ -36,7 +36,7 @@ <property name="cacheConfiguration"> <list> <bean class="org.apache.ignite.configuration.CacheConfiguration"> - <property name="name" value="portable_store"/> + <property name="name" value="binary_store"/> <property name="cacheMode" value="LOCAL"/> <property name="atomicityMode" value="TRANSACTIONAL"/> <property name="writeThrough" value="true"/> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml index c48e867..d8d4553 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml @@ -139,56 +139,5 @@ <property name="swapEnabled" value="true"/> <property name="backups" value="1"/> <property name="eagerTtl" value="true"/> - - <!-- - <property name="typeMetadata"> - <list> - <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="GridPortablePerson"/> - <property name="ascendingFields"> - <map> - <entry key="age" value="java.lang.Integer"/> - </map> - </property> - <property name="queryFields"> - <map> - <entry key="name" value="java.lang.String"/> - </map> - </property> - <property name="textFields"> - <list> - <value>address</value> - </list> - </property> - </bean> - <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="GridImplicitPortablePerson"/> - <property name="ascendingFields"> - <map> - <entry key="age" value="java.lang.Integer"/> - </map> - </property> - <property name="queryFields"> - <map> - <entry key="name" value="java.lang.String"/> - </map> - </property> - </bean> - <bean class="org.apache.ignite.cache.CacheTypeMetadata"> - <property name="valueType" value="GridNoDefPortablePerson"/> - <property name="ascendingFields"> - <map> - <entry key="age" value="java.lang.Integer"/> - </map> - </property> - <property name="queryFields"> - <map> - <entry key="name" value="java.lang.String"/> - </map> - </property> - </bean> - </list> - </property> - --> </bean> </beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml deleted file mode 100644 index f013749..0000000 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml +++ /dev/null @@ -1,56 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> - -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---> - -<beans xmlns="http://www.springframework.org/schema/beans" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://www.springframework.org/schema/beans - http://www.springframework.org/schema/beans/spring-beans.xsd"> - <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> - <property name="localHost" value="127.0.0.1"/> - <property name="connectorConfiguration"><null/></property> - - <property name="gridName" value="grid"/> - - <property name="metricsUpdateFrequency" value="1000"/> - <property name="metricsLogFrequency" value="0"/> - - <property name="cacheConfiguration"> - <list> - <bean class="org.apache.ignite.configuration.CacheConfiguration"> - <property name="name" value="cache"/> - </bean> - </list> - </property> - - <property name="discoverySpi"> - <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> - <property name="ipFinder"> - <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> - <property name="addresses"> - <list> - <!-- In distributed environment, replace with actual host IP address. --> - <value>127.0.0.1:47500..47502</value> - </list> - </property> - </bean> - </property> - </bean> - </property> - </bean> -</beans> http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 2f9f6c9..20ae629 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs @@ -383,7 +383,7 @@ namespace Apache.Ignite.Core.Tests.Dataload [Test] public void TestStreamReceiver() { - TestStreamReceiver(new StreamReceiverPortable()); + TestStreamReceiver(new StreamReceiverBinarizable()); TestStreamReceiver(new StreamReceiverSerializable()); } @@ -403,7 +403,7 @@ namespace Apache.Ignite.Core.Tests.Dataload public void TestStreamTransformer() { TestStreamReceiver(new StreamTransformer<int, int, int, int>(new EntryProcessorSerializable())); - TestStreamReceiver(new StreamTransformer<int, int, int, int>(new EntryProcessorPortable())); + TestStreamReceiver(new StreamTransformer<int, int, int, int>(new EntryProcessorBinarizable())); } /// <summary> @@ -415,7 +415,7 @@ namespace Apache.Ignite.Core.Tests.Dataload { ldr.AllowOverwrite = true; - ldr.Receiver = new StreamReceiverPortable(); + ldr.Receiver = new StreamReceiverBinarizable(); ldr.Receiver = receiver; // check double assignment @@ -432,23 +432,23 @@ namespace Apache.Ignite.Core.Tests.Dataload } /// <summary> - /// Tests the stream receiver in keepPortable mode. + /// Tests the stream receiver in keepBinary mode. /// </summary> [Test] - public void TestStreamReceiverKeepPortable() + public void TestStreamReceiverKeepBinary() { // ReSharper disable once LocalVariableHidesMember - var cache = _grid.GetCache<int, PortableEntry>(CacheName); + var cache = _grid.GetCache<int, BinarizableEntry>(CacheName); using (var ldr0 = _grid.GetDataStreamer<int, int>(CacheName)) using (var ldr = ldr0.WithKeepBinary<int, IBinaryObject>()) { - ldr.Receiver = new StreamReceiverKeepPortable(); + ldr.Receiver = new StreamReceiverKeepBinary(); ldr.AllowOverwrite = true; for (var i = 0; i < 100; i++) - ldr.AddData(i, _grid.GetBinary().ToBinary<IBinaryObject>(new PortableEntry {Val = i})); + ldr.AddData(i, _grid.GetBinary().ToBinary<IBinaryObject>(new BinarizableEntry {Val = i})); ldr.Flush(); @@ -474,9 +474,9 @@ namespace Apache.Ignite.Core.Tests.Dataload { new BinaryTypeConfiguration(typeof (CacheTestKey)), new BinaryTypeConfiguration(typeof (TestReferenceObject)), - new BinaryTypeConfiguration(typeof (StreamReceiverPortable)), - new BinaryTypeConfiguration(typeof (EntryProcessorPortable)), - new BinaryTypeConfiguration(typeof (PortableEntry)) + new BinaryTypeConfiguration(typeof (StreamReceiverBinarizable)), + new BinaryTypeConfiguration(typeof (EntryProcessorBinarizable)), + new BinaryTypeConfiguration(typeof (BinarizableEntry)) } }, JvmOptions = TestUtils.TestJavaOptions().Concat(new[] @@ -497,9 +497,9 @@ namespace Apache.Ignite.Core.Tests.Dataload } /// <summary> - /// Test portable receiver. + /// Test binarizable receiver. /// </summary> - private class StreamReceiverPortable : IStreamReceiver<int, int> + private class StreamReceiverBinarizable : IStreamReceiver<int, int> { /** <inheritdoc /> */ public void Receive(ICache<int, int> cache, ICollection<ICacheEntry<int, int>> entries) @@ -509,20 +509,20 @@ namespace Apache.Ignite.Core.Tests.Dataload } /// <summary> - /// Test portable receiver. + /// Test binary receiver. /// </summary> [Serializable] - private class StreamReceiverKeepPortable : IStreamReceiver<int, IBinaryObject> + private class StreamReceiverKeepBinary : IStreamReceiver<int, IBinaryObject> { /** <inheritdoc /> */ public void Receive(ICache<int, IBinaryObject> cache, ICollection<ICacheEntry<int, IBinaryObject>> entries) { - var portables = cache.Ignite.GetBinary(); + var binary = cache.Ignite.GetBinary(); cache.PutAll(entries.ToDictionary(x => x.Key, x => - portables.ToBinary<IBinaryObject>(new PortableEntry + binary.ToBinary<IBinaryObject>(new BinarizableEntry { - Val = x.Value.Deserialize<PortableEntry>().Val + 1 + Val = x.Value.Deserialize<BinarizableEntry>().Val + 1 }))); } } @@ -558,7 +558,7 @@ namespace Apache.Ignite.Core.Tests.Dataload /// <summary> /// Test entry processor. /// </summary> - private class EntryProcessorPortable : ICacheEntryProcessor<int, int, int, int>, IBinarizable + private class EntryProcessorBinarizable : ICacheEntryProcessor<int, int, int, int>, IBinarizable { /** <inheritdoc /> */ public int Process(IMutableCacheEntry<int, int> entry, int arg) @@ -582,9 +582,9 @@ namespace Apache.Ignite.Core.Tests.Dataload } /// <summary> - /// Portablecache entry. + /// Binarizable entry. /// </summary> - private class PortableEntry + private class BinarizableEntry { public int Val { get; set; } } http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 403f8a7..9f22355 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs @@ -365,7 +365,7 @@ namespace Apache.Ignite.Core.Tests [Test] public void TestRemoteListen( [Values(true, false)] bool async, - [Values(true, false)] bool portable, + [Values(true, false)] bool binarizable, [Values(true, false)] bool autoUnsubscribe) { foreach (var g in _grids) @@ -378,8 +378,8 @@ namespace Apache.Ignite.Core.Tests var expectedType = EventType.JobStarted; - var remoteFilter = portable - ? (IEventFilter<IEvent>) new RemoteEventPortableFilter(expectedType) + var remoteFilter = binary + ? (IEventFilter<IEvent>) new RemoteEventBinarizableFilter(expectedType) : new RemoteEventFilter(expectedType); var localListener = EventsTestHelper.GetListener(); @@ -616,7 +616,7 @@ namespace Apache.Ignite.Core.Tests { TypeConfigurations = new List<BinaryTypeConfiguration> { - new BinaryTypeConfiguration(typeof (RemoteEventPortableFilter)) + new BinaryTypeConfiguration(typeof (RemoteEventBinarizableFilter)) } } }; @@ -882,18 +882,18 @@ namespace Apache.Ignite.Core.Tests } /// <summary> - /// Portable remote event filter. + /// Binary remote event filter. /// </summary> - public class RemoteEventPortableFilter : IEventFilter<IEvent>, IBinarizable + public class RemoteEventBinarizableFilter : IEventFilter<IEvent>, IBinarizable { /** */ private int _type; /// <summary> - /// Initializes a new instance of the <see cref="RemoteEventPortableFilter"/> class. + /// Initializes a new instance of the <see cref="RemoteEventBinarizableFilter"/> class. /// </summary> /// <param name="type">The event type.</param> - public RemoteEventPortableFilter(int type) + public RemoteEventBinarizableFilter(int type) { _type = type; } http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 196d8ae..79297da 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/ExceptionsTest.cs @@ -107,18 +107,18 @@ namespace Apache.Ignite.Core.Tests TestPartialUpdateException(false, (x, g) => x); // User type - TestPartialUpdateException(false, (x, g) => new PortableEntry(x)); + TestPartialUpdateException(false, (x, g) => new BinarizableEntry(x)); } /// <summary> - /// Tests CachePartialUpdateException keys propagation in portable mode. + /// Tests CachePartialUpdateException keys propagation in binary mode. /// </summary> [Test] [Category(TestUtils.CategoryIntensive)] - public void TestPartialUpdateExceptionPortable() + public void TestPartialUpdateExceptionBinarizable() { // User type - TestPartialUpdateException(false, (x, g) => g.GetBinary().ToBinary<IBinaryObject>(new PortableEntry(x))); + TestPartialUpdateException(false, (x, g) => g.GetBinary().ToBinary<IBinaryObject>(new BinarizableEntry(x))); } /// <summary> @@ -195,17 +195,17 @@ namespace Apache.Ignite.Core.Tests TestPartialUpdateException(true, (x, g) => x); // User type - TestPartialUpdateException(true, (x, g) => new PortableEntry(x)); + TestPartialUpdateException(true, (x, g) => new BinarizableEntry(x)); } /// <summary> - /// Tests CachePartialUpdateException keys propagation in portable mode. + /// Tests CachePartialUpdateException keys propagation in binary mode. /// </summary> [Test] [Category(TestUtils.CategoryIntensive)] - public void TestPartialUpdateExceptionAsyncPortable() + public void TestPartialUpdateExceptionAsyncBinarizable() { - TestPartialUpdateException(true, (x, g) => g.GetBinary().ToBinary<IBinaryObject>(new PortableEntry(x))); + TestPartialUpdateException(true, (x, g) => g.GetBinary().ToBinary<IBinaryObject>(new BinarizableEntry(x))); } /// <summary> @@ -295,16 +295,16 @@ namespace Apache.Ignite.Core.Tests { TypeConfigurations = new[] { - new BinaryTypeConfiguration(typeof (PortableEntry)) + new BinaryTypeConfiguration(typeof (BinarizableEntry)) } } }); } /// <summary> - /// Portable entry. + /// Binarizable entry. /// </summary> - private class PortableEntry + private class BinarizableEntry { /** Value. */ private readonly int _val; @@ -319,7 +319,7 @@ namespace Apache.Ignite.Core.Tests /// Constructor. /// </summary> /// <param name="val">Value.</param> - public PortableEntry(int val) + public BinarizableEntry(int val) { _val = val; } @@ -327,12 +327,12 @@ namespace Apache.Ignite.Core.Tests /** <inheritDoc /> */ public override bool Equals(object obj) { - return obj is PortableEntry && ((PortableEntry)obj)._val == _val; + return obj is BinarizableEntry && ((BinarizableEntry)obj)._val == _val; } } /// <summary> - /// Portable entry. + /// Serializable entry. /// </summary> [Serializable] private class SerializableEntry http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/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 e32f49a..f18be8c 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/FutureTest.cs @@ -52,7 +52,7 @@ namespace Apache.Ignite.Core.Tests BinaryConfiguration = new BinaryConfiguration { TypeConfigurations = - new List<BinaryTypeConfiguration> { new BinaryTypeConfiguration(typeof(Portable)) } + new List<BinaryTypeConfiguration> { new BinaryTypeConfiguration(typeof(Binarizable)) } } }); @@ -107,7 +107,7 @@ namespace Apache.Ignite.Core.Tests TestType(18m); // decimal - TestType(new Portable { A = 10, B = "foo" }); + TestType(new Binarizable { A = 10, B = "foo" }); } /// <summary> @@ -123,9 +123,9 @@ namespace Apache.Ignite.Core.Tests } /// <summary> - /// Portable test class. + /// Binary test class. /// </summary> - private class Portable : IBinarizable + private class Binarizable : IBinarizable { public int A; public string B; @@ -156,7 +156,7 @@ namespace Apache.Ignite.Core.Tests if (obj.GetType() != GetType()) return false; - var other = (Portable)obj; + var other = (Binarizable)obj; return A == other.A && string.Equals(B, other.B); } http://git-wip-us.apache.org/repos/asf/ignite/blob/d69362f8/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MarshallerTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MarshallerTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MarshallerTest.cs index d3af288..541de0c 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MarshallerTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MarshallerTest.cs @@ -27,7 +27,7 @@ namespace Apache.Ignite.Core.Tests { /// <summary> /// Tests the default marhsaller. - /// By default, portable marshaller is used. + /// By default, binary marshaller is used. /// </summary> [Test] public void TestDefaultMarhsaller() @@ -43,13 +43,13 @@ namespace Apache.Ignite.Core.Tests } /// <summary> - /// Tests the portable marhsaller. - /// PortableMarshaller can be specified explicitly in config. + /// Tests the binary marhsaller. + /// Marshaller can be specified explicitly in config. /// </summary> [Test] - public void TestPortableMarhsaller() + public void TestExplicitMarhsaller() { - using (var grid = Ignition.Start("config\\marshaller-portable.xml")) + using (var grid = Ignition.Start("config\\marshaller-explicit.xml")) { var cache = grid.GetOrCreateCache<int, int>(null);