http://git-wip-us.apache.org/repos/asf/ignite/blob/7b61a097/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Memory/InteropMemoryTest.cs ---------------------------------------------------------------------- diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Memory/InteropMemoryTest.cs b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Memory/InteropMemoryTest.cs new file mode 100644 index 0000000..e32e622 --- /dev/null +++ b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Memory/InteropMemoryTest.cs @@ -0,0 +1,213 @@ +/* + * 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.Memory +{ + using System; + using Apache.Ignite.Core.Impl.Memory; + using NUnit.Framework; + + /// <summary> + /// Tests for interop memory. + /// </summary> + public class InteropMemoryTest + { + /// <summary> + /// Test pooled memory. + /// </summary> + [Test] + public void TestPooled() + { + PlatformMemoryManager mgr = new PlatformMemoryManager(256); + + var mem1 = mgr.Allocate(); + Assert.IsTrue(mem1 is PlatformPooledMemory); + Assert.IsTrue(mem1.Capacity >= 256); + Assert.IsTrue(mem1.Pointer > 0); + Assert.IsTrue(mem1.Data > 0); + Assert.AreEqual(0, mem1.Length); + + mem1.Reallocate(512); + + Assert.IsTrue(mem1.Capacity >= 512); + Assert.IsTrue(mem1.Pointer > 0); + Assert.IsTrue(mem1.Data > 0); + Assert.AreEqual(0, mem1.Length); + + mem1.Length = 128; + Assert.AreEqual(128, mem1.Length); + + mem1.Release(); + + Assert.AreSame(mem1, mgr.Allocate()); + Assert.IsTrue(mem1.Capacity >= 512); + Assert.IsTrue(mem1.Pointer > 0); + Assert.IsTrue(mem1.Data > 0); + Assert.AreEqual(128, mem1.Length); + + IPlatformMemory mem2 = mgr.Allocate(); + Assert.IsTrue(mem2 is PlatformPooledMemory); + + IPlatformMemory mem3 = mgr.Allocate(); + Assert.IsTrue(mem3 is PlatformPooledMemory); + + mem1.Release(); + Assert.AreSame(mem1, mgr.Allocate()); + + mem2.Release(); + Assert.AreSame(mem2, mgr.Allocate()); + + mem3.Release(); + Assert.AreSame(mem3, mgr.Allocate()); + + mem1.Release(); + mem2.Release(); + + Assert.AreSame(mem1, mgr.Allocate()); + Assert.AreSame(mem2, mgr.Allocate()); + + IPlatformMemory unpooled = mgr.Allocate(); + + try + { + Assert.IsTrue(unpooled is PlatformUnpooledMemory); + } + finally + { + unpooled.Release(); + } + } + + /// <summary> + /// Test unpooled memory. + /// </summary> + [Test] + public void TestUnpooled() + { + PlatformMemoryManager mgr = new PlatformMemoryManager(256); + + for (int i = 0; i < 3; i++) + mgr.Allocate(); + + IPlatformMemory mem1 = mgr.Allocate(); + Assert.IsTrue(mem1 is PlatformUnpooledMemory); + Assert.IsTrue(mem1.Capacity >= 256); + Assert.IsTrue(mem1.Pointer > 0); + Assert.IsTrue(mem1.Data > 0); + Assert.AreEqual(0, mem1.Length); + + mem1.Reallocate(512); + Assert.IsTrue(mem1.Capacity >= 512); + Assert.IsTrue(mem1.Pointer > 0); + Assert.IsTrue(mem1.Data > 0); + Assert.AreEqual(0, mem1.Length); + + mem1.Length = 128; + Assert.AreEqual(128, mem1.Length); + + mem1.Release(); + + IPlatformMemory mem2 = mgr.Allocate(); + Assert.AreNotSame(mem1, mem2); + Assert.IsTrue(mem2.Capacity >= 256); + Assert.IsTrue(mem2.Pointer > 0); + Assert.IsTrue(mem2.Data > 0); + Assert.AreEqual(0, mem2.Length); + + mem2.Release(); + } + + /// <summary> + /// Test pooled memory stream reallocation initiated from stream. + /// </summary> + [Test] + public void TestPooledStreamReallocate() + { + IPlatformMemory mem = new PlatformMemoryManager(256).Allocate(); + + try + { + Assert.IsTrue(mem is PlatformPooledMemory); + + CheckStreamReallocate(mem); + } + finally + { + mem.Release(); + } + } + + /// <summary> + /// Test unpooled memory stream reallocation initiated from stream. + /// </summary> + [Test] + public void TestUnpooledStreamReallocate() + { + PlatformMemoryManager mgr = new PlatformMemoryManager(256); + + for (int i = 0; i < 3; i++) + mgr.Allocate(); + + IPlatformMemory mem = mgr.Allocate(); + + try + { + Assert.IsTrue(mem is PlatformUnpooledMemory); + + CheckStreamReallocate(mem); + } + finally + { + mem.Release(); + } + } + + /// <summary> + /// Check stream reallocation. + /// </summary> + /// <param name="mem">Memory.</param> + private void CheckStreamReallocate(IPlatformMemory mem) + { + Assert.IsTrue(mem.Capacity >= 256); + + int dataLen = 2048 + 13; + + Random rand = new Random(); + + byte[] data = new byte[dataLen]; + + for (int i = 0; i < data.Length; i++) + data[i] = (byte)rand.Next(0, 255); + + PlatformMemoryStream stream = mem.Stream(); + + stream.WriteByteArray(data); + + stream.SynchronizeOutput(); + + Assert.IsTrue(mem.Capacity >= dataLen); + + stream.Reset(); + + stream.SynchronizeInput(); + + byte[] data0 = stream.ReadByteArray(dataLen); + + Assert.AreEqual(data, data0); + } + } +}
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b61a097/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/TestRunner.cs ---------------------------------------------------------------------- diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/TestRunner.cs b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/TestRunner.cs index feb91bc..73c9bcb 100644 --- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/TestRunner.cs +++ b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/TestRunner.cs @@ -31,9 +31,9 @@ namespace Apache.Ignite.Core.Tests //TestOne(typeof(ContinuousQueryAtomiclBackupTest), "TestInitialQuery"); - TestAll(typeof(IgnitionTest)); + //TestAll(typeof(IgnitionTest)); - //TestAllInAssembly(); + TestAllInAssembly(); } private static void TestOne(Type testClass, string method)
