forked from msgpack/msgpack-cli
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathByteArrayPackerTest.cs
More file actions
104 lines (91 loc) · 3.15 KB
/
ByteArrayPackerTest.cs
File metadata and controls
104 lines (91 loc) · 3.15 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
#region -- License Terms --
//
// MessagePack for CLI
//
// Copyright (C) 2017 FUJIWARA, Yusuke
//
// Licensed 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.
//
#endregion -- License Terms --
using System;
using System.IO;
using System.Linq;
#if !MSTEST
using NUnit.Framework;
#else
using TestFixtureAttribute = Microsoft.VisualStudio.TestPlatform.UnitTestFramework.TestClassAttribute;
using TestAttribute = Microsoft.VisualStudio.TestPlatform.UnitTestFramework.TestMethodAttribute;
using TimeoutAttribute = NUnit.Framework.TimeoutAttribute;
using Assert = NUnit.Framework.Assert;
using Is = NUnit.Framework.Is;
#endif
namespace MsgPack
{
[TestFixture]
[Timeout( 1000 )]
public partial class ByteArrayPackerTest : PackerTest
{
protected override Packer CreatePacker( MemoryStream stream )
{
Assert.That( stream.Position, Is.EqualTo( 0 ) );
return Packer.Create( new byte[ 64 * 1024 ] );
}
protected override Packer CreatePacker( MemoryStream stream, PackerCompatibilityOptions compatibilityOptions )
{
Assert.That( stream.Position, Is.EqualTo( 0 ) );
return Packer.Create( new byte[ 64 * 1024 ], true, compatibilityOptions );
}
private static ByteArrayPacker CreatePacker( byte[] buffer, int startOffset, bool allowsBufferExtension )
{
return Packer.Create( buffer, startOffset, allowsBufferExtension, PackerCompatibilityOptions.None );
}
private static ByteArrayPacker CreatePacker( byte[] buffer, int startOffset, Func<byte[], int, byte[]> allocator )
{
return Packer.Create( buffer, startOffset, allocator, PackerCompatibilityOptions.None );
}
protected override byte[] GetResult( Packer packer )
{
return ( ( ByteArrayPacker )packer ).GetResultBytes().ToArray();
}
private sealed class Allocator
{
public int LastAllocationSize { get; private set; }
public bool IsAllocateCalled { get; set; }
public bool IsReallocateCalled { get; set; }
public bool IsOnlyAllocateCalled()
{
return this.IsAllocateCalled && !this.IsReallocateCalled;
}
public bool IsOnlyReallocateCalled()
{
return !this.IsAllocateCalled && this.IsReallocateCalled;
}
public ArraySegment<byte> Allocate( int size )
{
this.IsAllocateCalled = true;
int actualSize = Math.Max( size, 16 );
this.LastAllocationSize = actualSize;
return new ArraySegment<byte>( new byte[ actualSize ] );
}
public byte[] Reallocate( byte[] old, int size )
{
this.IsReallocateCalled = true;
int actualSize = old.Length + Math.Max( size, 16 );
this.LastAllocationSize = actualSize;
var result = new byte[ actualSize ];
Buffer.BlockCopy( old, 0, result, 0, old.Length );
return result;
}
}
}
}