// 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. using Apache.Arrow.Tests.Fixtures; using System; using System.Runtime.InteropServices; using Xunit; namespace Apache.Arrow.Tests { public class ArrowBufferTests { public class Allocate : IClassFixture { private readonly DefaultMemoryAllocatorFixture _memoryPoolFixture; public Allocate(DefaultMemoryAllocatorFixture memoryPoolFixture) { _memoryPoolFixture = memoryPoolFixture; } /// /// Ensure Arrow buffers are allocated in multiples of 64 bytes. /// /// number of bytes to allocate /// expected buffer capacity after allocation [Theory] [InlineData(0, 0)] [InlineData(1, 64)] [InlineData(8, 64)] [InlineData(9, 64)] [InlineData(65, 128)] public void AllocatesWithExpectedPadding(int size, int expectedCapacity) { var builder = new ArrowBuffer.Builder(size); for (int i = 0; i < size; i++) { builder.Append(0); } var buffer = builder.Build(); Assert.Equal(expectedCapacity, buffer.Length); } /// /// Ensure allocated buffers are aligned to multiples of 64. /// [Theory] [InlineData(1)] [InlineData(8)] [InlineData(64)] [InlineData(128)] public unsafe void AllocatesAlignedToMultipleOf64(int size) { var builder = new ArrowBuffer.Builder(size); for (int i = 0; i < size; i++) { builder.Append(0); } var buffer = builder.Build(); fixed (byte* ptr = &buffer.Span.GetPinnableReference()) { Assert.True(new IntPtr(ptr).ToInt64() % 64 == 0); } } /// /// Ensure padding in arrow buffers is initialized with zeroes. /// [Fact] public void HasZeroPadding() { var buffer = new ArrowBuffer.Builder(10).Append(0).Build(); foreach (var b in buffer.Span) { Assert.Equal(0, b); } } } [Fact] public void TestExternalMemoryWrappedAsArrowBuffer() { Memory memory = new byte[sizeof(int) * 3]; Span spanOfBytes = memory.Span; var span = spanOfBytes.CastTo(); span[0] = 0; span[1] = 1; span[2] = 2; ArrowBuffer buffer = new ArrowBuffer(memory); Assert.Equal(2, buffer.Span.CastTo()[2]); span[2] = 10; Assert.Equal(10, buffer.Span.CastTo()[2]); } } }